public class JMSContextImpl
extends java.lang.Object
Constructor and Description |
---|
JMSContextImpl(ConnectionFactory factory,
int sessionMode,
java.lang.String user,
java.lang.String pwd,
boolean xa) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge() |
void |
close() |
void |
commit() |
protected Connection |
connection() |
QueueBrowser |
createBrowser(Queue queue) |
QueueBrowser |
createBrowser(Queue queue,
java.lang.String messageSelector) |
BytesMessage |
createBytesMessage() |
JMSConsumer |
createConsumer(Destination destination) |
JMSConsumer |
createConsumer(Destination destination,
java.lang.String messageSelector) |
JMSConsumer |
createConsumer(Destination destination,
java.lang.String messageSelector,
boolean noLocal) |
JMSContext |
createContext(int sessionMode) |
JMSConsumer |
createDurableConsumer(Topic topic,
java.lang.String name) |
JMSConsumer |
createDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal) |
MapMessage |
createMapMessage() |
Message |
createMessage() |
ObjectMessage |
createObjectMessage() |
ObjectMessage |
createObjectMessage(java.io.Serializable object) |
JMSProducer |
createProducer() |
Queue |
createQueue(java.lang.String queueName) |
JMSConsumer |
createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName) |
JMSConsumer |
createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName,
java.lang.String messageSelector) |
JMSConsumer |
createSharedDurableConsumer(Topic topic,
java.lang.String name) |
JMSConsumer |
createSharedDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector) |
StreamMessage |
createStreamMessage() |
TemporaryQueue |
createTemporaryQueue() |
TemporaryTopic |
createTemporaryTopic() |
TextMessage |
createTextMessage() |
TextMessage |
createTextMessage(java.lang.String text) |
Topic |
createTopic(java.lang.String topicName) |
boolean |
getAutoStart() |
java.lang.String |
getClientID() |
ExceptionListener |
getExceptionListener() |
ConnectionMetaData |
getMetaData() |
int |
getSessionMode() |
boolean |
getTransacted() |
void |
recover() |
void |
rollback() |
protected Session |
session() |
void |
setAutoStart(boolean autoStart) |
void |
setClientID(java.lang.String clientID) |
void |
setExceptionListener(ExceptionListener listener) |
void |
start() |
void |
stop() |
void |
unsubscribe(java.lang.String name) |
public JMSContextImpl(ConnectionFactory factory, int sessionMode, java.lang.String user, java.lang.String pwd, boolean xa)
protected Connection connection()
protected Session session()
public void acknowledge()
public void close()
public void commit()
public QueueBrowser createBrowser(Queue queue)
public QueueBrowser createBrowser(Queue queue, java.lang.String messageSelector)
public BytesMessage createBytesMessage()
public JMSConsumer createConsumer(Destination destination)
public JMSConsumer createConsumer(Destination destination, java.lang.String messageSelector)
public JMSConsumer createConsumer(Destination destination, java.lang.String messageSelector, boolean noLocal)
public JMSContext createContext(int sessionMode)
public JMSConsumer createDurableConsumer(Topic topic, java.lang.String name)
public JMSConsumer createDurableConsumer(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
public MapMessage createMapMessage()
public Message createMessage()
public ObjectMessage createObjectMessage()
public ObjectMessage createObjectMessage(java.io.Serializable object)
public JMSProducer createProducer()
public Queue createQueue(java.lang.String queueName)
public JMSConsumer createSharedConsumer(Topic topic, java.lang.String sharedSubscriptionName)
public JMSConsumer createSharedConsumer(Topic topic, java.lang.String sharedSubscriptionName, java.lang.String messageSelector)
public JMSConsumer createSharedDurableConsumer(Topic topic, java.lang.String name)
public JMSConsumer createSharedDurableConsumer(Topic topic, java.lang.String name, java.lang.String messageSelector)
public StreamMessage createStreamMessage()
public TemporaryQueue createTemporaryQueue()
public TemporaryTopic createTemporaryTopic()
public TextMessage createTextMessage()
public TextMessage createTextMessage(java.lang.String text)
public Topic createTopic(java.lang.String topicName)
public boolean getAutoStart()
public java.lang.String getClientID()
public ExceptionListener getExceptionListener()
public ConnectionMetaData getMetaData()
public int getSessionMode()
public boolean getTransacted()
public void recover()
public void rollback()
public void setAutoStart(boolean autoStart)
public void setClientID(java.lang.String clientID)
public void setExceptionListener(ExceptionListener listener)
public void start()
public void stop()
public void unsubscribe(java.lang.String name)