Package 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 Details

    • TRANSPORT_STATUS_OK

      static final int TRANSPORT_STATUS_OK
      transport specific status code that indicates success
      See Also:

    • TRANSPORT_STATUS_ERROR

      static final int TRANSPORT_STATUS_ERROR
      transport specific status code that indicates generic error
      See Also:

    • TRANSPORT_STATUS_APPLICATION_ERROR

      static final int TRANSPORT_STATUS_APPLICATION_ERROR
      transport specific status code that indicates application error
      See Also:

    • TRANSPORT_STATUS_CONNECTION_ERROR

      static final int TRANSPORT_STATUS_CONNECTION_ERROR
      transport specific status code that indicates connection error
      See Also:

    • TRANSPORT_STATUS_INVALID_PAYLOAD_SIZE

      static final int TRANSPORT_STATUS_INVALID_PAYLOAD_SIZE
      transport specific status code that indicates invalid length exception
      See Also:

    • TRANSPORT_RESOURCE_NAME

      static final String TRANSPORT_RESOURCE_NAME
      internal name used by monitoring subsystem
      See Also:

    • 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 Details

    • 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()