ClientSessionImpl (Red Hat JBoss Enterprise Application Platform 7.2.0.Beta public API)

java.lang.Object
- org.apache.activemq.artemis.core.client.impl.ClientSessionImpl

All Implemented Interfaces:: AutoCloseable, XAResource, ClientSession, ClientSessionInternal, FailureListener

public final class ClientSessionImpl
extends Object
implements ClientSessionInternal, FailureListener

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.activemq.artemis.api.core.client.ClientSession
  ClientSession.AddressQuery, ClientSession.QueueQuery

Field Summary
- Fields inherited from interface org.apache.activemq.artemis.api.core.client.ClientSession
  JMS_SESSION_CLIENT_ID_PROPERTY, JMS_SESSION_IDENTIFIER_PROPERTY
- Fields inherited from interface javax.transaction.xa.XAResource
  TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`acknowledge(ClientConsumer consumer, Message message)` Acknowledges all messages received by the consumer so far.
`void`	`addConsumer(ClientConsumerInternal consumer)`
`void`	`addFailoverListener(FailoverEventListener listener)` Adds a FailoverEventListener to the session which is notified if a failover event occurs on the session.
`void`	`addFailureListener(SessionFailureListener listener)` Adds a FailureListener to the session which is notified if a failure occurs on the session.
`void`	`addMetaData(String key, String data)` Attach any metadata to the session.
`void`	`addProducer(ClientProducerInternal producer)`
`ClientSession.AddressQuery`	`addressQuery(SimpleString address)` Queries information on a binding.
`void`	`addUniqueMetaData(String key, String data)` Attach any metadata to the session.
`void`	`cleanUp(boolean failingOver)`
`Set<ClientConsumerInternal>`	`cloneConsumers()` Not part of the interface, used on tests only
`Set<ClientProducerInternal>`	`cloneProducers()` Not part of the interface, used on tests only
`void`	`close()` Closes the session.
`void`	`commit()` Commits the current transaction.
`void`	`commit(Xid xid, boolean onePhase)`
`void`	`connectionFailed(ActiveMQException me, boolean failedOver)` Notifies that a connection has failed due to the specified exception.
`void`	`connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)` Notifies that a connection has failed due to the specified exception.
`static Object`	`convert(Xid xid)` If you ever tried to debug XIDs you will know what this is about.
`ClientConsumer`	`createConsumer(SimpleString queueName)` Creates a ClientConsumer to consume message from the queue with the given name.
`ClientConsumer`	`createConsumer(SimpleString queueName, boolean browseOnly)` Creates a ClientConsumer to consume or browse messages from the queue with the given name.
`ClientConsumer`	`createConsumer(SimpleString queueName, SimpleString filterString)` Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
`ClientConsumer`	`createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly)` Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
`ClientConsumer`	`createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly)` Note, we DO NOT currently support direct consumers (i.e.
`ClientConsumer`	`createConsumer(String queueName)` Creates a ClientConsumer to consume messages from the queue with the given name.
`ClientConsumer`	`createConsumer(String queueName, boolean browseOnly)` Creates a ClientConsumer to consume or browse messages from the queue with the given name.
`ClientConsumer`	`createConsumer(String queueName, String filterString)` Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
`ClientConsumer`	`createConsumer(String queueName, String filterString, boolean browseOnly)` Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
`ClientConsumer`	`createConsumer(String queueName, String filterString, int windowSize, int maxRate, boolean browseOnly)` Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
`ClientMessage`	`createMessage(boolean durable)` Creates a ClientMessage.
`ClientMessage`	`createMessage(byte type, boolean durable)` Creates a ClientMessage.
`ClientMessage`	`createMessage(byte type, boolean durable, long expiration, long timestamp, byte priority)` Creates a ClientMessage.
`ClientProducer`	`createProducer()` Creates a producer with no default address.
`ClientProducer`	`createProducer(SimpleString address)` Creates a producer which sends messages to the given address
`ClientProducer`	`createProducer(SimpleString address, int maxRate)` Creates a producer which sends messages to the given address
`ClientProducer`	`createProducer(String address)` Creates a producer which sends messages to the given address
`ClientProducer`	`createProducer(String address, int rate)`
`void`	`createQueue(SimpleString address, SimpleString queueName)` Creates a non-temporary queue non-durable queue.
`void`	`createQueue(SimpleString address, SimpleString queueName, boolean durable)` Creates a non-temporary queue.
`void`	`createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable)` Creates a non-temporary queue.
`void`	`createQueue(String address, String queueName)` Creates a non-temporary queue non-durable queue.
`void`	`createQueue(String address, String queueName, boolean durable)` Creates a non-temporary queue.
`void`	`createQueue(String address, String queueName, String filterString, boolean durable)` Creates a non-temporaryqueue.
`void`	`createSharedQueue(SimpleString address, SimpleString queueName, boolean durable)` Creates a transient queue.
`void`	`createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable)` Creates a transient queue.
`void`	`createTemporaryQueue(SimpleString address, SimpleString queueName)` Creates a temporary queue.
`void`	`createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter)` Creates a temporary queue with a filter.
`void`	`createTemporaryQueue(String address, String queueName)` Creates a temporary queue.
`void`	`createTemporaryQueue(String address, String queueName, String filter)` Creates a temporary queue with a filter.
`void`	`deleteQueue(SimpleString queueName)` Deletes the queue.
`void`	`deleteQueue(String queueName)` Deletes the queue.
`void`	`end(Xid xid, int flags)`
`void`	`endCall()`
`void`	`expire(ClientConsumer consumer, Message message)`
`void`	`forget(Xid xid)`
`RemotingConnection`	`getConnection()`
`ClientProducerCredits`	`getCredits(SimpleString address, boolean anon)`
`int`	`getMinLargeMessageSize()`
`String`	`getName()`
`String`	`getNodeId()`
`ClientProducerCreditManager`	`getProducerCreditManager()`
`SessionContext`	`getSessionContext()`
`ClientSessionFactory`	`getSessionFactory()` Return the sessionFactory used to created this Session.
`int`	`getTransactionTimeout()`
`int`	`getVersion()` Returns the server's incrementingVersion.
`XAResource`	`getXAResource()` Returns the XAResource associated to the session.
`void`	`handleConsumerDisconnect(ConsumerContext context)`
`void`	`handleFailover(RemotingConnection backupConnection, ActiveMQException cause)`
`void`	`handleReceiveContinuation(ConsumerContext consumerID, byte[] chunk, int flowControlSize, boolean isContinues)`
`void`	`handleReceiveLargeMessage(ConsumerContext consumerID, ClientLargeMessageInternal clientLargeMessage, long largeMessageSize)`
`void`	`handleReceiveMessage(ConsumerContext consumerID, ClientMessageInternal message)`
`void`	`handleReceiveProducerCredits(SimpleString address, int credits)`
`void`	`handleReceiveProducerFailCredits(SimpleString address, int credits)`
`void`	`individualAcknowledge(ClientConsumer consumer, Message message)`
`boolean`	`isAutoCommitAcks()` Returns whether the session will automatically commit its transaction every time a message is acknowledged by a ClientConsumer created by this session, `false` else
`boolean`	`isAutoCommitSends()` Returns whether the session will automatically commit its transaction every time a message is sent by a ClientProducer created by this session, `false` else
`boolean`	`isBlockOnAcknowledge()` Returns whether the ClientConsumer created by the session will block when they acknowledge a message.
`boolean`	`isCacheLargeMessageClient()`
`boolean`	`isClosed()` Returns whether the session is closed or not.
`boolean`	`isClosing()`
`boolean`	`isCompressLargeMessages()`
`boolean`	`isConfirmationWindowEnabled()`
`boolean`	`isRollbackOnly()` Returns `true` if the current transaction has been flagged to rollback, `false` else.
`boolean`	`isSameRM(XAResource xares)`
`boolean`	`isWritable(ReadyListener callback)`
`boolean`	`isXA()` Return `true` if the session supports XA, `false` else.
`void`	`markRollbackOnly()`
`void`	`preHandleFailover(RemotingConnection connection)`
`int`	`prepare(Xid xid)`
`ClientSession.QueueQuery`	`queueQuery(SimpleString queueName)` Queries information on a queue.
`Xid[]`	`recover(int flags)`
`void`	`removeConsumer(ClientConsumerInternal consumer)`
`boolean`	`removeFailoverListener(FailoverEventListener listener)` Removes a FailoverEventListener to the session.
`boolean`	`removeFailureListener(SessionFailureListener listener)` Removes a FailureListener to the session.
`void`	`removeProducer(ClientProducerInternal producer)`
`void`	`resetIfNeeded()`
`void`	`returnCredits(SimpleString address)`
`void`	`rollback()` Rolls back the current transaction.
`void`	`rollback(boolean isLastMessageAsDelivered)` Rolls back the current transaction.
`void`	`rollback(boolean isLastMessageAsDelivered, boolean waitConsumers)`
`void`	`rollback(Xid xid)`
`void`	`scheduleConfirmation(SendAcknowledgementHandler handler, Message message)`
`void`	`sendProducerCreditsMessage(int credits, SimpleString address)`
`void`	`setAddress(Message message, SimpleString address)` This will set the address at the message
`void`	`setForceNotSameRM(boolean force)`
`void`	`setPacketSize(int packetSize)`
`ClientSessionImpl`	`setSendAcknowledgementHandler(SendAcknowledgementHandler handler)` Sets a `SendAcknowledgementHandler` for this session.
`void`	`setStopSignal()` Sets a stop signal to true.
`boolean`	`setTransactionTimeout(int seconds)`
`ClientSessionImpl`	`start()` Starts the session.
`void`	`start(Xid xid, int flags)`
`void`	`startCall()` This is used internally to control and educate the user about using the thread boundaries properly.
`void`	`stop()` Stops the session.
`void`	`stop(boolean waitForOnMessage)`
`String`	`toString()`
`void`	`workDone()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Method Detail
  - createQueue
```
public void createQueue(SimpleString address,
                        SimpleString queueName)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a non-temporary queue non-durable queue.
    
    Specified by:
    
    createQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createQueue
```
public void createQueue(SimpleString address,
                        SimpleString queueName,
                        boolean durable)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a non-temporary queue.
    
    Specified by:
    
    createQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    durable - whether the queue is durable or not
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createQueue
```
public void createQueue(String address,
                        String queueName,
                        boolean durable)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a non-temporary queue.
    
    Specified by:
    
    createQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    durable - whether the queue is durable or not
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createSharedQueue
```
public void createSharedQueue(SimpleString address,
                              SimpleString queueName,
                              boolean durable)
                       throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a transient queue. A queue that will exist as long as there are consumers. When the last consumer is closed the queue will be deleted
    Notice: you will get an exception if the address or the filter doesn't match to an already existent queue
    
    Specified by:
    
    createSharedQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    durable - if the queue is durable
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createSharedQueue
```
public void createSharedQueue(SimpleString address,
                              SimpleString queueName,
                              SimpleString filterString,
                              boolean durable)
                       throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a transient queue. A queue that will exist as long as there are consumers. When the last consumer is closed the queue will be deleted
    Notice: you will get an exception if the address or the filter doesn't match to an already existent queue
    
    Specified by:
    
    createSharedQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    filterString - whether the queue is durable or not
    
    durable - if the queue is durable
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createQueue
```
public void createQueue(SimpleString address,
                        SimpleString queueName,
                        SimpleString filterString,
                        boolean durable)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a non-temporary queue.
    
    Specified by:
    
    createQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    filterString - only messages which match this filter will be put in the queue
    
    durable - whether the queue is durable or not
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createQueue
```
public void createQueue(String address,
                        String queueName,
                        String filterString,
                        boolean durable)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a non-temporaryqueue.
    
    Specified by:
    
    createQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    filterString - only messages which match this filter will be put in the queue
    
    durable - whether the queue is durable or not
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createTemporaryQueue
```
public void createTemporaryQueue(SimpleString address,
                                 SimpleString queueName)
                          throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a temporary queue.
    
    Specified by:
    
    createTemporaryQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createTemporaryQueue
```
public void createTemporaryQueue(String address,
                                 String queueName)
                          throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a temporary queue.
    
    Specified by:
    
    createTemporaryQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createTemporaryQueue
```
public void createTemporaryQueue(SimpleString address,
                                 SimpleString queueName,
                                 SimpleString filter)
                          throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a temporary queue with a filter.
    
    Specified by:
    
    createTemporaryQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    filter - only messages which match this filter will be put in the queue
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createTemporaryQueue
```
public void createTemporaryQueue(String address,
                                 String queueName,
                                 String filter)
                          throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a temporary queue with a filter.
    
    Specified by:
    
    createTemporaryQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    filter - only messages which match this filter will be put in the queue
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - deleteQueue
```
public void deleteQueue(SimpleString queueName)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Deletes the queue.
    
    Specified by:
    
    deleteQueue in interface ClientSession
    
    Parameters:
    
    queueName - the name of the queue to delete
    
    Throws:
    
    ActiveMQException - if there is no queue for the given name or if the queue has consumers
  - deleteQueue
```
public void deleteQueue(String queueName)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Deletes the queue.
    
    Specified by:
    
    deleteQueue in interface ClientSession
    
    Parameters:
    
    queueName - the name of the queue to delete
    
    Throws:
    
    ActiveMQException - if there is no queue for the given name or if the queue has consumers
  - queueQuery
```
public ClientSession.QueueQuery queueQuery(SimpleString queueName)
                                    throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Queries information on a queue.
    
    Specified by:
    
    queueQuery in interface ClientSession
    
    Parameters:
    
    queueName - the name of the queue to query
    
    Returns:
    
    a QueueQuery containing information on the given queue
    
    Throws:
    
    ActiveMQException - if an exception occurs while querying the queue
  - addressQuery
```
public ClientSession.AddressQuery addressQuery(SimpleString address)
                                        throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Queries information on a binding.
    
    Specified by:
    
    addressQuery in interface ClientSession
    
    Parameters:
    
    address - the address of the biding to query
    
    Returns:
    
    an AddressQuery containing information on the binding attached to the given address
    
    Throws:
    
    ActiveMQException - if an exception occurs while querying the binding
  - createConsumer
```
public ClientConsumer createConsumer(SimpleString queueName)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume message from the queue with the given name.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createConsumer
```
public ClientConsumer createConsumer(String queueName)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume messages from the queue with the given name.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createConsumer
```
public ClientConsumer createConsumer(SimpleString queueName,
                                     SimpleString filterString)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    filterString - only messages which match this filter will be consumed
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createQueue
```
public void createQueue(String address,
                        String queueName)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a non-temporary queue non-durable queue.
    
    Specified by:
    
    createQueue in interface ClientSession
    
    Parameters:
    
    address - the queue will be bound to this address
    
    queueName - the name of the queue
    
    Throws:
    
    ActiveMQException - in an exception occurs while creating the queue
  - createConsumer
```
public ClientConsumer createConsumer(String queueName,
                                     String filterString)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    filterString - only messages which match this filter will be consumed
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createConsumer
```
public ClientConsumer createConsumer(SimpleString queueName,
                                     SimpleString filterString,
                                     boolean browseOnly)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
    If browseOnly is true, the ClientConsumer will receive the messages from the queue but they will not be consumed (the messages will remain in the queue). Note that paged messages will not be in the queue, and will therefore not be visible if browseOnly is true.
    If browseOnly is false, the ClientConsumer will behave like consume the messages from the queue and the messages will effectively be removed from the queue.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    filterString - only messages which match this filter will be consumed
    
    browseOnly - whether the ClientConsumer will only browse the queue or consume messages.
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createConsumer
```
public ClientConsumer createConsumer(SimpleString queueName,
                                     boolean browseOnly)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume or browse messages from the queue with the given name.
    If browseOnly is true, the ClientConsumer will receive the messages from the queue but they will not be consumed (the messages will remain in the queue). Note that paged messages will not be in the queue, and will therefore not be visible if browseOnly is true.
    If browseOnly is false, the ClientConsumer will behave like consume the messages from the queue and the messages will effectively be removed from the queue.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    browseOnly - whether the ClientConsumer will only browse the queue or consume messages.
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createConsumer
```
public ClientConsumer createConsumer(String queueName,
                                     String filterString,
                                     boolean browseOnly)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
    If browseOnly is true, the ClientConsumer will receive the messages from the queue but they will not be consumed (the messages will remain in the queue). Note that paged messages will not be in the queue, and will therefore not be visible if browseOnly is true.
    If browseOnly is false, the ClientConsumer will behave like consume the messages from the queue and the messages will effectively be removed from the queue.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    filterString - only messages which match this filter will be consumed
    
    browseOnly - whether the ClientConsumer will only browse the queue or consume messages.
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createConsumer
```
public ClientConsumer createConsumer(String queueName,
                                     boolean browseOnly)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume or browse messages from the queue with the given name.
    If browseOnly is true, the ClientConsumer will receive the messages from the queue but they will not be consumed (the messages will remain in the queue). Note that paged messages will not be in the queue, and will therefore not be visible if browseOnly is true.
    If browseOnly is false, the ClientConsumer will behave like consume the messages from the queue and the messages will effectively be removed from the queue.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    browseOnly - whether the ClientConsumer will only browse the queue or consume messages.
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - isWritable
```
public boolean isWritable(ReadyListener callback)
```
    Specified by:
    
    isWritable in interface ClientSessionInternal
  - createConsumer
```
public ClientConsumer createConsumer(SimpleString queueName,
                                     SimpleString filterString,
                                     int windowSize,
                                     int maxRate,
                                     boolean browseOnly)
                              throws ActiveMQException
```
    Note, we DO NOT currently support direct consumers (i.e. consumers where delivery occurs on the remoting thread).
    Direct consumers have issues with blocking and failover. E.g. if direct then inside MessageHandler call a blocking method like rollback or acknowledge (blocking) This can block until failover completes, which disallows the thread to be used to deliver any responses to the client during that period, so failover won't occur. If we want direct consumers we need to rethink how they work.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    filterString - only messages which match this filter will be consumed
    
    windowSize - the consumer window size
    
    maxRate - the maximum rate to consume messages
    
    browseOnly - whether the ClientConsumer will only browse the queue or consume messages.
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createConsumer
```
public ClientConsumer createConsumer(String queueName,
                                     String filterString,
                                     int windowSize,
                                     int maxRate,
                                     boolean browseOnly)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
    If browseOnly is true, the ClientConsumer will receive the messages from the queue but they will not be consumed (the messages will remain in the queue). Note that paged messages will not be in the queue, and will therefore not be visible if browseOnly is true.
    If browseOnly is false, the ClientConsumer will behave like consume the messages from the queue and the messages will effectively be removed from the queue.
    
    Specified by:
    
    createConsumer in interface ClientSession
    
    Parameters:
    
    queueName - name of the queue to consume messages from
    
    filterString - only messages which match this filter will be consumed
    
    windowSize - the consumer window size
    
    maxRate - the maximum rate to consume messages
    
    browseOnly - whether the ClientConsumer will only browse the queue or consume messages.
    
    Returns:
    
    a ClientConsumer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientConsumer
  - createProducer
```
public ClientProducer createProducer()
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a producer with no default address. Address must be specified every time a message is sent
    
    Specified by:
    
    createProducer in interface ClientSession
    
    Returns:
    
    a ClientProducer
    
    Throws:
    
    ActiveMQException
    
    See Also:
    
    ClientProducer.send(SimpleString, org.apache.activemq.artemis.api.core.Message)
  - createProducer
```
public ClientProducer createProducer(SimpleString address)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a producer which sends messages to the given address
    
    Specified by:
    
    createProducer in interface ClientSession
    
    Parameters:
    
    address - the address to send messages to
    
    Returns:
    
    a ClientProducer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientProducer
  - createProducer
```
public ClientProducer createProducer(String address)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a producer which sends messages to the given address
    
    Specified by:
    
    createProducer in interface ClientSession
    
    Parameters:
    
    address - the address to send messages to
    
    Returns:
    
    a ClientProducer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientProducer
  - createProducer
```
public ClientProducer createProducer(SimpleString address,
                                     int maxRate)
                              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Creates a producer which sends messages to the given address
    
    Specified by:
    
    createProducer in interface ClientSession
    
    Parameters:
    
    address - the address to send messages to
    
    maxRate - the producer rate
    
    Returns:
    
    a ClientProducer
    
    Throws:
    
    ActiveMQException - if an exception occurs while creating the ClientProducer
  - createProducer
```
public ClientProducer createProducer(String address,
                                     int rate)
                              throws ActiveMQException
```
    Throws:
    
    ActiveMQException
  - getXAResource
```
public XAResource getXAResource()
```
    Description copied from interface: ClientSession
    
    Returns the XAResource associated to the session.
    
    Specified by:
    
    getXAResource in interface ClientSession
    
    Returns:
    
    the XAResource associated to the session
  - commit
```
public void commit()
            throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Commits the current transaction.
    
    Specified by:
    
    commit in interface ClientSession
    
    Throws:
    
    ActiveMQException - if an exception occurs while committing the transaction
  - isRollbackOnly
```
public boolean isRollbackOnly()
```
    Description copied from interface: ClientSession
    
    Returns true if the current transaction has been flagged to rollback, false else.
    
    Specified by:
    
    isRollbackOnly in interface ClientSession
    
    Returns:
    
    true if the current transaction has been flagged to rollback, false else.
  - rollback
```
public void rollback()
              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Rolls back the current transaction.
    
    Specified by:
    
    rollback in interface ClientSession
    
    Throws:
    
    ActiveMQException - if an exception occurs while rolling back the transaction
  - rollback
```
public void rollback(boolean isLastMessageAsDelivered)
              throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Rolls back the current transaction.
    
    Specified by:
    
    rollback in interface ClientSession
    
    Parameters:
    
    isLastMessageAsDelivered - the first message on deliveringMessage Buffer is considered as delivered
    
    Throws:
    
    ActiveMQException - if an exception occurs while rolling back the transaction
  - rollback
```
public void rollback(boolean isLastMessageAsDelivered,
                     boolean waitConsumers)
              throws ActiveMQException
```
    Throws:
    
    ActiveMQException
  - markRollbackOnly
```
public void markRollbackOnly()
```
    Specified by:
    
    markRollbackOnly in interface ClientSessionInternal
  - createMessage
```
public ClientMessage createMessage(byte type,
                                   boolean durable,
                                   long expiration,
                                   long timestamp,
                                   byte priority)
```
    Description copied from interface: ClientSession
    
    Creates a ClientMessage.
    
    Specified by:
    
    createMessage in interface ClientSession
    
    Parameters:
    
    type - type of the message
    
    durable - whether the created message is durable or not
    
    expiration - the message expiration
    
    timestamp - the message timestamp
    
    priority - the message priority (between 0 and 9 inclusive)
    
    Returns:
    
    a ClientMessage
  - createMessage
```
public ClientMessage createMessage(byte type,
                                   boolean durable)
```
    Description copied from interface: ClientSession
    
    Creates a ClientMessage.
    
    Specified by:
    
    createMessage in interface ClientSession
    
    Parameters:
    
    type - type of the message
    
    durable - whether the created message is durable or not
    
    Returns:
    
    a ClientMessage
  - createMessage
```
public ClientMessage createMessage(boolean durable)
```
    Description copied from interface: ClientSession
    
    Creates a ClientMessage.
    
    Specified by:
    
    createMessage in interface ClientSession
    
    Parameters:
    
    durable - whether the created message is durable or not
    
    Returns:
    
    a ClientMessage
  - isClosed
```
public boolean isClosed()
```
    Description copied from interface: ClientSession
    
    Returns whether the session is closed or not.
    
    Specified by:
    
    isClosed in interface ClientSession
    
    Returns:
    
    true if the session is closed, false else
  - isAutoCommitSends
```
public boolean isAutoCommitSends()
```
    Description copied from interface: ClientSession
    
    Returns whether the session will automatically commit its transaction every time a message is sent by a ClientProducer created by this session, false else
    
    Specified by:
    
    isAutoCommitSends in interface ClientSession
    
    Returns:
    
    true if the session automatically commit its transaction every time a message is sent, false else
  - isAutoCommitAcks
```
public boolean isAutoCommitAcks()
```
    Description copied from interface: ClientSession
    
    Returns whether the session will automatically commit its transaction every time a message is acknowledged by a ClientConsumer created by this session, false else
    
    Specified by:
    
    isAutoCommitAcks in interface ClientSession
    
    Returns:
    
    true if the session automatically commit its transaction every time a message is acknowledged, false else
  - isBlockOnAcknowledge
```
public boolean isBlockOnAcknowledge()
```
    Description copied from interface: ClientSession
    
    Returns whether the ClientConsumer created by the session will block when they acknowledge a message.
    
    Specified by:
    
    isBlockOnAcknowledge in interface ClientSession
    
    Returns:
    
    true if the session's ClientConsumer block when they acknowledge a message, false else
  - isXA
```
public boolean isXA()
```
    Description copied from interface: ClientSession
    
    Return true if the session supports XA, false else.
    
    Specified by:
    
    isXA in interface ClientSession
    
    Returns:
    
    true if the session supports XA, false else.
  - resetIfNeeded
```
public void resetIfNeeded()
                   throws ActiveMQException
```
    Specified by:
    
    resetIfNeeded in interface ClientSessionInternal
    
    Throws:
    
    ActiveMQException
  - start
```
public ClientSessionImpl start()
                        throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Starts the session. The session must be started before ClientConsumers created by the session can consume messages from the queue.
    
    Specified by:
    
    start in interface ClientSession
    
    Throws:
    
    ActiveMQException - if an exception occurs while starting the session
  - stop
```
public void stop()
          throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Stops the session. ClientConsumers created by the session can not consume messages when the session is stopped.
    
    Specified by:
    
    stop in interface ClientSession
    
    Throws:
    
    ActiveMQException - if an exception occurs while stopping the session
  - stop
```
public void stop(boolean waitForOnMessage)
          throws ActiveMQException
```
    Throws:
    
    ActiveMQException
  - addFailureListener
```
public void addFailureListener(SessionFailureListener listener)
```
    Description copied from interface: ClientSession
    
    Adds a FailureListener to the session which is notified if a failure occurs on the session.
    
    Specified by:
    
    addFailureListener in interface ClientSession
    
    Parameters:
    
    listener - the listener to add
  - removeFailureListener
```
public boolean removeFailureListener(SessionFailureListener listener)
```
    Description copied from interface: ClientSession
    
    Removes a FailureListener to the session.
    
    Specified by:
    
    removeFailureListener in interface ClientSession
    
    Parameters:
    
    listener - the listener to remove
    
    Returns:
    
    true if the listener was removed, false else
  - addFailoverListener
```
public void addFailoverListener(FailoverEventListener listener)
```
    Description copied from interface: ClientSession
    
    Adds a FailoverEventListener to the session which is notified if a failover event occurs on the session.
    
    Specified by:
    
    addFailoverListener in interface ClientSession
    
    Parameters:
    
    listener - the listener to add
  - removeFailoverListener
```
public boolean removeFailoverListener(FailoverEventListener listener)
```
    Description copied from interface: ClientSession
    
    Removes a FailoverEventListener to the session.
    
    Specified by:
    
    removeFailoverListener in interface ClientSession
    
    Parameters:
    
    listener - the listener to remove
    
    Returns:
    
    true if the listener was removed, false else
  - getVersion
```
public int getVersion()
```
    Description copied from interface: ClientSession
    
    Returns the server's incrementingVersion.
    
    Specified by:
    
    getVersion in interface ClientSession
    
    Returns:
    
    the server's incrementingVersion
  - isClosing
```
public boolean isClosing()
```
    Specified by:
    
    isClosing in interface ClientSessionInternal
  - getNodeId
```
public String getNodeId()
```
    Specified by:
    
    getNodeId in interface ClientSessionInternal
  - getMinLargeMessageSize
```
public int getMinLargeMessageSize()
```
    Specified by:
    
    getMinLargeMessageSize in interface ClientSessionInternal
  - isCompressLargeMessages
```
public boolean isCompressLargeMessages()
```
    Specified by:
    
    isCompressLargeMessages in interface ClientSessionInternal
  - isCacheLargeMessageClient
```
public boolean isCacheLargeMessageClient()
```
    Specified by:
    
    isCacheLargeMessageClient in interface ClientSessionInternal
    
    Returns:
    
    the cacheLargeMessageClient
  - getName
```
public String getName()
```
    Specified by:
    
    getName in interface ClientSessionInternal
  - acknowledge
```
public void acknowledge(ClientConsumer consumer,
                        Message message)
                 throws ActiveMQException
```
    Acknowledges all messages received by the consumer so far.
    
    Specified by:
    
    acknowledge in interface ClientSessionInternal
    
    Throws:
    
    ActiveMQException
  - individualAcknowledge
```
public void individualAcknowledge(ClientConsumer consumer,
                                  Message message)
                           throws ActiveMQException
```
    Specified by:
    
    individualAcknowledge in interface ClientSessionInternal
    
    Throws:
    
    ActiveMQException
  - expire
```
public void expire(ClientConsumer consumer,
                   Message message)
            throws ActiveMQException
```
    Specified by:
    
    expire in interface ClientSessionInternal
    
    Throws:
    
    ActiveMQException
  - addConsumer
```
public void addConsumer(ClientConsumerInternal consumer)
```
    Specified by:
    
    addConsumer in interface ClientSessionInternal
  - addProducer
```
public void addProducer(ClientProducerInternal producer)
```
    Specified by:
    
    addProducer in interface ClientSessionInternal
  - removeConsumer
```
public void removeConsumer(ClientConsumerInternal consumer)
                    throws ActiveMQException
```
    Specified by:
    
    removeConsumer in interface ClientSessionInternal
    
    Throws:
    
    ActiveMQException
  - removeProducer
```
public void removeProducer(ClientProducerInternal producer)
```
    Specified by:
    
    removeProducer in interface ClientSessionInternal
  - handleReceiveMessage
```
public void handleReceiveMessage(ConsumerContext consumerID,
                                 ClientMessageInternal message)
                          throws Exception
```
    Specified by:
    
    handleReceiveMessage in interface ClientSessionInternal
    
    Throws:
    
    Exception
  - handleReceiveLargeMessage
```
public void handleReceiveLargeMessage(ConsumerContext consumerID,
                                      ClientLargeMessageInternal clientLargeMessage,
                                      long largeMessageSize)
                               throws Exception
```
    Specified by:
    
    handleReceiveLargeMessage in interface ClientSessionInternal
    
    Throws:
    
    Exception
  - handleReceiveContinuation
```
public void handleReceiveContinuation(ConsumerContext consumerID,
                                      byte[] chunk,
                                      int flowControlSize,
                                      boolean isContinues)
                               throws Exception
```
    Specified by:
    
    handleReceiveContinuation in interface ClientSessionInternal
    
    Throws:
    
    Exception
  - handleConsumerDisconnect
```
public void handleConsumerDisconnect(ConsumerContext context)
                              throws ActiveMQException
```
    Specified by:
    
    handleConsumerDisconnect in interface ClientSessionInternal
    
    Throws:
    
    ActiveMQException
  - close
```
public void close()
           throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Closes the session.
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface ClientSession
    
    Throws:
    
    ActiveMQException - if an exception occurs while closing the session
  - cleanUp
```
public void cleanUp(boolean failingOver)
             throws ActiveMQException
```
    Specified by:
    
    cleanUp in interface ClientSessionInternal
    
    Throws:
    
    ActiveMQException
  - setSendAcknowledgementHandler
```
public ClientSessionImpl setSendAcknowledgementHandler(SendAcknowledgementHandler handler)
```
    Description copied from interface: ClientSession
    
    Sets a SendAcknowledgementHandler for this session.
    
    Specified by:
    
    setSendAcknowledgementHandler in interface ClientSession
    
    Parameters:
    
    handler - a SendAcknowledgementHandler
    
    Returns:
    
    this ClientSession
  - preHandleFailover
```
public void preHandleFailover(RemotingConnection connection)
```
    Specified by:
    
    preHandleFailover in interface ClientSessionInternal
  - handleFailover
```
public void handleFailover(RemotingConnection backupConnection,
                           ActiveMQException cause)
```
    Specified by:
    
    handleFailover in interface ClientSessionInternal
  - addMetaData
```
public void addMetaData(String key,
                        String data)
                 throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Attach any metadata to the session.
    
    Specified by:
    
    addMetaData in interface ClientSession
    
    Throws:
    
    ActiveMQException
  - addUniqueMetaData
```
public void addUniqueMetaData(String key,
                              String data)
                       throws ActiveMQException
```
    Description copied from interface: ClientSession
    
    Attach any metadata to the session. Throws an exception if there's already a metadata available. You can use this metadata to ensure that there is no other session with the same meta-data you are passing as an argument. This is useful to simulate unique client-ids, where you may want to avoid multiple instances of your client application connected.
    
    Specified by:
    
    addUniqueMetaData in interface ClientSession
    
    Throws:
    
    ActiveMQException
  - getSessionFactory
```
public ClientSessionFactory getSessionFactory()
```
    Description copied from interface: ClientSession
    
    Return the sessionFactory used to created this Session.
    
    Specified by:
    
    getSessionFactory in interface ClientSession
    
    Returns:
  - setAddress
```
public void setAddress(Message message,
                       SimpleString address)
```
    Description copied from interface: ClientSessionInternal
    
    This will set the address at the message
    
    Specified by:
    
    setAddress in interface ClientSessionInternal
  - setPacketSize
```
public void setPacketSize(int packetSize)
```
    Specified by:
    
    setPacketSize in interface ClientSessionInternal
  - workDone
```
public void workDone()
```
    Specified by:
    
    workDone in interface ClientSessionInternal
  - sendProducerCreditsMessage
```
public void sendProducerCreditsMessage(int credits,
                                       SimpleString address)
```
    Specified by:
    
    sendProducerCreditsMessage in interface ClientSessionInternal
  - getCredits
```
public ClientProducerCredits getCredits(SimpleString address,
                                        boolean anon)
```
    Specified by:
    
    getCredits in interface ClientSessionInternal
  - returnCredits
```
public void returnCredits(SimpleString address)
```
    Specified by:
    
    returnCredits in interface ClientSessionInternal
  - handleReceiveProducerCredits
```
public void handleReceiveProducerCredits(SimpleString address,
                                         int credits)
```
    Specified by:
    
    handleReceiveProducerCredits in interface ClientSessionInternal
  - handleReceiveProducerFailCredits
```
public void handleReceiveProducerFailCredits(SimpleString address,
                                             int credits)
```
    Specified by:
    
    handleReceiveProducerFailCredits in interface ClientSessionInternal
  - getProducerCreditManager
```
public ClientProducerCreditManager getProducerCreditManager()
```
    Specified by:
    
    getProducerCreditManager in interface ClientSessionInternal
  - startCall
```
public void startCall()
```
    Description copied from interface: ClientSessionInternal
    
    This is used internally to control and educate the user about using the thread boundaries properly. if more than one thread is using the session simultaneously this will generate a big warning on the docs. There are a limited number of places where we can call this such as acks and sends. otherwise we could get false warns
    
    Specified by:
    
    startCall in interface ClientSessionInternal
  - endCall
```
public void endCall()
```
    Specified by:
    
    endCall in interface ClientSessionInternal
    
    See Also:
    
    ClientSessionInternal.startCall()
  - commit
```
public void commit(Xid xid,
                   boolean onePhase)
            throws XAException
```
    Specified by:
    
    commit in interface XAResource
    
    Throws:
    
    XAException
  - end
```
public void end(Xid xid,
                int flags)
         throws XAException
```
    Specified by:
    
    end in interface XAResource
    
    Throws:
    
    XAException
  - forget
```
public void forget(Xid xid)
            throws XAException
```
    Specified by:
    
    forget in interface XAResource
    
    Throws:
    
    XAException
  - getTransactionTimeout
```
public int getTransactionTimeout()
                          throws XAException
```
    Specified by:
    
    getTransactionTimeout in interface XAResource
    
    Throws:
    
    XAException
  - setTransactionTimeout
```
public boolean setTransactionTimeout(int seconds)
                              throws XAException
```
    Specified by:
    
    setTransactionTimeout in interface XAResource
    
    Throws:
    
    XAException
  - isSameRM
```
public boolean isSameRM(XAResource xares)
                 throws XAException
```
    Specified by:
    
    isSameRM in interface XAResource
    
    Throws:
    
    XAException
  - prepare
```
public int prepare(Xid xid)
            throws XAException
```
    Specified by:
    
    prepare in interface XAResource
    
    Throws:
    
    XAException
  - recover
```
public Xid[] recover(int flags)
              throws XAException
```
    Specified by:
    
    recover in interface XAResource
    
    Throws:
    
    XAException
  - rollback
```
public void rollback(Xid xid)
              throws XAException
```
    Specified by:
    
    rollback in interface XAResource
    
    Throws:
    
    XAException
  - start
```
public void start(Xid xid,
                  int flags)
           throws XAException
```
    Specified by:
    
    start in interface XAResource
    
    Throws:
    
    XAException
  - connectionFailed
```
public void connectionFailed(ActiveMQException me,
                             boolean failedOver)
```
    Description copied from interface: FailureListener
    
    Notifies that a connection has failed due to the specified exception.
    
    Specified by:
    
    connectionFailed in interface FailureListener
    
    Parameters:
    
    me - exception which has caused the connection to fail
  - connectionFailed
```
public void connectionFailed(ActiveMQException me,
                             boolean failedOver,
                             String scaleDownTargetNodeID)
```
    Description copied from interface: FailureListener
    
    Notifies that a connection has failed due to the specified exception.
    
    Specified by:
    
    connectionFailed in interface FailureListener
    
    Parameters:
    
    me - exception which has caused the connection to fail
    
    scaleDownTargetNodeID - the ID of the node to which messages are scaling down
  - setForceNotSameRM
```
public void setForceNotSameRM(boolean force)
```
    Specified by:
    
    setForceNotSameRM in interface ClientSessionInternal
  - getConnection
```
public RemotingConnection getConnection()
```
    Specified by:
    
    getConnection in interface ClientSessionInternal
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - cloneProducers
```
public Set<ClientProducerInternal> cloneProducers()
```
    Not part of the interface, used on tests only
    
    Returns:
  - cloneConsumers
```
public Set<ClientConsumerInternal> cloneConsumers()
```
    Not part of the interface, used on tests only
    
    Returns:
  - convert
```
public static Object convert(Xid xid)
```
    If you ever tried to debug XIDs you will know what this is about. This will serialize and deserialize the XID to the same way it's going to be printed on server logs or print-data.
    This will convert to the same XID deserialized on the Server, hence we will be able to debug eventual stuff
    
    Parameters:
    
    xid -
    
    Returns:
  - setStopSignal
```
public void setStopSignal()
```
    Description copied from interface: ClientSessionInternal
    
    Sets a stop signal to true. This will cancel
    
    Specified by:
    
    setStopSignal in interface ClientSessionInternal
  - isConfirmationWindowEnabled
```
public boolean isConfirmationWindowEnabled()
```
    Specified by:
    
    isConfirmationWindowEnabled in interface ClientSessionInternal
  - scheduleConfirmation
```
public void scheduleConfirmation(SendAcknowledgementHandler handler,
                                 Message message)
```
    Specified by:
    
    scheduleConfirmation in interface ClientSessionInternal
  - getSessionContext
```
public SessionContext getSessionContext()
```
    Specified by:
    
    getSessionContext in interface ClientSessionInternal

Class ClientSessionImpl

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.api.core.client.ClientSession

Field Summary

Fields inherited from interface org.apache.activemq.artemis.api.core.client.ClientSession

Fields inherited from interface javax.transaction.xa.XAResource

Method Summary

Methods inherited from class java.lang.Object

Method Detail

createQueue

createQueue

createQueue

createSharedQueue

createSharedQueue

createQueue

createQueue

createTemporaryQueue

createTemporaryQueue

createTemporaryQueue

createTemporaryQueue

deleteQueue

deleteQueue

queueQuery

addressQuery

createConsumer

createConsumer

createConsumer

createQueue

createConsumer

createConsumer

createConsumer

createConsumer

createConsumer

isWritable

createConsumer

createConsumer

createProducer

createProducer

createProducer

createProducer

createProducer

getXAResource

commit

isRollbackOnly

rollback

rollback

rollback

markRollbackOnly

createMessage

createMessage

createMessage

isClosed

isAutoCommitSends

isAutoCommitAcks

isBlockOnAcknowledge

isXA

resetIfNeeded

start

stop

stop

addFailureListener

removeFailureListener

addFailoverListener

removeFailoverListener

getVersion

isClosing

getNodeId

getMinLargeMessageSize

isCompressLargeMessages

isCacheLargeMessageClient

getName

acknowledge

individualAcknowledge

expire

addConsumer

addProducer

removeConsumer

removeProducer

handleReceiveMessage

handleReceiveLargeMessage