A B C D E F G H I J L M N O P R S T U V W

A

ActiveMQActivationSpec - Class in org.activemq.ra

ActiveMQActivationSpec() - Constructor for class org.activemq.ra.ActiveMQActivationSpec

ActiveMQAsfEndpointWorker - Class in org.activemq.ra

ActiveMQAsfEndpointWorker(ActiveMQResourceAdapter, ActiveMQEndpointActivationKey) - Constructor for class org.activemq.ra.ActiveMQAsfEndpointWorker

ActiveMQBaseEndpointWorker - Class in org.activemq.ra

ActiveMQBaseEndpointWorker(ActiveMQResourceAdapter, ActiveMQEndpointActivationKey) - Constructor for class org.activemq.ra.ActiveMQBaseEndpointWorker

ActiveMQConnectionFactory - Class in org.activemq.ra

ActiveMQConnectionFactory(ActiveMQManagedConnectionFactory, ConnectionManager, ActiveMQConnectionRequestInfo) - Constructor for class org.activemq.ra.ActiveMQConnectionFactory

ActiveMQConnectionRequestInfo - Class in org.activemq.ra

ActiveMQConnectionRequestInfo() - Constructor for class org.activemq.ra.ActiveMQConnectionRequestInfo

ActiveMQEndpointActivationKey - Class in org.activemq.ra

ActiveMQEndpointActivationKey(MessageEndpointFactory, ActiveMQActivationSpec) - Constructor for class org.activemq.ra.ActiveMQEndpointActivationKey

ActiveMQManagedConnection - Class in org.activemq.ra

ActiveMQManagedConnection maps to real physical connection to the server.

ActiveMQManagedConnection(Subject, ActiveMQConnection, ActiveMQConnectionRequestInfo) - Constructor for class org.activemq.ra.ActiveMQManagedConnection

ActiveMQManagedConnectionFactory - Class in org.activemq.ra

ActiveMQManagedConnectionFactory() - Constructor for class org.activemq.ra.ActiveMQManagedConnectionFactory

ActiveMQPollingEndpointWorker - Class in org.activemq.ra

ActiveMQPollingEndpointWorker(ActiveMQResourceAdapter, ActiveMQEndpointActivationKey) - Constructor for class org.activemq.ra.ActiveMQPollingEndpointWorker

ActiveMQResourceAdapter - Class in org.activemq.ra

Knows how to connect to one ActiveMQ server.

ActiveMQResourceAdapter() - Constructor for class org.activemq.ra.ActiveMQResourceAdapter

adapter - Variable in class org.activemq.ra.ActiveMQBaseEndpointWorker

addConnectionEventListener(ConnectionEventListener) - Method in class org.activemq.ra.ActiveMQManagedConnection

addSession(ActiveMQSession) - Method in class org.activemq.ra.RATransactionContext

afterDelivery() - Method in class org.activemq.ra.MessageEndpointProxy

afterDelivery(ActiveMQSession, Message) - Method in class org.activemq.ra.ServerSessionImpl

The ActiveMQSession's run method will call back to this method after dispactching a message to the MessageListener.

allocateConnection(ManagedConnectionFactory, ConnectionRequestInfo) - Method in class org.activemq.ra.DefaultConnectionManager

allocateConnection(ManagedConnectionFactory, ConnectionRequestInfo) - Method in class org.activemq.ra.SimpleConnectionManager

associate(Subject, ActiveMQConnectionRequestInfo) - Method in class org.activemq.ra.ActiveMQManagedConnection

associateConnection(Object) - Method in class org.activemq.ra.ActiveMQManagedConnection

AUTO_ACKNOWLEDGE_MODE - Static variable in class org.activemq.ra.ActiveMQActivationSpec

Auto-acknowledge constant for acknowledgeMode property

B

beforeDelivery(Method) - Method in class org.activemq.ra.MessageEndpointProxy

beforeDelivery(ActiveMQSession, Message) - Method in class org.activemq.ra.ServerSessionImpl

The ActiveMQSession's run method will call back to this method before dispactching a message to the MessageListener.

begin() - Method in class org.activemq.ra.LocalAndXATransaction

begin() - Method in class org.activemq.ra.RATransactionContext

C

CircularQueue - Class in org.activemq.ra

CircularQueue(int, SynchronizedBoolean) - Constructor for class org.activemq.ra.CircularQueue

cleanup() - Method in class org.activemq.ra.ActiveMQManagedConnection

Cleans up all proxy handles attached to this physical connection so that they cannot be used anymore.

cleanup() - Method in class org.activemq.ra.JMSConnectionProxy

Called by the ActiveMQManagedConnection to invalidate this proxy.

cleanup() - Method in class org.activemq.ra.JMSSessionProxy

Called by the ActiveMQManagedConnection to invalidate this proxy.

close() - Method in class org.activemq.ra.jms.ConnectionProxy

close() - Method in class org.activemq.ra.jms.MessageProducerProxy

close() - Method in class org.activemq.ra.jms.SessionProxy

close() - Method in class org.activemq.ra.JMSConnectionProxy

Used to let the ActiveMQManagedConnection that this connection handel is not needed by the app.

close() - Method in class org.activemq.ra.JMSSessionProxy

