Java Enterprise in a Nutshell, Second Edition

Name

ConnectionConsumer

Synopsis

A ConnectionConsumer is used in situations where messages need to be read concurrently by multiple agents within the same process (e.g., within an application server running multiple message-based applications). The ConnectionConsumer delivers messages to one or more Sessions that are associated with MessageListeners for individual clients. It contains a reference to a ServerSessionPool which is uses to access the Sessions that are concurrently reading messages. Applications normally don’t need to use the ConnectionConsumer interface directly. It would be used by an application server to provide a message-handling service for client applications.

public interface ConnectionConsumer {
// Public Instance Methods
   public abstract void close() throws JMSException;  
   public abstract ServerSessionPool getServerSessionPool(
        ) throws JMSException;  
}

Returned By

QueueConnection.createConnectionConsumer(), TopicConnection.{createConnectionConsumer(), createDurableConnectionConsumer()}