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
static String TRANSPORT_ERROR_GENERIC
          String representation of generic error code
static String TRANSPORT_RESOURCE_NAME
          internal name used by monitoring subsystem
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
 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_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

See Also:
Constant Field Values
Method Detail

registerProvider

void registerProvider(TransportProvider p,
                      Transformer t)
                      throws TransportException
Registers a new provider with the transport manager. Typically called by the transport provider’s ApplicationLifeCycleListener postStart() method. Optional transformer argument allows the transport provider or ALSB 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 ALSB subsystem
t - transformer for those provider that support custom sources and tranbsformations. Maybe null.
Throws:
TransportException

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

getTransformer

Transformer getTransformer()
Returns:
the “uber”-Transformer, i.e. the union of all available transformers, including custom ones