|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.jboss.soa.esb.listeners.message.UncomposedMessageDeliveryAdapter
public class UncomposedMessageDeliveryAdapter
Adapter class for delivering uncomposed (ESB unaware) message payloads to a target service.
Basically wires aServiceInvoker instance with a MessageComposer
instance.
ServiceInvoker| Constructor Summary | |
|---|---|
UncomposedMessageDeliveryAdapter(java.lang.String serviceCategory,
java.lang.String serviceName,
MessageComposer composer)
Public constructor. |
|
| Method Summary | |
|---|---|
void |
deliverAsync(java.lang.Object messagePayload)
Asynchronously deliverAsync the supplied message to the target service associated with this adapter instance. |
java.lang.Object |
deliverSync(java.lang.Object messagePayload,
long timeoutMillis)
Synchronously deliver the supplied message to the target service associated with this adapter instance, decomposing the reply message payload. |
Message |
deliverSyncWithoutDecomposing(java.lang.Object messagePayload,
long timeoutMillis)
Synchronously deliver the supplied message to the target service associated with this adapter instance, without decompsing the synchronous reply message. |
ServiceInvoker |
getDeliveryAdapter()
Get the "composed" message delivery adapter instance through which this adpter is delivering message, after composing them. |
static UncomposedMessageDeliveryAdapter |
getGatewayDeliveryAdapter(ConfigTree gatewayConfig,
MessageComposer defaultComposer)
Utility factory method for creation of an uncomposed message delivery adapter from a gateway configuration. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public UncomposedMessageDeliveryAdapter(java.lang.String serviceCategory,
java.lang.String serviceName,
MessageComposer composer)
throws MessageDeliverException
serviceCategory - The category name of the Service to which this instance will
deliver messages.serviceName - The name of the Service to which this instance will
deliver messages.composer - The the message composer class for this delivery instance.
RegistryException - Failed to lookup EPRs for the specified Service.
MessageDeliverException| Method Detail |
|---|
public java.lang.Object deliverSync(java.lang.Object messagePayload,
long timeoutMillis)
throws MessageDeliverException,
RegistryException,
FaultMessageException
decomposing the reply message payload.
To deliver synchronusly without decomposing the reply, see
deliverSyncWithoutDecomposing(Object,long).
messagePayload - Message payload to be packaged, or a channel specific
container class for the message payload (e.g. a JMS message).timeoutMillis - Number of milliseconds before synchronous reply pickup should timeout.
decomposed).
MessageDeliverException - Failed to deliverAsync message, after trying all available EPRs.
RegistryException
FaultMessageException
public Message deliverSyncWithoutDecomposing(java.lang.Object messagePayload,
long timeoutMillis)
throws MessageDeliverException,
RegistryException,
FaultMessageException
messagePayload - Message payload to be packaged, or a channel specific
container class for the message payload (e.g. a JMS message).timeoutMillis - Number of milliseconds before synchronous reply pickup should timeout.
Message. The caller must decompose the message.
MessageDeliverException - Failed to deliverAsync message, after trying all available EPRs.
RegistryException
FaultMessageException
public void deliverAsync(java.lang.Object messagePayload)
throws MessageDeliverException,
RegistryException
messagePayload - Message payload to be packaged, or a channel specific
container class for the message payload (e.g. a JMS message).
MessageDeliverException - Failed to deliverAsync message, after trying all available EPRs.
RegistryExceptionpublic ServiceInvoker getDeliveryAdapter()
public static UncomposedMessageDeliveryAdapter getGatewayDeliveryAdapter(ConfigTree gatewayConfig,
MessageComposer defaultComposer)
throws ConfigurationException
gatewayConfig - The gateway configuration.defaultComposer - The default message composer, used when the configuration doesn't specify a composer.
ConfigurationException - Invalid gateway configuration.
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||