|
||||||||||
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. Methods are implemented to get a connection, as well as queues and topics. The error handling will try to reconnect on given error scenarios. The warnings and errorcodes reported by Sun Message Queue 4.1 can be found in Appendix A Sun Java System Message Queue 4.1 Developer's Guide for Java Clients: http://docs.sun.com/app/docs/doc/819-7757/aeqgo?a=view
Field Summary | |
---|---|
static java.lang.String |
JMS_BROKER_HOST
settings.common.jms.broker: The JMS broker host contacted by the JMS connection. |
static java.lang.String |
JMS_BROKER_PORT
settings.common.jms.port: The port the JMS connection should use. |
(package private) static java.lang.String |
PACKET_ACK_FAILED
The errorcode for failure of the JMSbroker to acknowledge a message. |
(package private) static java.lang.String |
READ_PACKET_FAILED
The errorcode for failure to fread from a JMS connection. |
(package private) static java.lang.String |
RECEIVED_GOODBYE_FROM_BROKER
The errorcode signifying that the JMSbroker has been shutdown. |
(package private) static java.lang.String |
SESSION_IS_CLOSED
The errorcode signifying that the current session to the JMSbroker has been closed by the jmsbroker. |
(package private) static java.lang.String |
WRITE_PACKET_FAILED
The errorcode for failure to write to a JMS connection. |
Fields inherited from class dk.netarkivet.common.distribute.JMSConnection |
---|
closeHook, connection, CONSUMER_KEY_SEPARATOR, consumers, instance, JMS_MAXTRIES, myQSess, myTSess, producers, reconnectInProgress |
Method Summary | |
---|---|
void |
cleanup()
Reset the singleton and close the connection by calling super(). |
protected javax.jms.ConnectionFactory |
getConnectionFactory()
Returns a new QueueConnectionFactory. |
protected javax.jms.Destination |
getDestination(java.lang.String channelName)
Returns an Queue or a Topic. |
static JMSConnection |
getInstance()
Intialises an Open Message Queue JMS connection. |
void |
onException(javax.jms.JMSException e)
Exceptionhandler for the JMSConnection. |
Methods inherited from class dk.netarkivet.common.distribute.JMSConnection |
---|
getConsumerKey, initConnection, reconnect, 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 |
---|
static final java.lang.String PACKET_ACK_FAILED
static final java.lang.String WRITE_PACKET_FAILED
static final java.lang.String READ_PACKET_FAILED
static final java.lang.String SESSION_IS_CLOSED
static final java.lang.String RECEIVED_GOODBYE_FROM_BROKER
public static java.lang.String JMS_BROKER_HOST
public static java.lang.String JMS_BROKER_PORT
Method Detail |
---|
public static JMSConnection getInstance() throws IOFailure
IOFailure
- when connection to JMS broker failedprotected javax.jms.ConnectionFactory getConnectionFactory() throws javax.jms.JMSException
getConnectionFactory
in class JMSConnection
javax.jms.JMSException
- If unable to create a QueueConnectionfactory with
the necessary properties: imqConsumerflowLimit set
to 1, imqBrokerHostname and imqBrokerHostPort set to
the values defined in our settings.protected javax.jms.Destination getDestination(java.lang.String channelName) throws javax.jms.JMSException
getDestination
in class JMSConnection
channelName
- the name of the queue or topic.
javax.jms.JMSException
- If unable to create the destination.public void cleanup()
cleanup
in interface CleanupIF
cleanup
in class JMSConnection
public void onException(javax.jms.JMSException e)
onException
in interface javax.jms.ExceptionListener
onException
in class JMSConnection
e
- an JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |