Package com.levigo.jadice.server.jms.shared

Class JMSTransportSender

java.lang.Object

com.levigo.jadice.server.jms.shared.JMSTransportSender

All Implemented Interfaces:

com.levigo.jadice.server.shared.transport.internal.TransportSender

public class JMSTransportSender
extends Object
implements com.levigo.jadice.server.shared.transport.internal.TransportSender

A JMS based TransportSender implementation.

Constructor Summary

Constructors

Constructor	Description
JMSTransportSender(CommunicationSide side, com.levigo.jadice.server.internal.JobInternal job, String uuid, javax.jms.QueueSession session, javax.jms.QueueSender messageProducer, com.levigo.jadice.server.jms.shared.internal.KeepaliveSender keepaliveSender)

Method Summary

Modifier and Type	Method	Description
com.levigo.jadice.server.shared.transport.internal.TransportSender	createNestedSender(com.levigo.jadice.server.shared.transport.internal.NestedTransportReceiver receiver)	Create a nested transport sender.
void	failed(org.jadice.util.log.qualified.QualifiedLogEvent qle)
void	finishTransport()	Method must be called at the end of the transport to signalize receiver that no more objects will be send.
void	sendInteger(int i)
void	sendObject(Serializable o)
void	sendString(String s)

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSTransportSender

public JMSTransportSender(CommunicationSide side,
                          com.levigo.jadice.server.internal.JobInternal job,
                          String uuid,
                          javax.jms.QueueSession session,
                          javax.jms.QueueSender messageProducer,
                          com.levigo.jadice.server.jms.shared.internal.KeepaliveSender keepaliveSender)

Method Detail

sendInteger

public void sendInteger(int i)
                 throws TransportException

Specified by:

sendInteger in interface com.levigo.jadice.server.shared.transport.internal.TransportSender

Throws:

TransportException

sendObject

public void sendObject(Serializable o)
                throws TransportException

Specified by:

sendObject in interface com.levigo.jadice.server.shared.transport.internal.TransportSender

Throws:

TransportException

sendString

public void sendString(String s)
                throws TransportException

Specified by:

sendString in interface com.levigo.jadice.server.shared.transport.internal.TransportSender

Throws:

TransportException

createNestedSender

public com.levigo.jadice.server.shared.transport.internal.TransportSender createNestedSender(com.levigo.jadice.server.shared.transport.internal.NestedTransportReceiver receiver)
                                                                                      throws TransportException

Create a nested transport sender. The supplied NestedTransportReceiver is initialized as needed and sent to the other side where it will receive messages sent via the newly created sender.

Specified by:

createNestedSender in interface com.levigo.jadice.server.shared.transport.internal.TransportSender

Parameters:

receiver - an associated NestedTransportReceiver

Returns:

A nested transport sender

Throws:

TransportException - in case of a initialization error.

failed

public void failed(org.jadice.util.log.qualified.QualifiedLogEvent qle)

Specified by:

failed in interface com.levigo.jadice.server.shared.transport.internal.TransportSender

finishTransport

public void finishTransport()
                     throws TransportException

Description copied from interface: com.levigo.jadice.server.shared.transport.internal.TransportSender

Method must be called at the end of the transport to signalize receiver that no more objects will be send.

Specified by:

finishTransport in interface com.levigo.jadice.server.shared.transport.internal.TransportSender

Throws:

TransportException