gov.nih.nci.caarray.services.util.jms
Class DefaultJMSMessageHandler
java.lang.Object
gov.nih.nci.caarray.services.util.jms.DefaultJMSMessageHandler
- All Implemented Interfaces:
- JMSMessageHandler
public class DefaultJMSMessageHandler
- extends java.lang.Object
- implements JMSMessageHandler
- Author:
- Joshua Phillips
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEFAULT_QUEUE_CONN_FACT
public static final java.lang.String DEFAULT_QUEUE_CONN_FACT
- See Also:
- Constant Field Values
DEFAULT_TOPIC_CONN_FACT
public static final java.lang.String DEFAULT_TOPIC_CONN_FACT
- See Also:
- Constant Field Values
DEFAULT_BATCH_SIZE
public static int DEFAULT_BATCH_SIZE
DEFAULT_FLUSH_INTERVAL
public static long DEFAULT_FLUSH_INTERVAL
getInstance
public static DefaultJMSMessageHandler getInstance()
startQueueSession
public void startQueueSession(java.lang.String queueName)
throws javax.jms.JMSException,
ServiceLookupException
- Specified by:
startQueueSession
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
ServiceLookupException
startQueueSession
public void startQueueSession(java.lang.String queueName,
java.lang.String connFactName)
throws javax.jms.JMSException,
ServiceLookupException
- Specified by:
startQueueSession
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
ServiceLookupException
startTopicSession
public void startTopicSession(java.lang.String queueName)
throws javax.jms.JMSException
- Specified by:
startTopicSession
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
startTopicSession
public void startTopicSession(java.lang.String topicName,
java.lang.String topicFactName)
throws javax.jms.JMSException
- Specified by:
startTopicSession
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
send
public void send(java.lang.String queueName,
javax.jms.Message msg,
long waitTime)
throws javax.jms.JMSException
- Specified by:
send
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
flushQueue
public void flushQueue(java.lang.String queueName)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
flushAllQueues
public void flushAllQueues()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getBatchSize
public int getBatchSize()
- Returns:
setBatchSize
public void setBatchSize(int b)
publish
public void publish(java.lang.String topicName,
javax.jms.Message msg)
throws javax.jms.JMSException
- Specified by:
publish
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
finalize
public void finalize()
- Overrides:
finalize
in class java.lang.Object
flushAllTopics
public void flushAllTopics()
endQueueSession
public void endQueueSession(java.lang.String queueName)
throws javax.jms.JMSException
- Specified by:
endQueueSession
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
getQueueSessionNames
public java.util.Collection getQueueSessionNames()
- Specified by:
getQueueSessionNames
in interface JMSMessageHandler
getTopicSessionNames
public java.util.Collection getTopicSessionNames()
- Specified by:
getTopicSessionNames
in interface JMSMessageHandler
endTopicSession
public void endTopicSession(java.lang.String queueName)
throws javax.jms.JMSException
- Specified by:
endTopicSession
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
createQueueObjectMessage
public javax.jms.ObjectMessage createQueueObjectMessage(java.lang.String queueName)
throws javax.jms.JMSException
- Specified by:
createQueueObjectMessage
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
createTopicObjectMessage
public javax.jms.ObjectMessage createTopicObjectMessage(java.lang.String topicName)
throws javax.jms.JMSException
- Specified by:
createTopicObjectMessage
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException
send
public void send(java.lang.String queueName,
javax.jms.Message msg)
throws javax.jms.JMSException
- Specified by:
send
in interface JMSMessageHandler
- Throws:
javax.jms.JMSException