org.transitime.ipc.jms

Class RestartableMessageProducer

java.lang.Object

org.transitime.ipc.jms.RestartableMessageProducer

public class RestartableMessageProducer
extends java.lang.Object

Sometimes when sending a message it will turn out that the session and/or the producer will have been closed. This class allows the session and producer to automatically be restarted if necessary. This means that writing messages will not fail when running on a laptop that is woken up after being asleep.

Author:

SkiBu Smith

Constructor Summary

Constructors

Constructor and Description
RestartableMessageProducer(JMSWrapper jmsWrapper, javax.jms.Destination destination) Constructor

Method Summary

Modifier and Type	Method and Description
void	sendObjectMessage(java.io.Serializable object) For sending a message to a Topic or a Queue.
void	sendTextMessage(java.lang.String message) For sending a message to a Topic or a Queue.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RestartableMessageProducer

public RestartableMessageProducer(JMSWrapper jmsWrapper,
                                  javax.jms.Destination destination)
                           throws javax.jms.JMSException

Constructor

Parameters:

jmsWrapper -

destination -

Throws:

javax.jms.JMSException

Method Detail

sendObjectMessage

public void sendObjectMessage(java.io.Serializable object)
                       throws javax.jms.JMSException

For sending a message to a Topic or a Queue. The message can be any serializable object.

Parameters:

object -

Throws:

javax.jms.JMSException

sendTextMessage

public void sendTextMessage(java.lang.String message)
                     throws javax.jms.JMSException

For sending a message to a Topic or a Queue. The message can be any serializable object.

Parameters:

object -

Throws:

javax.jms.JMSException