public class SimplePubSubMessageConverter extends Object implements PubSubMessageConverter
PubSubMessageConverter
that directly maps payloads of type
byte[]
, ByteString
, ByteBuffer
, and String
to Pub/Sub messages.Constructor and Description |
---|
SimplePubSubMessageConverter() |
SimplePubSubMessageConverter(Charset charset) |
Modifier and Type | Method and Description |
---|---|
Object |
fromPubSubMessage(com.google.pubsub.v1.PubsubMessage message,
Class<?> payloadType)
Convert the payload of a given
PubsubMessage to a desired Java type. |
com.google.pubsub.v1.PubsubMessage |
toPubSubMessage(Object payload,
Map<String,String> headers)
Create a
PubsubMessage given an object for the payload and a map of headers |
public SimplePubSubMessageConverter()
public SimplePubSubMessageConverter(Charset charset)
public com.google.pubsub.v1.PubsubMessage toPubSubMessage(Object payload, Map<String,String> headers)
PubSubMessageConverter
PubsubMessage
given an object for the payload and a map of headerstoPubSubMessage
in interface PubSubMessageConverter
payload
- the object to place into the message payloadheaders
- the headers of the messagepublic Object fromPubSubMessage(com.google.pubsub.v1.PubsubMessage message, Class<?> payloadType)
PubSubMessageConverter
PubsubMessage
to a desired Java type.fromPubSubMessage
in interface PubSubMessageConverter
message
- the message containing the payload of the objectpayloadType
- the desired type of the objectCopyright © 2018 Pivotal Software, Inc.. All rights reserved.