| Package | Description |
|---|---|
| org.apache.activemq |
The core JMS client API implementation classes.
|
| org.apache.activemq.camel |
Defines a JMS client which is capable of sending and receiving messages to
Apache Camel
endpoints to provide
Enterprise Integration Patterns
integration in any JMS client application.
|
| org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
| org.apache.activemq.management |
An implementation of the J2EE Management API
|
| org.apache.activemq.pool |
A JMS provider which pools Connection, Session and MessageProducer instances so it can be used with tools like
Spring's JmsTemplate.
|
| org.apache.activemq.ra |
JCA managed connections and resource adapters for working with ActiveMQ
|
| Modifier and Type | Class and Description |
|---|---|
class |
ActiveMQXAConnection
The XAConnection interface extends the capability of Connection by providing
an XASession (optional).
|
| Modifier and Type | Field and Description |
|---|---|
protected ActiveMQConnection |
ActiveMQSession.connection |
| Modifier and Type | Method and Description |
|---|---|
protected ActiveMQConnection |
ActiveMQConnectionFactory.createActiveMQConnection() |
protected ActiveMQConnection |
ActiveMQConnectionFactory.createActiveMQConnection(java.lang.String userName,
java.lang.String password) |
protected ActiveMQConnection |
ActiveMQXAConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats) |
protected ActiveMQConnection |
ActiveMQConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats) |
ActiveMQConnection |
TransactionContext.getConnection() |
ActiveMQConnection |
ActiveMQSession.getConnection() |
static ActiveMQConnection |
ActiveMQConnection.makeConnection()
A static helper method to create a new connection
|
static ActiveMQConnection |
ActiveMQConnection.makeConnection(java.lang.String uri)
A static helper method to create a new connection
|
static ActiveMQConnection |
ActiveMQConnection.makeConnection(java.lang.String user,
java.lang.String password,
java.lang.String uri)
A static helper method to create a new connection
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
ActiveMQConnectionFactory.configureConnection(ActiveMQConnection connection) |
static ActiveMQMessage |
ActiveMQMessageTransformation.transformMessage(javax.jms.Message message,
ActiveMQConnection connection)
Creates a fast shallow copy of the current ActiveMQMessage or creates a
whole new message instance from an available JMS message from another
provider.
|
| Constructor and Description |
|---|
ActiveMQConnectionConsumer(ActiveMQConnection theConnection,
javax.jms.ServerSessionPool theSessionPool,
ConsumerInfo theConsumerInfo)
Create a ConnectionConsumer
|
ActiveMQInputStream(ActiveMQConnection connection,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String selector,
boolean noLocal,
java.lang.String name,
int prefetch,
long timeout) |
ActiveMQOutputStream(ActiveMQConnection connection,
ProducerId producerId,
ActiveMQDestination destination,
java.util.Map<java.lang.String,java.lang.Object> properties,
int deliveryMode,
int priority,
long timeToLive) |
ActiveMQSession(ActiveMQConnection connection,
SessionId sessionId,
int acknowledgeMode,
boolean asyncDispatch) |
ActiveMQSession(ActiveMQConnection connection,
SessionId sessionId,
int acknowledgeMode,
boolean asyncDispatch,
boolean sessionAsyncDispatch)
Construct the Session
|
AdvisoryConsumer(ActiveMQConnection connection,
ConsumerId consumerId) |
TransactionContext(ActiveMQConnection connection) |
| Modifier and Type | Class and Description |
|---|---|
class |
CamelConnection |
| Modifier and Type | Field and Description |
|---|---|
protected ActiveMQConnection |
ActiveMQTempDestination.connection |
| Modifier and Type | Method and Description |
|---|---|
ActiveMQConnection |
Message.getConnection() |
ActiveMQConnection |
ActiveMQTempDestination.getConnection() |
| Modifier and Type | Method and Description |
|---|---|
void |
Message.setConnection(ActiveMQConnection connection) |
void |
ActiveMQTempDestination.setConnection(ActiveMQConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
JMSStatsImpl.addConnection(ActiveMQConnection connection) |
void |
JMSStatsImpl.removeConnection(ActiveMQConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
protected ActiveMQConnection |
PooledConnectionFactory.createConnection(ConnectionKey key) |
ActiveMQConnection |
PooledConnection.getConnection() |
ActiveMQConnection |
ConnectionPool.getConnection() |
| Modifier and Type | Method and Description |
|---|---|
protected ConnectionPool |
XaPooledConnectionFactory.createConnectionPool(ActiveMQConnection connection) |
protected ConnectionPool |
PooledConnectionFactory.createConnectionPool(ActiveMQConnection connection)
Delegate that creates each instance of an ConnectionPool object.
|
protected ConnectionPool |
JcaPooledConnectionFactory.createConnectionPool(ActiveMQConnection connection) |
| Constructor and Description |
|---|
ActiveMQResourceManager.ConnectionAndWrapperNamedXAResource(javax.transaction.xa.XAResource xaResource,
java.lang.String name,
ActiveMQConnection connection) |
ConnectionPool(ActiveMQConnection connection) |
JcaConnectionPool(ActiveMQConnection connection,
javax.transaction.TransactionManager transactionManager,
java.lang.String name) |
XaConnectionPool(ActiveMQConnection connection,
javax.transaction.TransactionManager transactionManager) |
| Modifier and Type | Method and Description |
|---|---|
protected ActiveMQConnection |
ActiveMQEndpointWorker.getConnection() |
ActiveMQConnection |
ActiveMQResourceAdapter.makeConnection() |
ActiveMQConnection |
MessageResourceAdapter.makeConnection(ActiveMQConnectionRequestInfo info) |
ActiveMQConnection |
ActiveMQConnectionSupport.makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo)
Creates a new physical connection to an Active MQ broker identified by given
connection request information.
|
ActiveMQConnection |
ActiveMQConnectionSupport.makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo,
ActiveMQConnectionFactory connectionFactory)
Creates a new physical connection to an Active MQ broker using a given
connection factory and credentials supplied in connection request information.
|
ActiveMQConnection |
MessageResourceAdapter.makeConnection(MessageActivationSpec activationSpec) |
ActiveMQConnection |
ActiveMQResourceAdapter.makeConnection(MessageActivationSpec activationSpec) |
| Constructor and Description |
|---|
ActiveMQManagedConnection(javax.security.auth.Subject subject,
ActiveMQConnection physicalConnection,
ActiveMQConnectionRequestInfo info) |
Copyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.