Package com.attivio.sdk.transport

Interface ManagedTransport<S,R>

Type Parameters:

S - The object to use for sending messages.

R - The object to use for receiving messages.

All Superinterfaces:

ClientTransport<S>, Transport<S,R>

public interface ManagedTransport<S,R>
extends Transport<S,R>

Represents a Transport that is managed by the core system.

All threading, work management, etc is managed for the implementer of this class automatically.

Field Summary

Fields inherited from interface com.attivio.sdk.transport.Transport

SEND_SIZE

Method Summary

Modifier and Type	Method	Description
SyncronousMessageHandle	receiveMessage(R receiver)	Receive a message waiting indefinitely until a message is received.
SyncronousMessageHandle	receiveMessage(R receiver, long timeout)	Receive a message waiting up to the timeout period.

Methods inherited from interface com.attivio.sdk.transport.ClientTransport

createSender, dispatchMessage, getProtocol, getSender, sendMessage, shutdown, stopSender

Methods inherited from interface com.attivio.sdk.transport.Transport

createReceiver, initialize, prepareReceiver, setDefaultQueueSize, stopReceiver

Method Detail

receiveMessage

SyncronousMessageHandle receiveMessage(R receiver)
                                throws TransportException

Receive a message waiting indefinitely until a message is received.

Throws:

TransportException

receiveMessage

SyncronousMessageHandle receiveMessage(R receiver,
                                       long timeout)
                                throws TransportException

Receive a message waiting up to the timeout period.

Parameters:

timeout - timeout period in milliseconds

Throws:

TransportException