public class ActiveMQEndpointWorker extends Object
Modifier and Type | Field and Description |
---|---|
protected ActiveMQEndpointActivationKey |
endpointActivationKey |
protected javax.resource.spi.endpoint.MessageEndpointFactory |
endpointFactory |
static Method |
ON_MESSAGE_METHOD |
protected boolean |
transacted |
protected javax.resource.spi.work.WorkManager |
workManager |
Modifier | Constructor and Description |
---|---|
protected |
ActiveMQEndpointWorker(MessageResourceAdapter adapter,
ActiveMQEndpointActivationKey key) |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQConnection |
getConnection() |
protected void |
registerThreadSession(javax.jms.Session session) |
static void |
safeClose(javax.jms.Connection c) |
static void |
safeClose(javax.jms.ConnectionConsumer cc) |
void |
setConnection(ActiveMQConnection activeMQConnection) |
void |
start() |
void |
stop() |
protected void |
unregisterThreadSession(javax.jms.Session session) |
public static final Method ON_MESSAGE_METHOD
protected final ActiveMQEndpointActivationKey endpointActivationKey
protected final javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory
protected final javax.resource.spi.work.WorkManager workManager
protected final boolean transacted
protected ActiveMQEndpointWorker(MessageResourceAdapter adapter, ActiveMQEndpointActivationKey key) throws javax.resource.ResourceException
javax.resource.ResourceException
public static void safeClose(javax.jms.Connection c)
c
- public static void safeClose(javax.jms.ConnectionConsumer cc)
cc
- public void start() throws javax.resource.ResourceException
javax.resource.ResourceException
public void stop() throws InterruptedException
InterruptedException
protected void registerThreadSession(javax.jms.Session session)
protected void unregisterThreadSession(javax.jms.Session session)
public void setConnection(ActiveMQConnection activeMQConnection)
protected ActiveMQConnection getConnection()
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.