net.sf.dropboxmq.connections
Class XAQueueConnectionImpl

java.lang.Object
  net.sf.dropboxmq.connections.ConnectionImpl
      net.sf.dropboxmq.connections.XAConnectionImpl
          net.sf.dropboxmq.connections.XAQueueConnectionImpl

All Implemented Interfaces:

Connection, QueueConnection, XAConnection, XAQueueConnection

public class XAQueueConnectionImpl
extends XAConnectionImpl
implements XAQueueConnection

Created: 30 Jul 2006

Version:

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

Author:

Dwayne Schultz

Field Summary

Fields inherited from class net.sf.dropboxmq.connections.ConnectionImpl

JMS_PROVIDER_NAME, JMSX_DELIVERY_COUNT, JMSX_GROUP_ID, JMSX_GROUP_SEQ, PROVIDER_VERSION

Constructor Summary

XAQueueConnectionImpl(ManagedConnectionImpl managedConnection, Configuration configuration)

Method Summary

ConnectionConsumer	createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages) Creates a connection consumer for this connection (optional operation).
ConnectionConsumer	createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages) Create a durable connection consumer for this connection (optional operation).
QueueSession	createQueueSession(boolean transacted, int acknowledgeMode) Creates an XAQueueSession object.
XAQueueSession	createXAQueueSession() Creates an XAQueueSession object.

Methods inherited from class net.sf.dropboxmq.connections.XAConnectionImpl

createSession, createXASession

Methods inherited from class net.sf.dropboxmq.connections.ConnectionImpl

addDurableSubscriptionName, addSession, checkClosed, close, createConnectionConsumer, createNonXASession, getClientID, getConfiguration, getExceptionListener, getLocalClientID, getLock, getManagedConnection, getMetaData, newDropboxTransaction, removeDurableSubscriptionName, removeServerConsumer, removeSession, setClientID, setExceptionListener, start, stop, toObjectString, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.XAConnection

createSession, createXASession

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Constructor Detail

XAQueueConnectionImpl

public XAQueueConnectionImpl(ManagedConnectionImpl managedConnection,
                             Configuration configuration)
                      throws JMSException

Throws:

JMSException

Method Detail

createQueueSession

public QueueSession createQueueSession(boolean transacted,
                                       int acknowledgeMode)
                                throws JMSException

Description copied from interface: javax.jms.XAQueueConnection

Creates an XAQueueSession object.

Specified by:

createQueueSession in interface QueueConnection

Specified by:

createQueueSession in interface XAQueueConnection

Parameters:

transacted - usage undefined

acknowledgeMode - usage undefined

Returns:

a newly created XAQueueSession

Throws:

JMSException - if the XAQueueConnection object fails to create an XA queue session due to some internal error.

See Also:

Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, Session.DUPS_OK_ACKNOWLEDGE

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Queue queue,
                                                   String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
                                            throws JMSException

Description copied from interface: javax.jms.QueueConnection

Creates a connection consumer for this connection (optional operation). This is an expert facility not used by regular JMS clients.

Specified by:

createConnectionConsumer in interface QueueConnection

Parameters:

queue - the queue to access

messageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.

sessionPool - the server session pool to associate with this connection consumer

maxMessages - the maximum number of messages that can be assigned to a server session at one time

Returns:

the connection consumer

Throws:

JMSException - if the QueueConnection object fails to create a connection consumer due to some internal error or invalid arguments for sessionPool and messageSelector.

InvalidSelectorException - if the message selector is invalid.

See Also:

ConnectionConsumer

createDurableConnectionConsumer

public ConnectionConsumer createDurableConnectionConsumer(Topic topic,
                                                          String subscriptionName,
                                                          String messageSelector,
                                                          ServerSessionPool sessionPool,
                                                          int maxMessages)
                                                   throws JMSException

Description copied from interface: javax.jms.Connection

Create a durable connection consumer for this connection (optional operation). This is an expert facility not used by regular JMS clients.

Specified by:

createDurableConnectionConsumer in interface Connection

Overrides:

createDurableConnectionConsumer in class ConnectionImpl

Parameters:

topic - topic to access

subscriptionName - durable subscription name

messageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.

sessionPool - the server session pool to associate with this durable connection consumer

maxMessages - the maximum number of messages that can be assigned to a server session at one time

Returns:

the durable connection consumer

Throws:

JMSException - if the Connection object fails to create a connection consumer due to some internal error or invalid arguments for sessionPool and messageSelector.

InvalidSelectorException - if the message selector is invalid.

See Also:

ConnectionConsumer

createXAQueueSession

public XAQueueSession createXAQueueSession()
                                    throws JMSException

Description copied from interface: javax.jms.XAQueueConnection

Creates an XAQueueSession object.

Specified by:

createXAQueueSession in interface XAQueueConnection

Returns:

a newly created XAQueueSession

Throws:

JMSException - if the XAQueueConnection object fails to create an XA queue session due to some internal error.