ie.nuigalway.ecrg.jade.jmsmtp.providersupport
Class QLManager
java.lang.Object
|
+--ie.nuigalway.ecrg.jade.jmsmtp.providersupport.QLManager
- public class QLManager
- extends java.lang.Object
Field Summary |
private java.util.HashMap |
listenerMap
|
private static org.apache.log4j.Category |
log
|
Constructor Summary |
QLManager()
Creates a new QLManager object. |
Method Summary |
void |
addQL(javax.jms.QueueConnection conn,
jade.mtp.InChannel.Dispatcher disp,
JMSAddress jmsTA)
Add a queue listener for a specific queue |
void |
removeAllQL()
Remove all queue listeners |
void |
removeQL(java.lang.String key)
Remove a specific queue listener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
private static org.apache.log4j.Category log
listenerMap
private java.util.HashMap listenerMap
QLManager
public QLManager()
- Creates a new QLManager object.
addQL
public void addQL(javax.jms.QueueConnection conn,
jade.mtp.InChannel.Dispatcher disp,
JMSAddress jmsTA)
throws java.lang.Exception
- Add a queue listener for a specific queue
- Parameters:
conn
- Connection to usedisp
- Dispatcher to send the messages tojmsTA
- Address to listen to
- Throws:
java.lang.Exception
- Error during listener activation
removeQL
public void removeQL(java.lang.String key)
throws java.lang.Exception
- Remove a specific queue listener
- Parameters:
key
- Key of the queue listener to remove
- Throws:
java.lang.Exception
- Error during queue removal
removeAllQL
public void removeAllQL()
throws java.lang.Exception
- Remove all queue listeners
- Throws:
java.lang.Exception
- Error during listener removal