close() - Method in class org.activemq.ra.ServerSessionImpl

close() - Method in class org.activemq.ra.ServerSessionPoolImpl

commit() - Method in class org.activemq.ra.jms.SessionProxy

commit() - Method in class org.activemq.ra.JMSSessionProxy

commit() - Method in class org.activemq.ra.LocalAndXATransaction

commit(Xid, boolean) - Method in class org.activemq.ra.LocalAndXATransaction

commit() - Method in class org.activemq.ra.RATransactionContext

commit(Xid, boolean) - Method in class org.activemq.ra.RATransactionContext

connection - Variable in class org.activemq.ra.ActiveMQAsfEndpointWorker

connectionClosed(ConnectionEvent) - Method in class org.activemq.ra.DefaultConnectionManager

connectionClosed(ConnectionEvent) - Method in class org.activemq.ra.SimpleConnectionManager

connectionErrorOccurred(ConnectionEvent) - Method in class org.activemq.ra.DefaultConnectionManager

connectionErrorOccurred(ConnectionEvent) - Method in class org.activemq.ra.SimpleConnectionManager

ConnectionProxy - Class in org.activemq.ra.jms

A Connection implementation which can be used with the ActiveMQ JCA Resource Adapter to publish messages using the same JMS session that is used to dispatch messages.

ConnectionProxy() - Constructor for class org.activemq.ra.jms.ConnectionProxy

ConnectionProxyFactory - Class in org.activemq.ra.jms

A ConnectionFactory implementation which creates connections which can be used with the ActiveMQ JCA Resource Adapter to publish messages using the same underlying JMS session that is used to dispatch messages.

ConnectionProxyFactory() - Constructor for class org.activemq.ra.jms.ConnectionProxyFactory

ConnectionProxyMetaData - Class in org.activemq.ra.jms

A ConnectionMetaData object provides information describing the Connection object.

ConnectionProxyMetaData() - Constructor for class org.activemq.ra.jms.ConnectionProxyMetaData

copy() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

createBrowser(Queue) - Method in class org.activemq.ra.jms.SessionProxy

createBrowser(Queue, String) - Method in class org.activemq.ra.jms.SessionProxy

createBrowser(Queue) - Method in class org.activemq.ra.JMSSessionProxy

createBrowser(Queue, String) - Method in class org.activemq.ra.JMSSessionProxy

createBytesMessage() - Method in class org.activemq.ra.jms.SessionProxy

createBytesMessage() - Method in class org.activemq.ra.JMSSessionProxy

createConnection() - Method in class org.activemq.ra.ActiveMQConnectionFactory

createConnection(String, String) - Method in class org.activemq.ra.ActiveMQConnectionFactory

createConnection() - Method in class org.activemq.ra.jms.ConnectionProxyFactory

createConnection(String, String) - Method in class org.activemq.ra.jms.ConnectionProxyFactory

createConnectionConsumer(Destination, String, ServerSessionPool, int) - Method in class org.activemq.ra.jms.ConnectionProxy

createConnectionConsumer(Queue, String, ServerSessionPool, int) - Method in class org.activemq.ra.jms.ConnectionProxy

createConnectionConsumer(Topic, String, ServerSessionPool, int) - Method in class org.activemq.ra.jms.ConnectionProxy

createConnectionConsumer(Queue, String, ServerSessionPool, int) - Method in class org.activemq.ra.JMSConnectionProxy

createConnectionConsumer(Topic, String, ServerSessionPool, int) - Method in class org.activemq.ra.JMSConnectionProxy

createConnectionConsumer(Destination, String, ServerSessionPool, int) - Method in class org.activemq.ra.JMSConnectionProxy

createConnectionFactory(ConnectionManager) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

createConnectionFactory() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

This is used when not running in an app server.

createConsumer(Destination) - Method in class org.activemq.ra.jms.SessionProxy

createConsumer(Destination, String) - Method in class org.activemq.ra.jms.SessionProxy

createConsumer(Destination, String, boolean) - Method in class org.activemq.ra.jms.SessionProxy

createConsumer(Destination) - Method in class org.activemq.ra.JMSSessionProxy

createConsumer(Destination, String) - Method in class org.activemq.ra.JMSSessionProxy

createConsumer(Destination, String, boolean) - Method in class org.activemq.ra.JMSSessionProxy

createDestination() - Method in class org.activemq.ra.ActiveMQActivationSpec

createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class org.activemq.ra.jms.ConnectionProxy

createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class org.activemq.ra.JMSConnectionProxy

createDurableSubscriber(Topic, String) - Method in class org.activemq.ra.jms.SessionProxy

createDurableSubscriber(Topic, String, String, boolean) - Method in class org.activemq.ra.jms.SessionProxy

createDurableSubscriber(Topic, String) - Method in class org.activemq.ra.JMSSessionProxy

createDurableSubscriber(Topic, String, String, boolean) - Method in class org.activemq.ra.JMSSessionProxy

createManagedConnection(Subject, ConnectionRequestInfo) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

createMapMessage() - Method in class org.activemq.ra.jms.SessionProxy

createMapMessage() - Method in class org.activemq.ra.JMSSessionProxy

createMessage() - Method in class org.activemq.ra.jms.SessionProxy

createMessage() - Method in class org.activemq.ra.JMSSessionProxy

createNotSupported(String) - Method in class org.activemq.ra.jms.ConnectionProxy

createObjectMessage() - Method in class org.activemq.ra.jms.SessionProxy

createObjectMessage(Serializable) - Method in class org.activemq.ra.jms.SessionProxy

createObjectMessage() - Method in class org.activemq.ra.JMSSessionProxy

createObjectMessage(Serializable) - Method in class org.activemq.ra.JMSSessionProxy

createProducer(Destination) - Method in class org.activemq.ra.jms.SessionProxy

createProducer(Destination) - Method in class org.activemq.ra.JMSSessionProxy

createPublisher(Topic) - Method in class org.activemq.ra.jms.SessionProxy

createPublisher(Topic) - Method in class org.activemq.ra.JMSSessionProxy

createQueue(String) - Method in class org.activemq.ra.jms.SessionProxy

createQueue(String) - Method in class org.activemq.ra.JMSSessionProxy

createQueueConnection() - Method in class org.activemq.ra.ActiveMQConnectionFactory

createQueueConnection(String, String) - Method in class org.activemq.ra.ActiveMQConnectionFactory

createQueueConnection() - Method in class org.activemq.ra.jms.ConnectionProxyFactory

createQueueConnection(String, String) - Method in class org.activemq.ra.jms.ConnectionProxyFactory

createQueueSession(boolean, int) - Method in class org.activemq.ra.jms.ConnectionProxy

createQueueSession(boolean, int) - Method in class org.activemq.ra.JMSConnectionProxy

createReceiver(Queue) - Method in class org.activemq.ra.jms.SessionProxy

createReceiver(Queue, String) - Method in class org.activemq.ra.jms.SessionProxy

createReceiver(Queue) - Method in class org.activemq.ra.JMSSessionProxy

createReceiver(Queue, String) - Method in class org.activemq.ra.JMSSessionProxy

createSender(Queue) - Method in class org.activemq.ra.jms.SessionProxy

createSender(Queue) - Method in class org.activemq.ra.JMSSessionProxy

createSession(boolean, int) - Method in class org.activemq.ra.jms.ConnectionProxy

createSession(boolean, int) - Method in class org.activemq.ra.JMSConnectionProxy

createStreamMessage() - Method in class org.activemq.ra.jms.SessionProxy

createStreamMessage() - Method in class org.activemq.ra.JMSSessionProxy

createSubscriber(Topic) - Method in class org.activemq.ra.jms.SessionProxy

createSubscriber(Topic, String, boolean) - Method in class org.activemq.ra.jms.SessionProxy

createSubscriber(Topic) - Method in class org.activemq.ra.JMSSessionProxy

createSubscriber(Topic, String, boolean) - Method in class org.activemq.ra.JMSSessionProxy

createTemporaryQueue() - Method in class org.activemq.ra.jms.SessionProxy

createTemporaryQueue() - Method in class org.activemq.ra.JMSSessionProxy

createTemporaryTopic() - Method in class org.activemq.ra.jms.SessionProxy

createTemporaryTopic() - Method in class org.activemq.ra.JMSSessionProxy

createTextMessage() - Method in class org.activemq.ra.jms.SessionProxy

createTextMessage(String) - Method in class org.activemq.ra.jms.SessionProxy

createTextMessage() - Method in class org.activemq.ra.JMSSessionProxy

createTextMessage(String) - Method in class org.activemq.ra.JMSSessionProxy

createTopic(String) - Method in class org.activemq.ra.jms.SessionProxy

createTopic(String) - Method in class org.activemq.ra.JMSSessionProxy

createTopicConnection() - Method in class org.activemq.ra.ActiveMQConnectionFactory

createTopicConnection(String, String) - Method in class org.activemq.ra.ActiveMQConnectionFactory

createTopicConnection() - Method in class org.activemq.ra.jms.ConnectionProxyFactory

createTopicConnection(String, String) - Method in class org.activemq.ra.jms.ConnectionProxyFactory

createTopicSession(boolean, int) - Method in class org.activemq.ra.jms.ConnectionProxy

createTopicSession(boolean, int) - Method in class org.activemq.ra.JMSConnectionProxy

D

DefaultConnectionManager - Class in org.activemq.ra

A simple implementation of a ConnectionManager.

DefaultConnectionManager() - Constructor for class org.activemq.ra.DefaultConnectionManager

destroy() - Method in class org.activemq.ra.ActiveMQManagedConnection

Close down the physical connection to the server.

drain() - Method in class org.activemq.ra.CircularQueue

DUPS_OK_ACKNOWLEDGE_MODE - Static variable in class org.activemq.ra.ActiveMQActivationSpec

Dups-ok-acknowledge constant for acknowledgeMode property *

DURABLE_SUBSCRIPTION - Static variable in class org.activemq.ra.ActiveMQActivationSpec

Durable constant for subscriptionDurability property *

E

end(Xid, int) - Method in class org.activemq.ra.LocalAndXATransaction

end(Xid, int) - Method in class org.activemq.ra.RATransactionContext

endpointActivation(MessageEndpointFactory, ActivationSpec) - Method in class org.activemq.ra.ActiveMQResourceAdapter

endpointActivationKey - Variable in class org.activemq.ra.ActiveMQBaseEndpointWorker

endpointDeactivation(MessageEndpointFactory, ActivationSpec) - Method in class org.activemq.ra.ActiveMQResourceAdapter

endpointFactory - Variable in class org.activemq.ra.ActiveMQBaseEndpointWorker

equals(Object) - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

equals(Object) - Method in class org.activemq.ra.ActiveMQEndpointActivationKey

equals(Object) - Method in class org.activemq.ra.ActiveMQResourceAdapter

F

forget(Xid) - Method in class org.activemq.ra.LocalAndXATransaction

forget(Xid) - Method in class org.activemq.ra.RATransactionContext

G

get() - Method in class org.activemq.ra.CircularQueue

getAcknowledgeMode() - Method in class org.activemq.ra.ActiveMQActivationSpec

getAcknowledgeMode() - Method in class org.activemq.ra.jms.SessionProxy

getAcknowledgeMode() - Method in class org.activemq.ra.JMSSessionProxy

getAcknowledgeModeForSession() - Method in class org.activemq.ra.ActiveMQActivationSpec

getActivationSpec() - Method in class org.activemq.ra.ActiveMQEndpointActivationKey

getActiveSessionAndProducer() - Static method in class org.activemq.ra.SessionAndProducerHelper

Returns the current SessionAndProducer used by the current thread which is processing a message.

getBootstrapContext() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getBrokerXmlConfig() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getClientId() - Method in class org.activemq.ra.ActiveMQActivationSpec

getClientid() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

getClientid() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

getClientid() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getClientID() - Method in class org.activemq.ra.jms.ConnectionProxy

getClientID() - Method in class org.activemq.ra.JMSConnectionProxy

getConnection(Subject, ConnectionRequestInfo) - Method in class org.activemq.ra.ActiveMQManagedConnection

getDeliveryMode() - Method in class org.activemq.ra.jms.MessageProducerProxy

getDestination() - Method in class org.activemq.ra.ActiveMQActivationSpec

getDestination() - Method in class org.activemq.ra.jms.MessageProducerProxy

getDestinationType() - Method in class org.activemq.ra.ActiveMQActivationSpec

getDisableMessageID() - Method in class org.activemq.ra.jms.MessageProducerProxy

getDisableMessageTimestamp() - Method in class org.activemq.ra.jms.MessageProducerProxy

getEnableBatch() - Method in class org.activemq.ra.ActiveMQActivationSpec

getEnableBatchBooleanValue() - Method in class org.activemq.ra.ActiveMQActivationSpec

getEndpointWorkerType() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getExceptionListener() - Method in class org.activemq.ra.jms.ConnectionProxy

getExceptionListener() - Method in class org.activemq.ra.JMSConnectionProxy

getInfo() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getJMSMajorVersion() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets the JMS major version number.

getJMSMinorVersion() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets the JMS minor version number.

getJMSProviderName() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets the JMS provider name.

getJMSVersion() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets the JMS API version.

getJMSXPropertyNames() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets an enumeration of the JMSX property names.

getLocalTransaction() - Method in class org.activemq.ra.ActiveMQManagedConnection

getLogWriter() - Method in class org.activemq.ra.ActiveMQManagedConnection

getLogWriter() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

getManagedConnection() - Method in class org.activemq.ra.JMSConnectionProxy

getMaxMessagesPerBatch() - Method in class org.activemq.ra.ActiveMQActivationSpec

getMaxMessagesPerBatchIntValue() - Method in class org.activemq.ra.ActiveMQActivationSpec

getMaxMessagesPerSessions() - Method in class org.activemq.ra.ActiveMQActivationSpec

getMaxMessagesPerSessionsIntValue() - Method in class org.activemq.ra.ActiveMQActivationSpec

getMaxSessions() - Method in class org.activemq.ra.ActiveMQActivationSpec

getMaxSessionsIntValue() - Method in class org.activemq.ra.ActiveMQActivationSpec

getMessage() - Method in class org.activemq.ra.InboundEndpointWork

getMessageEndpointFactory() - Method in class org.activemq.ra.ActiveMQEndpointActivationKey

getMessageListener() - Method in class org.activemq.ra.jms.SessionProxy

getMessageListener() - Method in class org.activemq.ra.JMSSessionProxy

getMessageProducer() - Method in class org.activemq.ra.InboundEndpointWork

getMessageProducer() - Method in class org.activemq.ra.ServerSessionImpl

getMessageProducer() - Method in interface org.activemq.ra.SessionAndProducer

Lazily creates a message producer that can be used to send messages using the same JMS Session which is being used to dispatch messages which minimises the XA overheard of consuming and producing or allows JMS transactions to be used for consuming and producing messages.

getMessageSelector() - Method in class org.activemq.ra.ActiveMQActivationSpec

getMetaData() - Method in class org.activemq.ra.ActiveMQManagedConnection

getMetaData() - Method in class org.activemq.ra.jms.ConnectionProxy

getMetaData() - Method in class org.activemq.ra.JMSConnectionProxy

getNoLocal() - Method in class org.activemq.ra.ActiveMQActivationSpec

getNoLocalBooleanValue() - Method in class org.activemq.ra.ActiveMQActivationSpec

getPassword() - Method in class org.activemq.ra.ActiveMQActivationSpec

getPassword() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

getPassword() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

getPassword() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getPhysicalConnection() - Method in class org.activemq.ra.ActiveMQManagedConnection

getPriority() - Method in class org.activemq.ra.jms.MessageProducerProxy

getProviderMajorVersion() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets the JMS provider major version number.

getProviderMinorVersion() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets the JMS provider minor version number.

getProviderVersion() - Method in class org.activemq.ra.jms.ConnectionProxyMetaData

Gets the JMS provider version.

getQueue() - Method in class org.activemq.ra.jms.MessageProducerProxy

getQueueSession() - Method in class org.activemq.ra.jms.SessionProxy

getReference() - Method in class org.activemq.ra.ActiveMQConnectionFactory

getResourceAdapter() - Method in class org.activemq.ra.ActiveMQActivationSpec

getResourceAdapter() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

getServerSession() - Method in class org.activemq.ra.ServerSessionPoolImpl

getServerUrl() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

getServerUrl() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

getServerUrl() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getSession() - Method in class org.activemq.ra.InboundEndpointWork

getSession() - Method in class org.activemq.ra.jms.SessionProxy

getSession() - Method in class org.activemq.ra.ServerSessionImpl

getSession() - Method in interface org.activemq.ra.SessionAndProducer

Returns the current session being used to process a JMS message in the current thread.

getSessionAndProducer() - Method in class org.activemq.ra.jms.SessionProxy

getSubscriptionDurability() - Method in class org.activemq.ra.ActiveMQActivationSpec

getSubscriptionName() - Method in class org.activemq.ra.ActiveMQActivationSpec

getTimeToLive() - Method in class org.activemq.ra.jms.MessageProducerProxy

getTopic() - Method in class org.activemq.ra.jms.MessageProducerProxy

getTopicSession() - Method in class org.activemq.ra.jms.SessionProxy

getTransacted() - Method in class org.activemq.ra.jms.SessionProxy

getTransacted() - Method in class org.activemq.ra.JMSSessionProxy

getTransactionContext() - Method in class org.activemq.ra.ActiveMQManagedConnection

getTransactionId() - Method in class org.activemq.ra.RATransactionContext

getTransactionTimeout() - Method in class org.activemq.ra.LocalAndXATransaction

getTransactionTimeout() - Method in class org.activemq.ra.RATransactionContext

getUseEmbeddedBroker() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getUseInboundSession() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

getUseInboundSession() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

getUseInboundSession() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getUseRAManagedTransaction() - Method in class org.activemq.ra.ActiveMQActivationSpec

getUserName() - Method in class org.activemq.ra.ActiveMQActivationSpec

getUserName() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

getUserName() - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

getUserName() - Method in class org.activemq.ra.ActiveMQResourceAdapter

getXAResource() - Method in class org.activemq.ra.ActiveMQManagedConnection

getXAResources(ActivationSpec[]) - Method in class org.activemq.ra.ActiveMQResourceAdapter

We only connect to one resource manager per ResourceAdapter instance, so any ActivationSpec will return the same XAResource.

H

hashCode() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

hashCode() - Method in class org.activemq.ra.ActiveMQEndpointActivationKey

hashCode() - Method in class org.activemq.ra.ActiveMQResourceAdapter

I

InboundEndpointWork - Class in org.activemq.ra

InboundEndpointWork(ActiveMQSession, MessageEndpoint, CircularQueue) - Constructor for class org.activemq.ra.InboundEndpointWork

INVALID_ACKNOWLEDGE_MODE - Static variable in class org.activemq.ra.ActiveMQActivationSpec

InvalidMessageEndpointException - Exception in org.activemq.ra

Thrown to indicate that a MessageEndpoint is no longer valid and should be discarded.

InvalidMessageEndpointException() - Constructor for exception org.activemq.ra.InvalidMessageEndpointException

Constructs a new exception with null as its detail message.

InvalidMessageEndpointException(String) - Constructor for exception org.activemq.ra.InvalidMessageEndpointException

Constructs a new exception with the specified detail message.

InvalidMessageEndpointException(String, Throwable) - Constructor for exception org.activemq.ra.InvalidMessageEndpointException

Constructs a new exception with the specified detail message and cause.

InvalidMessageEndpointException(Throwable) - Constructor for exception org.activemq.ra.InvalidMessageEndpointException

Constructs a new exception with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).

isDurableSubscription() - Method in class org.activemq.ra.ActiveMQActivationSpec

isInLocalTransaction() - Method in class org.activemq.ra.RATransactionContext

isInManagedTx() - Method in class org.activemq.ra.ActiveMQManagedConnection

isInManagedTx() - Method in class org.activemq.ra.LocalAndXATransaction

isInXATransaction() - Method in class org.activemq.ra.RATransactionContext

isSameRM(XAResource) - Method in class org.activemq.ra.LocalAndXATransaction

isSameRM(XAResource) - Method in class org.activemq.ra.RATransactionContext

