Class Subscriber (1.135.0)

public class Subscriber extends AbstractApiService implements SubscriberInterface

A Cloud Pub/Sub subscriber that is associated with a specific subscription at creation.

A Subscriber allows you to provide an implementation of a receiver to which messages are going to be delivered as soon as they are received by the subscriber. The delivered messages then can be acked or nacked at will as they get processed by the receiver. Nacking a messages implies a later redelivery of such message.

The subscriber handles the ack management, by automatically extending the ack deadline while the message is being processed, to then issue the ack or nack of such message when the processing is done (see Builder#setMaxAckExtensionPeriod(Duration)). Note: message redelivery is still possible.

It also provides customizable options that control:

Ack deadline extension: such as the amount of time ahead to trigger the extension of message acknowledgement expiration.
Flow control: such as the maximum outstanding messages or maximum outstanding bytes to keep in memory before the receiver either ack or nack them.

Subscriber will use the credentials set on the channel, which uses application default credentials through GoogleCredentials#getApplicationDefault by default.

Subscriber is implemented using Guava's Service and provides the same methods. See Guava documentation for more details.

Inheritance

java.lang.Object > AbstractApiService > Subscriber

Implements

SubscriberInterface

Inherited Members

AbstractApiService.addListener(ApiService.Listener,Executor)

AbstractApiService.awaitRunning()

AbstractApiService.awaitRunning(long,TimeUnit)

AbstractApiService.awaitTerminated()

AbstractApiService.awaitTerminated(long,TimeUnit)

AbstractApiService.doStart()

AbstractApiService.doStop()

AbstractApiService.failureCause()

AbstractApiService.isRunning()

AbstractApiService.notifyFailed(Throwable)

AbstractApiService.notifyStarted()

AbstractApiService.notifyStopped()

AbstractApiService.startAsync()

AbstractApiService.state()

AbstractApiService.stopAsync()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Methods

getDeliveryAttempt(PubsubMessage message)

public static Integer getDeliveryAttempt(PubsubMessage message)

Returns the delivery attempt count for a received PubsubMessage

Parameter
Name	Description
`message`	`PubsubMessage`

Returns
Type	Description
`Integer`

newBuilder(ProjectSubscriptionName subscription, MessageReceiver receiver)

public static Subscriber.Builder newBuilder(ProjectSubscriptionName subscription, MessageReceiver receiver)

Constructs a new Builder.

Parameters
Name	Description
`subscription`	`ProjectSubscriptionName` Cloud Pub/Sub subscription to bind the subscriber to
`receiver`	`MessageReceiver` an implementation of MessageReceiver used to process the received messages

Returns
Type	Description
`Subscriber.Builder`

newBuilder(ProjectSubscriptionName subscription, MessageReceiverWithAckResponse receiver)

public static Subscriber.Builder newBuilder(ProjectSubscriptionName subscription, MessageReceiverWithAckResponse receiver)

Parameters
Name	Description
`subscription`	`ProjectSubscriptionName`
`receiver`	`MessageReceiverWithAckResponse`

Returns
Type	Description
`Subscriber.Builder`

newBuilder(String subscription, MessageReceiver receiver)

public static Subscriber.Builder newBuilder(String subscription, MessageReceiver receiver)

Constructs a new Builder.

Parameters
Name	Description
`subscription`	`String` Cloud Pub/Sub subscription to bind the subscriber to
`receiver`	`MessageReceiver` an implementation of MessageReceiver used to process the received messages

Returns
Type	Description
`Subscriber.Builder`

newBuilder(String subscription, MessageReceiverWithAckResponse receiver)

public static Subscriber.Builder newBuilder(String subscription, MessageReceiverWithAckResponse receiver)

Parameters
Name	Description
`subscription`	`String`
`receiver`	`MessageReceiverWithAckResponse`

Returns
Type	Description
`Subscriber.Builder`

Methods

doStart()

protected void doStart()

Overrides

AbstractApiService.doStart()

doStop()

protected void doStop()

Overrides

AbstractApiService.doStop()

getFlowControlSettings()

public FlowControlSettings getFlowControlSettings()

The flow control settings the Subscriber is configured with.

Returns
Type	Description
`FlowControlSettings`

getSubscriptionNameString()

public String getSubscriptionNameString()

Subscription which the subscriber is subscribed to.

Returns
Type	Description
`String`

startAsync()

public ApiService startAsync()

Initiates service startup and returns immediately.

Example of receiving a specific number of messages.


 Subscriber subscriber = Subscriber.newBuilder(subscription, receiver).build();
 subscriber.addListener(new Subscriber.Listener() {
   public void failed(Subscriber.State from, Throwable failure) {
     // Handle error.
   }
 }, executor);
 subscriber.startAsync();

 // Wait for a stop signal.
 // In a server, this might be a signal to stop serving.
 // In this example, the signal is just a dummy Future.
 //
 // By default, Subscriber uses daemon threads (see
 // https://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html).
 // Consequently, once other threads have terminated, Subscriber will not stop the JVM from
 // exiting.
 // If the Subscriber should simply run forever, either use the setExecutorProvider method in
 // Subscriber.Builder
 // to use non-daemon threads or run
 //   for (;;) {
 //     Thread.sleep(Long.MAX_VALUE);
 //   }
 // at the end of main() to previent the main thread from exiting.
 done.get();
 subscriber.stopAsync().awaitTerminated();

Returns
Type	Description
`ApiService`

Overrides

AbstractApiService.startAsync()