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 and Description
JMSTransportSender(com.levigo.jadice.server.internal.JobInternal job, String uuid, javax.jms.QueueSession session, javax.jms.QueueSender messageProducer)

Method Summary

Methods

Modifier and Type	Method and 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(com.levigo.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(com.levigo.jadice.server.internal.JobInternal job,
                  String uuid,
                  javax.jms.QueueSession session,
                  javax.jms.QueueSender messageProducer)

Method Detail

sendInteger

public void sendInteger(int i)
                 throws com.levigo.jadice.server.shared.transport.internal.TransportException

Specified by:

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

Throws:

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

sendObject

public void sendObject(Serializable o)
                throws com.levigo.jadice.server.shared.transport.internal.TransportException

Specified by:

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

Throws:

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

sendString

public void sendString(String s)
                throws com.levigo.jadice.server.shared.transport.internal.TransportException

Specified by:

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

Throws:

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

createNestedSender

public com.levigo.jadice.server.shared.transport.internal.TransportSender createNestedSender(com.levigo.jadice.server.shared.transport.internal.NestedTransportReceiver receiver)
                                                                                      throws com.levigo.jadice.server.shared.transport.internal.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 -

Returns:

A nested transport sender

Throws:

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

failed

public void failed(com.levigo.util.log.qualified.QualifiedLogEvent qle)

Specified by:

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

finishTransport

public void finishTransport()
                     throws com.levigo.jadice.server.shared.transport.internal.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:

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