Package | Description |
---|---|
org.springframework.cloud.stream.binder |
Modifier and Type | Method and Description |
---|---|
protected MessageValues |
AbstractBinder.deserializePayloadIfNecessary(org.springframework.messaging.Message<?> message) |
protected MessageValues |
AbstractBinder.deserializePayloadIfNecessary(MessageValues messageValues) |
static MessageValues |
EmbeddedHeaderUtils.extractHeaders(byte[] payload)
Return a message where headers, that were originally embedded into the payload,
have been promoted back to actual headers.
|
static MessageValues |
EmbeddedHeaderUtils.extractHeaders(org.springframework.messaging.Message<byte[]> message,
boolean copyRequestHeaders)
Return a message where headers, that were originally embedded into the payload,
have been promoted back to actual headers.
|
protected MessageValues |
AbstractBinder.serializePayloadIfNecessary(org.springframework.messaging.Message<?> message) |
Modifier and Type | Method and Description |
---|---|
protected MessageValues |
AbstractBinder.deserializePayloadIfNecessary(MessageValues messageValues) |
static byte[] |
EmbeddedHeaderUtils.embedHeaders(MessageValues original,
String... headers)
Return a new message where some of the original headers of
original have
been embedded into the new message payload. |
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.