com.solacesystems.jcsmp

Interface FlowReceiver

All Superinterfaces:

Consumer

public interface FlowReceiver
extends Consumer

An interface for applications to receive messages from an Endpoint on a Solace appliance. All messages delivered to a Session through a particular appliance Endpoint are transmitted on a logical flow.

FlowReceiver is acquired from JCSMPSession. When acquired successfully, an instance of FlowReceiver has a channel (connection) opened to the appliance, which is shared with other FlowReceiver instances within the same Session. In general, it is an expensive operation to acquire a FlowReceiver instance. Applications must cache this instance, and close it only when it is no longer needed.

Note: All methods defined in JCSMPDestinationSession are thread-safe.

Lifecycle Concerns

To receive messages, an application must call start() to start receiving messages from the underlying connection by using either synchronous receive(...) calls or using asynchronous notification by setting XMLMessageListener. The received messages are read-only.

The stop() method is used to disable the receiving of messages on this flow.

Once the close() method is invoked, any further access causes an exception to be thrown.

A flow can be administratively closed on the appliance, or closed due to an error condition. Such an event is indicated by throwing on access (or, in the case of a flow in asynchronous mode, delivering to the XMLMessageListener) a JCSMPFlowTransportException.

Method Summary

Modifier and Type	Method and Description
Destination	getDestination() Returns the Destination to which messages should be published to get routed to this flow's bound Endpoint.
Endpoint	getEndpoint() Returns the appliance Endpoint this flow is bound to.
Subscription	getSubscription() Returns the subscription associated to the Endpoint when bound to a TopicEndpoint.
void	logFlowInfo(JCSMPLogLevel level) Outputs a log containing the flow state information for the flow at a specified log level.

Methods inherited from interface com.solacesystems.jcsmp.Consumer

close, isClosed, receive, receive, receiveNoWait, start, stop

Method Detail

logFlowInfo

void logFlowInfo(JCSMPLogLevel level)

Outputs a log containing the flow state information for the flow at a specified log level.

Parameters:

level - The level (corresponding to org.apache.commons.logging levels) at which to output the log.

getEndpoint

Endpoint getEndpoint()

Returns the appliance Endpoint this flow is bound to.

Returns:

The bound appliance Endpoint.

getSubscription

Subscription getSubscription()

Returns the subscription associated to the Endpoint when bound to a TopicEndpoint.

Returns:

The Topic subscription associated to the TopicEndpoint this flow is bound to, null if not bound to a TopicEndpoint.

getDestination

Destination getDestination()

Returns the Destination to which messages should be published to get routed to this flow's bound Endpoint.

• If bound to a TopicEndpoint, the Destination will be of type Topic.
• If bound to a Queue, the Destination will be of type Queue.
• If bound to a SubscriberEndpoint, this method returns null.

Returns:

The Destination to which messages should be published to get routed to this flow's bound Endpoint.