org.apache.storm.rocketmq

Interface MessageBodySerializer

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultMessageBodySerializer

public interface MessageBodySerializer
extends Serializable

RocketMQ message body serializer.

Method Summary

Modifier and Type	Method and Description
byte[]	serialize(Object body)

Method Detail

serialize

byte[] serialize(Object body)