Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
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(String userName,
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(String uri)
A static helper method to create a new connection
|
static ActiveMQConnection |
ActiveMQConnection.makeConnection(String user,
String password,
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,
String selector,
boolean noLocal,
String name,
int prefetch,
long timeout) |
ActiveMQOutputStream(ActiveMQConnection connection,
ProducerId producerId,
ActiveMQDestination destination,
Map<String,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 | Field and Description |
---|---|
protected ActiveMQConnection |
ActiveMQTempDestination.connection |
Modifier and Type | Method and Description |
---|---|
ActiveMQConnection |
ActiveMQTempDestination.getConnection() |
ActiveMQConnection |
Message.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQTempDestination.setConnection(ActiveMQConnection connection) |
void |
Message.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() |
protected ActiveMQConnection |
SessionPool.getConnection() |
ActiveMQConnection |
ConnectionPool.getConnection() |
Modifier and Type | Method and Description |
---|---|
protected ConnectionPool |
JcaPooledConnectionFactory.createConnectionPool(ActiveMQConnection connection) |
protected ConnectionPool |
PooledConnectionFactory.createConnectionPool(ActiveMQConnection connection) |
protected ConnectionPool |
XaPooledConnectionFactory.createConnectionPool(ActiveMQConnection connection) |
Constructor and Description |
---|
ActiveMQResourceManager.ConnectionAndWrapperNamedXAResource(XAResource xaResource,
String name,
ActiveMQConnection connection) |
ConnectionPool(ActiveMQConnection connection,
ConcurrentHashMap<SessionKey,SessionPool> cache,
org.apache.commons.pool.ObjectPoolFactory poolFactory) |
ConnectionPool(ActiveMQConnection connection,
org.apache.commons.pool.ObjectPoolFactory poolFactory) |
JcaConnectionPool(ActiveMQConnection connection,
org.apache.commons.pool.ObjectPoolFactory poolFactory,
TransactionManager transactionManager,
String name) |
XaConnectionPool(ActiveMQConnection connection,
org.apache.commons.pool.ObjectPoolFactory poolFactory,
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 |
ActiveMQResourceAdapter.makeConnection(MessageActivationSpec activationSpec) |
ActiveMQConnection |
MessageResourceAdapter.makeConnection(MessageActivationSpec activationSpec) |
Constructor and Description |
---|
ActiveMQManagedConnection(Subject subject,
ActiveMQConnection physicalConnection,
ActiveMQConnectionRequestInfo info) |
Copyright © 2005–2016. All rights reserved.