public final class MessageTransformer extends Object
Message
entity.
Prerequisite: exchange with several header values - see input params of createMessage(org.apache.camel.Exchange, org.openhubframework.openhub.api.asynch.model.TraceHeader, java.lang.String, org.openhubframework.openhub.api.entity.ServiceExtEnum, java.lang.String, java.lang.String, org.openhubframework.openhub.api.entity.EntityTypeExtEnum, java.lang.String, java.lang.Boolean, java.lang.Boolean)
(call AsynchInMessageRoute
before)
Output: Message
entity in the state MsgStateEnum.PROCESSING
because we want to process
the message immediately
Modifier and Type | Method and Description |
---|---|
Message |
createMessage(org.apache.camel.Exchange exchange,
TraceHeader traceHeader,
String payload,
ServiceExtEnum service,
String operationName,
String objectId,
EntityTypeExtEnum entityType,
String funnelValue,
Boolean guaranteedOrder,
Boolean excludeFailedState)
Creates message entity.
|
static MessageTransformer |
getInstance() |
static String |
getSOAPEnvelope(org.apache.camel.Exchange exchange)
Gets original SOAP envelope.
|
public static MessageTransformer getInstance()
@Handler public Message createMessage(org.apache.camel.Exchange exchange, @Header(value="ASYNCH_TRACE_HEADER") TraceHeader traceHeader, @Body String payload, @Header(value="asynchService") ServiceExtEnum service, @Header(value="asynchOperation") String operationName, @Header(value="asynchObjectId") @Nullable String objectId, @Header(value="entityType") @Nullable EntityTypeExtEnum entityType, @Header(value="asynchFunnelValue") @Nullable String funnelValue, @Header(value="guaranteedOrderValue") @Nullable Boolean guaranteedOrder, @Header(value="guaranteedOrderWithoutFailedValue") @Nullable Boolean excludeFailedState)
exchange
- the exchangetraceHeader
- the trace headerpayload
- the message payloadservice
- the source serviceoperationName
- the source operation nameobjectId
- the object IDentityType
- the entity typefunnelValue
- the funnel valueguaranteedOrder
- the flag if order is guaranteed or notexcludeFailedState
- the exclude failed state flagCopyright © 2018 Pivotal Software, Inc.. All rights reserved.