public class ActiveMQEndpointWorker extends Object
Modifier and Type | Field and Description |
---|---|
protected ActiveMQEndpointActivationKey |
endpointActivationKey |
protected MessageEndpointFactory |
endpointFactory |
static Method |
ON_MESSAGE_METHOD |
protected boolean |
transacted |
protected WorkManager |
workManager |
Modifier | Constructor and Description |
---|---|
protected |
ActiveMQEndpointWorker(MessageResourceAdapter adapter,
ActiveMQEndpointActivationKey key) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.activemq.ActiveMQConnection |
getConnection() |
protected void |
registerThreadSession(Session session) |
static void |
safeClose(Connection c) |
static void |
safeClose(ConnectionConsumer cc) |
void |
setConnection(org.apache.activemq.ActiveMQConnection activeMQConnection) |
void |
start() |
void |
stop() |
protected void |
unregisterThreadSession(Session session) |
public static final Method ON_MESSAGE_METHOD
protected final ActiveMQEndpointActivationKey endpointActivationKey
protected final MessageEndpointFactory endpointFactory
protected final WorkManager workManager
protected final boolean transacted
protected ActiveMQEndpointWorker(MessageResourceAdapter adapter, ActiveMQEndpointActivationKey key) throws ResourceException
ResourceException
public static void safeClose(Connection c)
c
- public static void safeClose(ConnectionConsumer cc)
cc
- public void start() throws ResourceException
ResourceException
public void stop() throws InterruptedException
InterruptedException
protected void registerThreadSession(Session session)
protected void unregisterThreadSession(Session session)
public void setConnection(org.apache.activemq.ActiveMQConnection activeMQConnection)
protected org.apache.activemq.ActiveMQConnection getConnection()
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.