isUseEmbeddedBroker() - Method in class org.activemq.ra.ActiveMQResourceAdapter

isUseInboundSessionEnabled() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

isUseRAManagedTransactionEnabled() - Method in class org.activemq.ra.ActiveMQActivationSpec

J

JMSConnectionProxy - Class in org.activemq.ra

Acts as a pass through proxy for a JMS Connection object.

JMSConnectionProxy(ActiveMQManagedConnection) - Constructor for class org.activemq.ra.JMSConnectionProxy

JMSSessionProxy - Class in org.activemq.ra

Acts as a pass through proxy for a JMS Session object.

JMSSessionProxy(ActiveMQSession) - Constructor for class org.activemq.ra.JMSSessionProxy

L

LocalAndXATransaction - Class in org.activemq.ra

Used to provide a LocalTransaction and XAResource to a JMS session.

LocalAndXATransaction(TransactionContext) - Constructor for class org.activemq.ra.LocalAndXATransaction

localTransactionCommitted(ConnectionEvent) - Method in class org.activemq.ra.DefaultConnectionManager

localTransactionCommitted(ConnectionEvent) - Method in class org.activemq.ra.SimpleConnectionManager

localTransactionRolledback(ConnectionEvent) - Method in class org.activemq.ra.DefaultConnectionManager

localTransactionRolledback(ConnectionEvent) - Method in class org.activemq.ra.SimpleConnectionManager

localTransactionStarted(ConnectionEvent) - Method in class org.activemq.ra.DefaultConnectionManager

localTransactionStarted(ConnectionEvent) - Method in class org.activemq.ra.SimpleConnectionManager

M

makeConnection() - Method in class org.activemq.ra.ActiveMQResourceAdapter

Return a connection using the default connection request info from the RAR deployment.

makeConnection(ActiveMQConnectionRequestInfo) - Method in class org.activemq.ra.ActiveMQResourceAdapter

Return a connection using a specific connection request info.

makeConnection(ActiveMQActivationSpec) - Method in class org.activemq.ra.ActiveMQResourceAdapter

matches(Object, Object) - Static method in class org.activemq.ra.ActiveMQManagedConnection

matches(Subject, ConnectionRequestInfo) - Method in class org.activemq.ra.ActiveMQManagedConnection

matchManagedConnections(Set, Subject, ConnectionRequestInfo) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

MessageEndpointProxy - Class in org.activemq.ra

MessageEndpointProxy(MessageEndpoint) - Constructor for class org.activemq.ra.MessageEndpointProxy

MessageProducerProxy - Class in org.activemq.ra.jms

An implementation of MessageProducer which uses the ActiveMQ JCA ResourceAdapter's current thread's JMS Session to send messages.

MessageProducerProxy(MessageProducer, Destination) - Constructor for class org.activemq.ra.jms.MessageProducerProxy

N

NON_DURABLE_SUBSCRIPTION - Static variable in class org.activemq.ra.ActiveMQActivationSpec

NonDurable constant for subscriptionDurability property *

notifyWaiting() - Method in class org.activemq.ra.CircularQueue

O

ON_MESSAGE_METHOD - Static variable in class org.activemq.ra.ActiveMQBaseEndpointWorker

ON_MESSAGE_METHOD - Static variable in class org.activemq.ra.ServerSessionImpl

onException(JMSException) - Method in class org.activemq.ra.ActiveMQManagedConnection

onException(JMSException) - Method in class org.activemq.ra.JMSConnectionProxy

onMessage(Message) - Method in class org.activemq.ra.MessageEndpointProxy

org.activemq.ra - package org.activemq.ra

JCA managed connections and resource adapters for working with ActiveMQ

org.activemq.ra.jms - package org.activemq.ra.jms

A JMS provider for working with ActiveMQ's JCA ResourceAdapter which uses the same JMS Session that is being used to dispatch JMS Messages inside a JCA or MDB container.

P

prepare(Xid) - Method in class org.activemq.ra.LocalAndXATransaction

prepare(Xid) - Method in class org.activemq.ra.RATransactionContext

proxyClosedEvent(JMSConnectionProxy) - Method in class org.activemq.ra.ActiveMQManagedConnection

When a proxy is closed this cleans up the proxy and notifys the ConnectionEventListeners that a connection closed.

publish(Message) - Method in class org.activemq.ra.jms.MessageProducerProxy

publish(Message, int, int, long) - Method in class org.activemq.ra.jms.MessageProducerProxy

publish(Topic, Message) - Method in class org.activemq.ra.jms.MessageProducerProxy

publish(Topic, Message, int, int, long) - Method in class org.activemq.ra.jms.MessageProducerProxy

R

RATransactionContext - Class in org.activemq.ra

Allows us to switch between using a shared transaction context, or using a local transaction context.

RATransactionContext(TransactionContext) - Constructor for class org.activemq.ra.RATransactionContext

recover() - Method in class org.activemq.ra.jms.SessionProxy

recover() - Method in class org.activemq.ra.JMSSessionProxy

recover(int) - Method in class org.activemq.ra.LocalAndXATransaction

recover(int) - Method in class org.activemq.ra.RATransactionContext

