T - The type of payload contained in this messagepublic class SerializedEventMessage<T> extends Object implements EventMessage<T>, SerializationAware
| Constructor and Description |
|---|
SerializedEventMessage(String eventIdentifier,
org.joda.time.DateTime timestamp,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Constructor to reconstruct an EventMessage using serialized data
|
| Modifier and Type | Method and Description |
|---|---|
EventMessage<T> |
andMetaData(Map<String,?> additionalMetaData)
Returns a copy of this EventMessage with it MetaData merged with the given
metaData. |
String |
getIdentifier()
Returns the identifier of this event.
|
MetaData |
getMetaData()
Returns the meta data for this event.
|
T |
getPayload()
Returns the payload of this Event.
|
Class |
getPayloadType()
Returns the type of the payload.
|
org.joda.time.DateTime |
getTimestamp()
Returns the timestamp of this event.
|
boolean |
isPayloadDeserialized()
Indicates whether the payload of this message has already been deserialized.
|
<R> SerializedObject<R> |
serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation)
Serialize the meta data of this message using given
serializer, using given
expectedRepresentation. |
<R> SerializedObject<R> |
serializePayload(Serializer serializer,
Class<R> expectedRepresentation)
Serialize the payload of this message using given
serializer, using given
expectedRepresentation. |
SerializedEventMessage<T> |
withMetaData(Map<String,?> newMetaData)
Returns a copy of this EventMessage with the given
metaData. |
protected Object |
writeReplace()
Java Serialization API Method that provides a replacement to serialize, as the fields contained in this instance
are not serializable themselves.
|
public SerializedEventMessage(String eventIdentifier, org.joda.time.DateTime timestamp, SerializedObject<?> serializedPayload, SerializedObject<?> serializedMetaData, Serializer serializer)
eventIdentifier - The identifier of the messagetimestamp - The timestamp of the event messageserializedPayload - The serialized payload of the messageserializedMetaData - The serialized meta data of the messageserializer - The serializer to deserialize the payload and meta data withUnknownSerializedTypeException - if the type of the serialized object cannot be resolved to a classpublic <R> SerializedObject<R> serializePayload(Serializer serializer, Class<R> expectedRepresentation)
SerializationAwareserializer, using given
expectedRepresentation. This method should return the same SerializedObject instance when
invoked multiple times using the same serializer.serializePayload in interface SerializationAwareR - The type of data to serialize toserializer - The serializer to serialize payload withexpectedRepresentation - The type of data to serialize topublic <R> SerializedObject<R> serializeMetaData(Serializer serializer, Class<R> expectedRepresentation)
SerializationAwareserializer, using given
expectedRepresentation. This method should return the same SerializedObject instance when
invoked multiple times using the same serializer.serializeMetaData in interface SerializationAwareR - The type of data to serialize toserializer - The serializer to serialize meta data withexpectedRepresentation - The type of data to serialize topublic String getIdentifier()
EventMessagegetIdentifier in interface EventMessage<T>getIdentifier in interface Message<T>public org.joda.time.DateTime getTimestamp()
EventMessagegetTimestamp in interface EventMessage<T>public MetaData getMetaData()
MessagegetMetaData in interface Message<T>public T getPayload()
MessagegetPayload in interface Message<T>public Class getPayloadType()
MessagegetPayload().getClass(), but allows implementations to optimize by using
lazy loading or deserialization.getPayloadType in interface Message<T>public SerializedEventMessage<T> withMetaData(Map<String,?> newMetaData)
EventMessagemetaData. The payload, Timestamp and Identifier remain unchanged.withMetaData in interface EventMessage<T>withMetaData in interface Message<T>newMetaData - The new MetaData for the Messagepublic EventMessage<T> andMetaData(Map<String,?> additionalMetaData)
EventMessagemetaData. The payload,
Timestamp and Identifier remain unchanged.andMetaData in interface EventMessage<T>andMetaData in interface Message<T>additionalMetaData - The MetaData to merge withpublic boolean isPayloadDeserialized()
true if the payload is deserialized, otherwise falseprotected Object writeReplace()
Copyright © 2010-2014. All Rights Reserved.