|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--ie.nuigalway.ecrg.jade.jmsmtp.providersupport.QueueListener
Field Summary | |
private javax.jms.QueueConnection |
conn
|
private jade.mtp.InChannel.Dispatcher |
dispatcher
|
private JMSAddress |
jmsTA
|
private static org.apache.log4j.Category |
log
|
private MapMessageUtil |
mapUtil
|
private ProviderAdmin |
pAdmin
|
private javax.jms.Queue |
que
|
private javax.jms.QueueSession |
session
|
private FipaXMLUtil |
xmlUtil
|
Constructor Summary | |
QueueListener(javax.jms.QueueConnection conn,
jade.mtp.InChannel.Dispatcher dispatcher,
JMSAddress jmsTA)
Creates a new QueueListener object. |
Method Summary | |
ProviderAdmin |
getProviderAdmin(java.lang.String providerType)
Get the Admin interface for a specific JMS provider |
void |
onException(javax.jms.JMSException jmse)
Method is executed when an execption is thrown by the JMS Provider Attempts to reconnect to the provider |
void |
onMessage(javax.jms.Message msg)
Method is executed when a message is receivd from the agents queue |
private void |
setupConnection()
Method is executed in order to create a connection to a JMS server and listen to |
void |
stop()
Method is executed to disconnect from a JMS server |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static org.apache.log4j.Category log
private jade.mtp.InChannel.Dispatcher dispatcher
private JMSAddress jmsTA
private FipaXMLUtil xmlUtil
private MapMessageUtil mapUtil
private javax.jms.QueueConnection conn
private javax.jms.QueueSession session
private javax.jms.Queue que
private ProviderAdmin pAdmin
Constructor Detail |
public QueueListener(javax.jms.QueueConnection conn, jade.mtp.InChannel.Dispatcher dispatcher, JMSAddress jmsTA) throws java.lang.Exception
conn
- Connection to usedispatcher
- Dispatcher to send the messages tojmsTA
- Address to listen to
java.lang.Exception
- Description of the ExceptionMethod Detail |
private void setupConnection() throws javax.jms.JMSException, jade.mtp.MTPException
javax.jms.JMSException
jade.mtp.MTPException
public void onMessage(javax.jms.Message msg)
onMessage
in interface javax.jms.MessageListener
msg
- JMS Message receivedpublic void onException(javax.jms.JMSException jmse)
onException
in interface javax.jms.ExceptionListener
jmse
- JMS Exception thrownpublic void stop() throws java.lang.Exception
java.lang.Exception
- Error in closeing JMS Connectionpublic ProviderAdmin getProviderAdmin(java.lang.String providerType) throws java.lang.Exception
providerType
- Providers interface to return
java.lang.Exception
- Error in creating the provider interface
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |