|
||||||||||
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 |
---|
Fields inherited from class dk.netarkivet.common.distribute.JMSConnection |
---|
CONSUMER_KEY_SEPARATOR, instance, log |
Constructor Summary | |
---|---|
protected |
JMSConnectionSunMQ()
Override default public constructor. |
Method Summary | |
---|---|
protected javax.jms.Queue |
getQueue(java.lang.String queueName)
Returns an Queue. |
protected javax.jms.QueueConnectionFactory |
getQueueConnectionFactory()
Returns a new QueueConnectionFactory. |
protected javax.jms.Topic |
getTopic(java.lang.String topicName)
Returns an Topic. |
protected javax.jms.TopicConnectionFactory |
getTopicConnectionFactory()
Returns a new TopicConnectionFactory. |
Methods inherited from class dk.netarkivet.common.distribute.JMSConnection |
---|
cleanup, close, getHost, getInstance, 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 |
Constructor Detail |
---|
protected JMSConnectionSunMQ()
Method Detail |
---|
protected javax.jms.QueueConnectionFactory getQueueConnectionFactory() throws javax.jms.JMSException
getQueueConnectionFactory
in class JMSConnection
javax.jms.JMSException
protected javax.jms.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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |