org.atlasapi.messaging

Interface Message

All Known Implementing Classes:

AbstractMessage, BeginReplayMessage, EndReplayMessage, EntityUpdatedMessage, ReplayMessage

public interface Message

Base interface for messages to be dispatched to org.atlasapi.messaging.messaging.worker.Workers.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canCoalesce()
void	dispatchTo(Worker worker) Dispatch this message to the given org.atlasapi.messaging.messaging.worker.Worker.
String	getEntityId() Get the id of the entity this message refers to.
String	getEntitySource() Get the source identifier of the entity to which this message refers.
String	getEntityType() Get the type of the entity this message refers to.
String	getMessageId() Get a unique id for this message.
Long	getTimestamp() Get the timestamp when the message happened

Method Detail

getMessageId

String getMessageId()

Get a unique id for this message.

getTimestamp

Long getTimestamp()

Get the timestamp when the message happened

getEntityId

String getEntityId()

Get the id of the entity this message refers to.

getEntityType

String getEntityType()

Get the type of the entity this message refers to.

getEntitySource

String getEntitySource()

Get the source identifier of the entity to which this message refers.

canCoalesce

boolean canCoalesce()

dispatchTo

void dispatchTo(Worker worker)

Dispatch this message to the given org.atlasapi.messaging.messaging.worker.Worker.