In Java Springboot app, i’m publishing message to GCP Pub Sub and it is getting failed sometimes with DeadlineExceeded exception. Can someone please advise me on best retry approach.
Publishing message to GCP Pub sub. Below is the code
<code>publisher = Publisher.newBuilder(topicName).build();
ByteString data = ByteString.copyFromUtf8(message);
// Invoking the gpsAttrEnrichment in Core lib
PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data)
.putAllAttributes(gpsAttrEnrichment.getOrganizationValue(orgs.get(index),
envKey, document, jsonObject))
.build();
ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
String messageId = messageIdFuture.get();
ContentBasedRouterProcessor.log.info("Published message ID: " + messageId);
</code>
<code>publisher = Publisher.newBuilder(topicName).build();
ByteString data = ByteString.copyFromUtf8(message);
// Invoking the gpsAttrEnrichment in Core lib
PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data)
.putAllAttributes(gpsAttrEnrichment.getOrganizationValue(orgs.get(index),
envKey, document, jsonObject))
.build();
ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
String messageId = messageIdFuture.get();
ContentBasedRouterProcessor.log.info("Published message ID: " + messageId);
</code>
publisher = Publisher.newBuilder(topicName).build();
ByteString data = ByteString.copyFromUtf8(message);
// Invoking the gpsAttrEnrichment in Core lib
PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data)
.putAllAttributes(gpsAttrEnrichment.getOrganizationValue(orgs.get(index),
envKey, document, jsonObject))
.build();
ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
String messageId = messageIdFuture.get();
ContentBasedRouterProcessor.log.info("Published message ID: " + messageId);
New contributor
StabhinJoel Santhakumar is a new contributor to this site. Take care in asking for clarification, commenting, and answering.
Check out our Code of Conduct.