org.cg.eventbus.message

Class Message

java.lang.Object

org.cg.eventbus.message.Message

public class Message
extends Object

Author:

liang.li

Constructor Summary

Constructors

Constructor and Description
Message(String topic, long offset, byte[] key, byte[] payload)
Message(String topic, long offset, byte[] key, byte[] payload, int partition)

Method Summary

Modifier and Type	Method and Description
byte[]	getKey()
long	getOffset()
int	getPartition()
byte[]	getPayload()
String	getTopic()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Message

public Message(String topic,
               long offset,
               byte[] key,
               byte[] payload,
               int partition)

Message

public Message(String topic,
               long offset,
               byte[] key,
               byte[] payload)

Method Detail

getTopic

public String getTopic()

getOffset

public long getOffset()

getKey

public byte[] getKey()

getPayload

public byte[] getPayload()

getPartition

public int getPartition()

toString

public String toString()

Overrides:

toString in class Object