com.solace.messaging.receiver

Interface ReceiverSubscriptions

All Known Subinterfaces:

DirectMessageReceiver, PersistentMessageReceiver

@ProviderType
public interface ReceiverSubscriptions

An interface to subscribe and unsubscribe to and from additional message sources, respectively.

Since:

1.0.

Method Summary

Modifier and Type	Method and Description
void	addSubscription(TopicSubscription anotherSubscription) Subscribes to another message source on a broker to receive messages from.
void	removeSubscription(TopicSubscription subscription) Un-subscribes from a previously subscribed message source on a broker.

Method Detail

addSubscription

void addSubscription(TopicSubscription anotherSubscription)
              throws PubSubPlusClientException,
                     InterruptedException

Subscribes to another message source on a broker to receive messages from.

Parameters:

anotherSubscription - the additional message source to consume messages from

Throws:

PubSubPlusClientException - if the operation could not be performed

IllegalStateException - if the service is not running

InterruptedException - if any thread has interrupted the current thread which can occur when the receiver has been shut down; when this occurs, the interrupted status of the current thread is cleared when this exception is thrown

Since:

1.0

removeSubscription

void removeSubscription(TopicSubscription subscription)
                 throws PubSubPlusClientException,
                        InterruptedException

Un-subscribes from a previously subscribed message source on a broker. After this method successfully completes, no more messages will be received from the specified message source.

Parameters:

subscription - the message source to unsubscribe from

Throws:

PubSubPlusClientException - if the operation could not be performed

IllegalStateException - if the service is not running

InterruptedException - if any thread has interrupted the current thread which can occur when the receiver has been shut down; when this occurs, the interrupted status of the current thread is cleared when this exception is thrown

Since:

1.0