|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectdk.netarkivet.common.distribute.JMSConnection
dk.netarkivet.common.distribute.JMSConnectionSunMQ
public class JMSConnectionSunMQ
Handles the communication with a Sun JMS broker. Note on Thread-safety: the methods and fields of JMSConnection are not accessed by multiple threads (though JMSConnection itself creates threads). Thus no synchronization is needed on methods and fields of JMSConnection. A shutdown hook is also added, which closes the connection.
Field Summary | |
---|---|
protected static JMSConnectionSunMQ |
instance
Singleton pattern is be used for this class. |
Fields inherited from class dk.netarkivet.common.distribute.JMSConnection |
---|
CONSUMER_KEY_SEPARATOR, log |
Method Summary | |
---|---|
void |
cleanup()
Close the connection and reset the singleton |
static JMSConnectionSunMQ |
getInstance()
Intialises a Open Message Queue JMS connection. |
protected javax.jms.Queue |
getQueue(java.lang.String queueName)
Returns an Queue. |
protected com.sun.messaging.QueueConnectionFactory |
getQueueConnectionFactory()
Returns a new QueueConnectionFactory. |
protected javax.jms.Topic |
getTopic(java.lang.String topicName)
Returns an Topic. |
protected com.sun.messaging.TopicConnectionFactory |
getTopicConnectionFactory()
Returns a new TopicConnectionFactory. |
Methods inherited from class dk.netarkivet.common.distribute.JMSConnection |
---|
close, getHost, getPort, initConnection, removeAllMessages, removeListener, reply, resend, send, sendMessage, setListener, unpack |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static JMSConnectionSunMQ instance
Method Detail |
---|
public static JMSConnectionSunMQ getInstance() throws UnknownID, IOFailure
IOFailure
- when connection to JMS broker failed
UnknownID
protected com.sun.messaging.QueueConnectionFactory getQueueConnectionFactory() throws javax.jms.JMSException
getQueueConnectionFactory
in class JMSConnection
javax.jms.JMSException
protected com.sun.messaging.TopicConnectionFactory getTopicConnectionFactory() throws javax.jms.JMSException
getTopicConnectionFactory
in class JMSConnection
javax.jms.JMSException
protected javax.jms.Queue getQueue(java.lang.String queueName) throws javax.jms.JMSException
getQueue
in class JMSConnection
queueName
- the name of the queue.
javax.jms.JMSException
protected javax.jms.Topic getTopic(java.lang.String topicName) throws javax.jms.JMSException
getTopic
in class JMSConnection
topicName
- the name of the topic.
javax.jms.JMSException
public void cleanup()
cleanup
in interface CleanupIF
cleanup
in class JMSConnection
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |