com.bea.wli.sb.transports

Interface TransportManager

public interface TransportManager

A singleton object that provides the main point of centralization for managing different transport providers, endpoint registration, control, processing of inbound and outbound messages, etc

Field Summary

Fields

Modifier and Type	Field and Description
static String	TRANSPORT_ERROR_APPLICATION String representation of application error code.
static String	TRANSPORT_ERROR_CONNECTION String representation of connection error code.
static String	TRANSPORT_ERROR_GENERIC String representation of generic error code
static String	TRANSPORT_ERROR_THROTTLING_EXPIRED String representation of a transport error due to throttling.
static String	TRANSPORT_ERROR_THROTTLING_OVERLOAD String representation of a transport error due to throttling.
static String	TRANSPORT_ERROR_THROTTLING_QUEUE String representation of a transport error due to throttling.
static String	TRANSPORT_RESOURCE_NAME internal name used by monitoring subsystem
static int	TRANSPORT_STATUS_APPLICATION_ERROR transport specific status code that indicates application error
static int	TRANSPORT_STATUS_CONNECTION_ERROR transport specific status code that indicates connection error
static int	TRANSPORT_STATUS_ERROR transport specific status code that indicates generic error
static int	TRANSPORT_STATUS_OK transport specific status code that indicates success

Method Summary

Modifier and Type	Method and Description
Transformer	getTransformer()
void	receiveMessage(InboundTransportMessageContext ctx, TransportOptions options) Processes an inbound message: the caller is the transport endpoint implementation, and transport manager passes the message context down to the router manager, which sends the incoming message down the request pipeline.
void	registerProvider(TransportProvider p, Transformer t) Registers a new provider with the transport manager.

Field Detail

TRANSPORT_STATUS_OK

static final int TRANSPORT_STATUS_OK

transport specific status code that indicates success

See Also:

Constant Field Values

TRANSPORT_STATUS_ERROR

static final int TRANSPORT_STATUS_ERROR

transport specific status code that indicates generic error

See Also:

Constant Field Values

TRANSPORT_STATUS_APPLICATION_ERROR

static final int TRANSPORT_STATUS_APPLICATION_ERROR

transport specific status code that indicates application error

See Also:

Constant Field Values

TRANSPORT_STATUS_CONNECTION_ERROR

static final int TRANSPORT_STATUS_CONNECTION_ERROR

transport specific status code that indicates connection error

See Also:

Constant Field Values

TRANSPORT_RESOURCE_NAME

static final String TRANSPORT_RESOURCE_NAME

internal name used by monitoring subsystem

See Also:

Constant Field Values

TRANSPORT_ERROR_GENERIC

static final String TRANSPORT_ERROR_GENERIC

String representation of generic error code

TRANSPORT_ERROR_APPLICATION

static final String TRANSPORT_ERROR_APPLICATION

String representation of application error code. Transport Providers use this error code to indicate application errors to the TransportSDK.

TRANSPORT_ERROR_THROTTLING_OVERLOAD

static final String TRANSPORT_ERROR_THROTTLING_OVERLOAD

String representation of a transport error due to throttling. The target throttled business service could not process any more message and there is no throttling queue configured for receiving backlog messages.

TRANSPORT_ERROR_THROTTLING_EXPIRED

static final String TRANSPORT_ERROR_THROTTLING_EXPIRED

String representation of a transport error due to throttling. The message expired while waiting in the throttling queue to be processed by a throttled business service.

TRANSPORT_ERROR_THROTTLING_QUEUE

static final String TRANSPORT_ERROR_THROTTLING_QUEUE

String representation of a transport error due to throttling. The target throttled business service could not process the message. The message couldn't be inserted in the throttling queue because the queue is full and the message priority is lower than the messages already in this queue.

TRANSPORT_ERROR_CONNECTION

static final String TRANSPORT_ERROR_CONNECTION

String representation of connection error code. Transport Providers use this error code to indicate connection errors to the TransportSDK.

Method Detail

registerProvider

void registerProvider(TransportProvider p,
                      Transformer t)
               throws TransportException

Registers a new provider with the transport manager. This is typically called by the transport provider's ApplicationLifeCycleListener postStart() method. Optional transformer argument allows the transport provider or OSB runtime to perform custom transformations from custom Source-derived classes to one or more of standard results.

Parameters:

p - new tramsport provider to be registered with OSB subsystem

t - transformer for those provider that support custom sources and tranbsformations. Maybe null.

Throws:

TransportException - if an exception occurred.

receiveMessage

void receiveMessage(InboundTransportMessageContext ctx,
                    TransportOptions options)
             throws TransportException

Processes an inbound message: the caller is the transport endpoint implementation, and transport manager passes the message context down to the router manager, which sends the incoming message down the request pipeline. The TransportManager will eventually put a response (if any) into the InboundTransportMessageContext and signal its readiness to be sent by calling InboundTransportMessageContext.close().

Parameters:

ctx - message context created by transport provider

options - provider-supplied directives on processing the message, e.g. desired quality of service

Throws:

TransportException - if an exception occurred.

getTransformer

Transformer getTransformer()

Returns:

the "uber"-Transformer, i.e. the union of all available transformers, including custom ones. Note, that this transformer instance does not include any transformers that make use of message flow state for a specific request (e.g. XmlObjectSource -> JavaSource). In order to make use of such transformations one has to use TransportSender.getTransformer()