|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.commons.messenger.MessengerSession
MessengerSession
represents all the local information for a single thread.
Field Summary | |
private javax.jms.Session |
listenerSession
the JMS Listener (async subscription) Session for this thread |
private static org.apache.commons.logging.Log |
log
|
private MessengerSupport |
messenger
The current messenger to which I'm connected |
private javax.jms.MessageProducer |
producer
The producer used to send messages using this session |
private javax.jms.MessageConsumer |
replyToConsumer
the MessageConsumer for this threads reply to destination |
private javax.jms.Destination |
replyToDestination
The inbox which is used for the call() methods |
private java.util.Map |
requestorsMap
An optional cache of requestors |
private javax.jms.Session |
session
the JMS Session for this thread |
private SessionFactory |
sessionFactory
The factory used to create each thread's JMS Session |
Constructor Summary | |
MessengerSession(MessengerSupport messenger,
SessionFactory sessionFactory)
|
Method Summary | |
void |
close()
Closes any sessions or producers open |
protected javax.jms.Session |
createSession()
Factory method to create a new JMS Session |
protected javax.jms.Destination |
createTemporaryDestination()
Factory method to create a new temporary destination |
javax.jms.Session |
getListenerSession()
|
javax.jms.MessageProducer |
getMessageProducer(javax.jms.Destination destination)
|
javax.jms.QueueRequestor |
getQueueRequestor(javax.jms.QueueSession session,
javax.jms.Queue destination)
|
javax.jms.MessageConsumer |
getReplyToConsumer()
|
protected javax.jms.Destination |
getReplyToDestination()
|
protected java.util.Map |
getRequestorsMap()
|
javax.jms.Session |
getSession()
|
SessionFactory |
getSessionFactory()
|
javax.jms.TopicRequestor |
getTopicRequestor(javax.jms.TopicSession session,
javax.jms.Topic destination)
|
boolean |
isTopic()
|
void |
setReplyToConsumer(javax.jms.MessageConsumer replyToConsumer)
|
protected void |
setReplyToDestination(javax.jms.Destination replyToDestination)
Sets the reply to destination to use |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static final org.apache.commons.logging.Log log
private javax.jms.Session session
private javax.jms.Session listenerSession
private javax.jms.MessageConsumer replyToConsumer
private SessionFactory sessionFactory
private java.util.Map requestorsMap
private javax.jms.Destination replyToDestination
private MessengerSupport messenger
private javax.jms.MessageProducer producer
Constructor Detail |
public MessengerSession(MessengerSupport messenger, SessionFactory sessionFactory)
Method Detail |
public SessionFactory getSessionFactory()
public void close() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Session getSession() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Session getListenerSession() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MessageConsumer getReplyToConsumer() throws javax.jms.JMSException
javax.jms.JMSException
public void setReplyToConsumer(javax.jms.MessageConsumer replyToConsumer)
public javax.jms.MessageProducer getMessageProducer(javax.jms.Destination destination) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Destination getReplyToDestination() throws javax.jms.JMSException
javax.jms.JMSException
protected void setReplyToDestination(javax.jms.Destination replyToDestination) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TopicRequestor getTopicRequestor(javax.jms.TopicSession session, javax.jms.Topic destination) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.QueueRequestor getQueueRequestor(javax.jms.QueueSession session, javax.jms.Queue destination) throws javax.jms.JMSException
javax.jms.JMSException
public boolean isTopic() throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Session createSession() throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Destination createTemporaryDestination() throws javax.jms.JMSException
javax.jms.JMSException
protected java.util.Map getRequestorsMap()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |