Interface PublisherInterface (1.129.6)

Version 1.129.6

• 1.134.1 (latest)
• 1.133.1
• 1.132.2
• 1.131.0
• 1.130.0
• 1.129.6
• 1.127.3
• 1.126.6
• 1.125.13
• 1.123.18
• 1.122.2
• 1.121.1
• 1.120.24
• 1.119.1
• 1.118.0
• 1.117.0
• 1.116.4
• 1.115.5

public interface PublisherInterface

An interface for a Cloud Pub/Sub publisher.

Methods

publish(PubsubMessage message)

public abstract ApiFuture<String> publish(PubsubMessage message)

Schedules the publishing of a message. The future will be returned with the message ID on success or an exception on failure.

Some implementations of this method may block in the downcall until allowed by flow control.

Example of publishing a message.

 String message = "my_message";
 ByteString data = ByteString.copyFromUtf8(message);
 PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build();
 ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
 ApiFutures.addCallback(messageIdFuture, new ApiFutureCallback<String>() {
   public void onSuccess(String messageId) {
     System.out.println("published with message id: " + messageId);
   }

   public void onFailure(Throwable t) {
     System.out.println("failed to publish: " + t);
   }
 }, MoreExecutors.directExecutor());
 

Parameter
Name	Description
message	PubsubMessage the message to publish.

Returns
Type	Description
ApiFuture<String>	the message ID wrapped in a future.