com.levigo.jadice.server.streamtransport.jms

Class JMSStreamTransportFactory

java.lang.Object

com.levigo.jadice.server.streamtransport.jms.JMSStreamTransportFactory

All Implemented Interfaces:

StreamTransportFactory

public class JMSStreamTransportFactory
extends Object
implements StreamTransportFactory

Constructor Summary

Constructors

Constructor and Description
JMSStreamTransportFactory()

Method Summary

Methods

Modifier and Type	Method and Description
String	getDigest()
int	getMaximumMessageSize()
Future<?>	initiateTransport(Stream stream, com.levigo.jadice.server.shared.transport.internal.TransportSender transport) Create a transport for the given InputStream.
void	setDigest(String digest) Set an (optional) digest for integrity of transported streams
void	setMaximumMessageSize(int maximumMessageSize) If the stream must be split in several messages, this value limits the maximum size of the individual messages.
void	shutdown() Shut down the stream transport factory.
void	startup() Initialize the stream transport factory.

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSStreamTransportFactory

public JMSStreamTransportFactory()

Method Detail

initiateTransport

public Future<?> initiateTransport(Stream stream,
                          com.levigo.jadice.server.shared.transport.internal.TransportSender transport)
                            throws StreamTransportException,
                                   com.levigo.jadice.server.shared.transport.internal.TransportAbortedException

Description copied from interface: StreamTransportFactory

Create a transport for the given InputStream.

Specified by:

initiateTransport in interface StreamTransportFactory

Parameters:

stream - the Stream to transport

transport - a TransportSender which can be used by the transport

Throws:

StreamTransportException

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

startup

public void startup()
             throws StreamTransportException

Description copied from interface: StreamTransportFactory

Initialize the stream transport factory.

Specified by:

startup in interface StreamTransportFactory

Throws:

StreamTransportException

shutdown

public void shutdown()
              throws StreamTransportException

Description copied from interface: StreamTransportFactory

Shut down the stream transport factory.

Specified by:

shutdown in interface StreamTransportFactory

Throws:

StreamTransportException

setDigest

public void setDigest(String digest)
               throws NoSuchAlgorithmException

Description copied from interface: StreamTransportFactory

Set an (optional) digest for integrity of transported streams

Specified by:

setDigest in interface StreamTransportFactory

Parameters:

digest - Name of the digest algorithm (or null to disable feature)

Throws:

NoSuchAlgorithmException - If no digest with the given name was found

getDigest

public String getDigest()

Specified by:

getDigest in interface StreamTransportFactory

Returns:

The name of the digest algorithm (or null if no checking is enabled)

setMaximumMessageSize

public void setMaximumMessageSize(int maximumMessageSize)

Description copied from interface: StreamTransportFactory

If the stream must be split in several messages, this value limits the maximum size of the individual messages.

Specified by:

setMaximumMessageSize in interface StreamTransportFactory

Parameters:

maximumMessageSize - max. size of a message (in bytes)

getMaximumMessageSize

public int getMaximumMessageSize()

Specified by:

getMaximumMessageSize in interface StreamTransportFactory