net.sf.dropboxmq.messageconsumers
Class ConnectionConsumerImpl

java.lang.Object
  net.sf.dropboxmq.messageconsumers.ServerConsumer
      net.sf.dropboxmq.messageconsumers.ConnectionConsumerImpl

All Implemented Interfaces:

ConnectionConsumer

public class ConnectionConsumerImpl
extends ServerConsumer
implements ConnectionConsumer

Created: 24 Dec 2006

Version:

$Revision: 211 $, $Date: 2010-11-14 14:21:24 -0700 (Sun, 14 Nov 2010) $

Author:

Dwayne Schultz

Constructor Summary

ConnectionConsumerImpl(ConnectionImpl connection, Destination destination, String subscriptionName, String messageSelector, ServerSessionPool serverSessionPool, int maxMessages)

Method Summary

void	close() Closes the connection consumer.
ServerSessionPool	getServerSessionPool() Gets the server session pool associated with this connection consumer.
protected SessionImpl	newChildSession()
void	start()
protected void	startChildSession()

Methods inherited from class net.sf.dropboxmq.messageconsumers.ServerConsumer

closeServerConsumer, getConnection, startConsuming, toObjectString, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ConnectionConsumerImpl

public ConnectionConsumerImpl(ConnectionImpl connection,
                              Destination destination,
                              String subscriptionName,
                              String messageSelector,
                              ServerSessionPool serverSessionPool,
                              int maxMessages)
                       throws JMSException

Throws:

JMSException

Method Detail

getServerSessionPool

public ServerSessionPool getServerSessionPool()
                                       throws JMSException

Description copied from interface: javax.jms.ConnectionConsumer

Gets the server session pool associated with this connection consumer.

Specified by:

getServerSessionPool in interface ConnectionConsumer

Returns:

the server session pool used by this connection consumer

Throws:

JMSException - if the JMS provider fails to get the server session pool associated with this consumer due to some internal error.

close

public void close()
           throws JMSException

Description copied from interface: javax.jms.ConnectionConsumer

Closes the connection consumer.

Since a provider may allocate some resources on behalf of a connection consumer outside the Java virtual machine, clients should close these resources when they are not needed. Relying on garbage collection to eventually reclaim these resources may not be timely enough.

Specified by:

close in interface ConnectionConsumer

Throws:

JMSException - if the JMS provider fails to release resources on behalf of the connection consumer or fails to close the connection consumer.

newChildSession

protected SessionImpl newChildSession()

Specified by:

newChildSession in class ServerConsumer

startChildSession

protected void startChildSession()
                          throws JMSException

Specified by:

startChildSession in class ServerConsumer

Throws:

JMSException

start

public void start()