register(SessionAndProducer) - Static method in class org.activemq.ra.SessionAndProducerHelper

Registers the session and producer which should be called before the MessageEndpoint.beforeDelivery(java.lang.reflect.Method) method is called.

registerThreadSession(Session) - Method in class org.activemq.ra.ActiveMQAsfEndpointWorker

release() - Method in class org.activemq.ra.ActiveMQPollingEndpointWorker

release() - Method in class org.activemq.ra.InboundEndpointWork

release() - Method in class org.activemq.ra.MessageEndpointProxy

release() - Method in class org.activemq.ra.ServerSessionImpl

removeConnectionEventListener(ConnectionEventListener) - Method in class org.activemq.ra.ActiveMQManagedConnection

removeFromPool(ServerSessionImpl) - Method in class org.activemq.ra.ServerSessionPoolImpl

removeSession(ActiveMQSession) - Method in class org.activemq.ra.RATransactionContext

returnObject(Object) - Method in class org.activemq.ra.CircularQueue

returnToPool(ServerSessionImpl) - Method in class org.activemq.ra.ServerSessionPoolImpl

rollback() - Method in class org.activemq.ra.jms.SessionProxy

rollback() - Method in class org.activemq.ra.JMSSessionProxy

rollback() - Method in class org.activemq.ra.LocalAndXATransaction

rollback(Xid) - Method in class org.activemq.ra.LocalAndXATransaction

rollback() - Method in class org.activemq.ra.RATransactionContext

rollback(Xid) - Method in class org.activemq.ra.RATransactionContext

run() - Method in class org.activemq.ra.ActiveMQPollingEndpointWorker

The WorkManager has started up and we now need to pull message off the destination and push them to an endpoint.

run() - Method in class org.activemq.ra.InboundEndpointWork

run() - Method in class org.activemq.ra.jms.SessionProxy

run() - Method in class org.activemq.ra.JMSSessionProxy

run() - Method in class org.activemq.ra.ServerSessionImpl

S

safeClose(Session) - Static method in class org.activemq.ra.ActiveMQBaseEndpointWorker

safeClose(Connection) - Static method in class org.activemq.ra.ActiveMQBaseEndpointWorker

safeClose(ConnectionConsumer) - Static method in class org.activemq.ra.ActiveMQBaseEndpointWorker

send(Destination, Message) - Method in class org.activemq.ra.jms.MessageProducerProxy

send(Destination, Message, int, int, long) - Method in class org.activemq.ra.jms.MessageProducerProxy

send(Message) - Method in class org.activemq.ra.jms.MessageProducerProxy

send(Message, int, int, long) - Method in class org.activemq.ra.jms.MessageProducerProxy

send(Queue, Message) - Method in class org.activemq.ra.jms.MessageProducerProxy

send(Queue, Message, int, int, long) - Method in class org.activemq.ra.jms.MessageProducerProxy

ServerSessionImpl - Class in org.activemq.ra

ServerSessionImpl(ServerSessionPoolImpl, ActiveMQSession, WorkManager, MessageEndpoint, boolean, int) - Constructor for class org.activemq.ra.ServerSessionImpl

ServerSessionPoolImpl - Class in org.activemq.ra

ServerSessionPoolImpl(ActiveMQAsfEndpointWorker, int) - Constructor for class org.activemq.ra.ServerSessionPoolImpl

SessionAndProducer - Interface in org.activemq.ra

Represents an object which has-a Session instance and an optional, lazily created MessageProducer instance which can them be used by a pooling based JMS provider for publishing messages using the session used by the current thread.

SessionAndProducerHelper - Class in org.activemq.ra

A helper class used to provide access to the current active SessionAndProducer instance being used to process a message in the current thread so that messages can be produced using the same session.

SessionAndProducerHelper() - Constructor for class org.activemq.ra.SessionAndProducerHelper

SessionProxy - Class in org.activemq.ra.jms

A Session implementation which can be used with the ActiveMQ JCA Resource Adapter to publish messages using the same JMS session that is used to dispatch messages.

SessionProxy() - Constructor for class org.activemq.ra.jms.SessionProxy

