Package io.ably.lib.types

Class MessageSerializer

java.lang.Object

io.ably.lib.types.MessageSerializer

public class MessageSerializer
extends Object

MessageReader: internal Utility class to convert response bodies in different formats to Message and Message arrays.

Constructor Summary

Constructors

Constructor	Description
MessageSerializer()

Method Summary

Modifier and Type	Method	Description
static HttpCore.RequestBody	asJsonRequest(Message message)	JSON encode
static HttpCore.RequestBody	asJsonRequest(Message[] messages)
static HttpCore.RequestBody	asJSONRequest(Message.Batch[] pubSpecs)
static HttpCore.RequestBody	asMsgpackRequest(Message message)	Msgpack encode
static HttpCore.RequestBody	asMsgpackRequest(Message[] messages)
static HttpCore.RequestBody	asMsgpackRequest(Message.Batch[] pubSpecs)
static HttpCore.BodyHandler<Message>	getMessageResponseHandler(ChannelOptions opts)	BodyHandler
static Message[]	readMessagesFromJson(byte[] packed)	JSON decode
static Message[]	readMsgpack(byte[] packed)
static Message[]	readMsgpackArray(org.msgpack.core.MessageUnpacker unpacker)	Msgpack decode
static Map<String,String>	readStringMap(org.msgpack.core.MessageUnpacker unpacker)
static void	write(Map<String,String> map, org.msgpack.core.MessagePacker packer)
static byte[]	writeMsgpackArray(Message[] messages)
static void	writeMsgpackArray(Message[] messages, org.msgpack.core.MessagePacker packer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MessageSerializer

public MessageSerializer()

Method Details

readMsgpackArray

public static Message[] readMsgpackArray(org.msgpack.core.MessageUnpacker unpacker)
                                  throws IOException

Msgpack decode

Throws:

IOException

readMsgpack

public static Message[] readMsgpack(byte[] packed)
                             throws AblyException

Throws:

AblyException

asMsgpackRequest

public static HttpCore.RequestBody asMsgpackRequest(Message message)
                                             throws AblyException

Msgpack encode

Throws:

AblyException

asMsgpackRequest

public static HttpCore.RequestBody asMsgpackRequest(Message[] messages)

writeMsgpackArray

public static byte[] writeMsgpackArray(Message[] messages)

writeMsgpackArray

public static void writeMsgpackArray(Message[] messages,
 org.msgpack.core.MessagePacker packer)

write

public static void write(Map<String,String> map,
 org.msgpack.core.MessagePacker packer)
                  throws IOException

Throws:

IOException

readStringMap

public static Map<String,String> readStringMap(org.msgpack.core.MessageUnpacker unpacker)
                                        throws IOException

Throws:

IOException

asMsgpackRequest

public static HttpCore.RequestBody asMsgpackRequest(Message.Batch[] pubSpecs)

readMessagesFromJson

public static Message[] readMessagesFromJson(byte[] packed)
                                      throws MessageDecodeException

JSON decode

Throws:

MessageDecodeException

asJsonRequest

public static HttpCore.RequestBody asJsonRequest(Message message)
                                          throws AblyException

JSON encode

Throws:

AblyException

asJsonRequest

public static HttpCore.RequestBody asJsonRequest(Message[] messages)

asJSONRequest

public static HttpCore.RequestBody asJSONRequest(Message.Batch[] pubSpecs)

getMessageResponseHandler

public static HttpCore.BodyHandler<Message> getMessageResponseHandler(ChannelOptions opts)

BodyHandler