public class StreamableRecordMessageComposer extends BaseMessageComposer<StreamableRecordBindingData>
| Constructor and Description |
|---|
StreamableRecordMessageComposer() |
| Modifier and Type | Method and Description |
|---|---|
Message |
compose(StreamableRecordBindingData source,
Exchange exchange)
Takes the data from the passed in source object and composes a SwithYardMessage based on the specified Exchange.
|
StreamableRecordBindingData |
decompose(Exchange exchange,
StreamableRecordBindingData target)
Takes the data from the SwitchYardMessage in the specified Exchange and decomposes it into the target object.
|
getContextMapper, getMessageType, setContextMapperpublic Message compose(StreamableRecordBindingData source, Exchange exchange) throws Exception
source - the source objectexchange - the exchange to useException - if a problem happenspublic StreamableRecordBindingData decompose(Exchange exchange, StreamableRecordBindingData target) throws Exception
exchange - the exchange to usetarget - the target objectException - if a problem happensCopyright © 2013–2018 JBoss by Red Hat. All rights reserved.