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