setAcknowledgeMode(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setBrokerXmlConfig(String) - Method in class org.activemq.ra.ActiveMQResourceAdapter

Sets the XML configuration file used to configure the ActiveMQ broker via Spring if using embedded mode.

setClientId(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setClientid(String) - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

setClientid(String) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

setClientid(String) - Method in class org.activemq.ra.ActiveMQResourceAdapter

setClientID(String) - Method in class org.activemq.ra.jms.ConnectionProxy

setClientID(String) - Method in class org.activemq.ra.JMSConnectionProxy

setDeliveryMode(int) - Method in class org.activemq.ra.jms.MessageProducerProxy

setDestination(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setDestinationType(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setDisableMessageID(boolean) - Method in class org.activemq.ra.jms.MessageProducerProxy

setDisableMessageTimestamp(boolean) - Method in class org.activemq.ra.jms.MessageProducerProxy

setEnableBatch(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setEndpointWorkerType(String) - Method in class org.activemq.ra.ActiveMQResourceAdapter

setExceptionListener(ExceptionListener) - Method in class org.activemq.ra.jms.ConnectionProxy

setExceptionListener(ExceptionListener) - Method in class org.activemq.ra.JMSConnectionProxy

setInManagedTx(boolean) - Method in class org.activemq.ra.LocalAndXATransaction

setLogWriter(PrintWriter) - Method in class org.activemq.ra.ActiveMQManagedConnection

setLogWriter(PrintWriter) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

setMaxMessagesPerBatch(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setMaxMessagesPerSessions(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setMaxSessions(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setMessage(ActiveMQMessage) - Method in class org.activemq.ra.InboundEndpointWork

setMessageListener(MessageListener) - Method in class org.activemq.ra.jms.SessionProxy

setMessageListener(MessageListener) - Method in class org.activemq.ra.JMSSessionProxy

setMessageSelector(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setNoLocal(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setPassword(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setPassword(String) - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

setPassword(String) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

setPassword(String) - Method in class org.activemq.ra.ActiveMQResourceAdapter

setPriority(int) - Method in class org.activemq.ra.jms.MessageProducerProxy

setReference(Reference) - Method in class org.activemq.ra.ActiveMQConnectionFactory

setResourceAdapter(ResourceAdapter) - Method in class org.activemq.ra.ActiveMQActivationSpec

setResourceAdapter(ResourceAdapter) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

setServerUrl(String) - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

setServerUrl(String) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

setServerUrl(String) - Method in class org.activemq.ra.ActiveMQResourceAdapter

setSubscriptionDurability(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setSubscriptionName(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setTimeToLive(long) - Method in class org.activemq.ra.jms.MessageProducerProxy

setTransactionTimeout(int) - Method in class org.activemq.ra.LocalAndXATransaction

setTransactionTimeout(int) - Method in class org.activemq.ra.RATransactionContext

setUseEmbeddedBroker(Boolean) - Method in class org.activemq.ra.ActiveMQResourceAdapter

setUseInboundSession(Boolean) - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

setUseInboundSession(Boolean) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

setUseInboundSession(Boolean) - Method in class org.activemq.ra.ActiveMQResourceAdapter

setUseRAManagedTransaction(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setUserName(String) - Method in class org.activemq.ra.ActiveMQActivationSpec

setUserName(String) - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

setUserName(String) - Method in class org.activemq.ra.ActiveMQManagedConnectionFactory

setUserName(String) - Method in class org.activemq.ra.ActiveMQResourceAdapter

setUseSharedTxContext(boolean) - Method in class org.activemq.ra.JMSConnectionProxy

setUseSharedTxContext(boolean) - Method in class org.activemq.ra.JMSSessionProxy

setUseSharedTxContext(boolean) - Method in class org.activemq.ra.RATransactionContext

SimpleConnectionManager - Class in org.activemq.ra

A simple implementation of a ConnectionManager.

SimpleConnectionManager() - Constructor for class org.activemq.ra.SimpleConnectionManager

size() - Method in class org.activemq.ra.CircularQueue

start() - Method in class org.activemq.ra.ActiveMQAsfEndpointWorker

start() - Method in class org.activemq.ra.ActiveMQBaseEndpointWorker

start() - Method in class org.activemq.ra.ActiveMQPollingEndpointWorker

start(BootstrapContext) - Method in class org.activemq.ra.ActiveMQResourceAdapter

start() - Method in class org.activemq.ra.jms.ConnectionProxy

start() - Method in class org.activemq.ra.JMSConnectionProxy

start(Xid, int) - Method in class org.activemq.ra.LocalAndXATransaction

start(Xid, int) - Method in class org.activemq.ra.RATransactionContext

start() - Method in class org.activemq.ra.ServerSessionImpl

stop() - Method in class org.activemq.ra.ActiveMQAsfEndpointWorker

stop() - Method in class org.activemq.ra.ActiveMQBaseEndpointWorker

stop() - Method in class org.activemq.ra.ActiveMQPollingEndpointWorker

stop() - Method in class org.activemq.ra.ActiveMQResourceAdapter

stop() - Method in class org.activemq.ra.jms.ConnectionProxy

stop() - Method in class org.activemq.ra.JMSConnectionProxy

T

toString() - Method in class org.activemq.ra.ActiveMQActivationSpec

toString() - Method in class org.activemq.ra.ActiveMQConnectionRequestInfo

toString() - Method in class org.activemq.ra.MessageEndpointProxy

toString() - Method in class org.activemq.ra.ServerSessionImpl

transacted - Variable in class org.activemq.ra.ActiveMQBaseEndpointWorker

U

unregister(SessionAndProducer) - Static method in class org.activemq.ra.SessionAndProducerHelper

Unregisters the session and producer which should be called after the MessageEndpoint.afterDelivery() method is called.

unregisterThreadSession(Session) - Method in class org.activemq.ra.ActiveMQAsfEndpointWorker

unsubscribe(String) - Method in class org.activemq.ra.jms.SessionProxy

unsubscribe(String) - Method in class org.activemq.ra.JMSSessionProxy

V

validate() - Method in class org.activemq.ra.ActiveMQActivationSpec

W

workManager - Variable in class org.activemq.ra.ActiveMQBaseEndpointWorker

A B C D E F G H I J L M N O P R S T U V W