|
||||||||||
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.ProviderManager
Field Summary | |
private java.util.HashMap |
brokerConnections
|
private static org.apache.log4j.Category |
log
|
private MapMessageUtil |
mapUtil
|
ProviderAdmin |
providerAdmin
Description of the Field |
private QLManager |
qlManager
|
private FipaXMLUtil |
xmlUtil
|
Constructor Summary | |
ProviderManager()
Creates a new ProviderManager object. |
Method Summary | |
void |
activate(jade.mtp.InChannel.Dispatcher disp,
JMSAddress jmsTA)
Activate a specific TransportAddress |
private void |
closeBrokerConnections()
Close all connections in the hashmap |
void |
deactivate()
Deactivate the MTP |
void |
deactivate(JMSAddress jmsTA)
Deactivate a specific address |
void |
deliver(JMSAddress jmsTA,
jade.domain.FIPAAgentManagement.Envelope env,
byte[] payload)
Deliver a message to a jmsTA |
javax.jms.QueueConnection |
getBrokerConnection(JMSAddress jmsTA)
Used to create a new broker connection or to retrive one from the hashmap |
ProviderAdmin |
getProviderAdmin(java.lang.String providerType)
Get the Admin interface for a specific JMS provider |
private void |
setupBrokerConnection(JMSAddress jmsTA)
Create a QueueConnection to a specified broker and place it in the hashmap |
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 QLManager qlManager
private FipaXMLUtil xmlUtil
private MapMessageUtil mapUtil
public ProviderAdmin providerAdmin
private java.util.HashMap brokerConnections
Constructor Detail |
public ProviderManager()
Method Detail |
public void activate(jade.mtp.InChannel.Dispatcher disp, JMSAddress jmsTA) throws jade.mtp.MTPException
activate
in interface JmsProviderManager
disp
- Used to pass messages to the platformjmsTA
- Address to activate
jade.mtp.MTPException
- Error during address activationpublic void deactivate(JMSAddress jmsTA) throws jade.mtp.MTPException
deactivate
in interface JmsProviderManager
jmsTA
- Address to deactivate
jade.mtp.MTPException
- Error during address deactivationpublic void deactivate() throws jade.mtp.MTPException
deactivate
in interface JmsProviderManager
jade.mtp.MTPException
- Error with MTP deactivationpublic void deliver(JMSAddress jmsTA, jade.domain.FIPAAgentManagement.Envelope env, byte[] payload) throws jade.mtp.MTPException
deliver
in interface JmsProviderManager
jmsTA
- Address to deliver tooenv
- Envelope of messagepayload
- Message payload
jade.mtp.MTPException
- Error during message sendpublic javax.jms.QueueConnection getBrokerConnection(JMSAddress jmsTA) throws jade.mtp.MTPException
getBrokerConnection
in interface JmsProviderManager
jmsTA
- Address of the Broker
jade.mtp.MTPException
- Description of the Exception
java.lang.Exception
- Error During Connection Activationprivate void setupBrokerConnection(JMSAddress jmsTA) throws jade.mtp.MTPException
jmsTA
- Contains details of the broker
jade.mtp.MTPException
- Description of the Exception
java.lang.Exception
- Error during connection setupprivate void closeBrokerConnections()
public ProviderAdmin getProviderAdmin(java.lang.String providerType) throws jade.mtp.MTPException
getProviderAdmin
in interface JmsProviderManager
providerType
- Providers interface to return
jade.mtp.MTPException
- Description of the Exception
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 |