public class InboundConnectionProxy extends Object implements javax.jms.Connection, javax.jms.QueueConnection, javax.jms.TopicConnection
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.Constructor and Description |
---|
InboundConnectionProxy() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Destination destination,
String s,
javax.jms.ServerSessionPool serverSessionPool,
int i) |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
String s,
javax.jms.ServerSessionPool serverSessionPool,
int i) |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
String s,
javax.jms.ServerSessionPool serverSessionPool,
int i) |
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
String s,
String s1,
javax.jms.ServerSessionPool serverSessionPool,
int i) |
protected javax.jms.JMSException |
createNotSupported(String text) |
javax.jms.QueueSession |
createQueueSession(boolean transacted,
int ackMode) |
javax.jms.Session |
createSession(boolean transacted,
int ackMode) |
javax.jms.TopicSession |
createTopicSession(boolean transacted,
int ackMode) |
String |
getClientID() |
javax.jms.ExceptionListener |
getExceptionListener() |
javax.jms.ConnectionMetaData |
getMetaData() |
void |
setClientID(String s) |
void |
setExceptionListener(javax.jms.ExceptionListener exceptionListener) |
void |
start() |
void |
stop() |
public InboundConnectionProxy()
public javax.jms.Session createSession(boolean transacted, int ackMode) throws javax.jms.JMSException
createSession
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.QueueSession createQueueSession(boolean transacted, int ackMode) throws javax.jms.JMSException
createQueueSession
in interface javax.jms.QueueConnection
javax.jms.JMSException
public javax.jms.TopicSession createTopicSession(boolean transacted, int ackMode) throws javax.jms.JMSException
createTopicSession
in interface javax.jms.TopicConnection
javax.jms.JMSException
public void start() throws javax.jms.JMSException
start
in interface javax.jms.Connection
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface javax.jms.Connection
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ConnectionMetaData getMetaData() throws javax.jms.JMSException
getMetaData
in interface javax.jms.Connection
javax.jms.JMSException
public String getClientID() throws javax.jms.JMSException
getClientID
in interface javax.jms.Connection
javax.jms.JMSException
public void setClientID(String s) throws javax.jms.JMSException
setClientID
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ExceptionListener getExceptionListener() throws javax.jms.JMSException
getExceptionListener
in interface javax.jms.Connection
javax.jms.JMSException
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener) throws javax.jms.JMSException
setExceptionListener
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination, String s, javax.jms.ServerSessionPool serverSessionPool, int i) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, String s, String s1, javax.jms.ServerSessionPool serverSessionPool, int i) throws javax.jms.JMSException
createDurableConnectionConsumer
in interface javax.jms.Connection
createDurableConnectionConsumer
in interface javax.jms.TopicConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, String s, javax.jms.ServerSessionPool serverSessionPool, int i) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.QueueConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic, String s, javax.jms.ServerSessionPool serverSessionPool, int i) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.TopicConnection
javax.jms.JMSException
protected javax.jms.JMSException createNotSupported(String text)
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.