public class BackloggingIncomingMessageHandler extends Object implements IncomingMessageHandler
Constructor and Description |
---|
BackloggingIncomingMessageHandler()
Creates a new BackloggingIncomingMessageHandler.
|
BackloggingIncomingMessageHandler(org.joda.time.Duration backlogThresholdMargin)
Creates a new BackloggingIncomingMessageHandler.
|
Modifier and Type | Method and Description |
---|---|
void |
onIncomingMessages(Cluster destination,
EventMessage... messages)
Invoked while the ReplayingCluster is in replay mode and an Event is being dispatched to the Cluster.
|
void |
onReplayFailed(Cluster destination,
RuntimeException cause)
Invoked when a replay has failed.
|
void |
prepareForReplay(Cluster destination)
Invoked just before replay mode is activated.
|
void |
processBacklog(Cluster destination)
Invoked when all events from the Event Store have been processed.
|
void |
releaseMessage(DomainEventMessage message)
Invoked when a message has been replayed from the event store.
|
public BackloggingIncomingMessageHandler()
BackloggingIncomingMessageHandler(org.joda.time.Duration)
constructor to provide a margin that better suits
the latency.public BackloggingIncomingMessageHandler(org.joda.time.Duration backlogThresholdMargin)
backlogThresholdMargin
indicates the
age that an event may have to be backlogged. Older events will not be backlogged, as we may assume they will be
part of the replay process.
A good starting value for this is the maximum expected latency of incoming events.backlogThresholdMargin
- The margin of time to take into account when backlogging events.public void prepareForReplay(Cluster destination)
IncomingMessageHandler
IncomingMessageHandler.onIncomingMessages(org.axonframework.eventhandling.Cluster, org.axonframework.domain.EventMessage[])
prior to this method invocation should be dispatched immediately to the destination cluster to prevent message
loss.
This method is invoked in the thread that executes the replay process.prepareForReplay
in interface IncomingMessageHandler
destination
- The cluster on which events are about te be replayedpublic void onIncomingMessages(Cluster destination, EventMessage... messages)
IncomingMessageHandler
message
is before the timestamp of any message reported via IncomingMessageHandler.releaseMessage(org.axonframework.domain.DomainEventMessage)
, consider discarding the incoming message.
This method is invoked in the thread that attempts to publish the given messages to the given destination.onIncomingMessages
in interface IncomingMessageHandler
destination
- The cluster to receive the messagemessages
- The messages to dispatch to the clusterpublic void releaseMessage(DomainEventMessage message)
IncomingMessageHandler
IncomingMessageHandler.onIncomingMessages(org.axonframework.eventhandling.Cluster, org.axonframework.domain.EventMessage[])
, it
should
be discarded.
After this invocation, any invocation of IncomingMessageHandler.onIncomingMessages(org.axonframework.eventhandling.Cluster,
org.axonframework.domain.EventMessage[])
with a message who's timestamp is lower that this message's timestamp
can be safely discarded.
This method is invoked in the thread that executes the replay processreleaseMessage
in interface IncomingMessageHandler
message
- The message replayed from the event storepublic void onReplayFailed(Cluster destination, RuntimeException cause)
IncomingMessageHandler
onReplayFailed
in interface IncomingMessageHandler
destination
- The destination cluster to dispatch backlogged messages to, if appropriate in this scenariocause
- The cause of the failurepublic void processBacklog(Cluster destination)
IncomingMessageHandler
IncomingMessageHandler.onIncomingMessages(org.axonframework.eventhandling.Cluster,
org.axonframework.domain.EventMessage[])
should be dispatched to the given delegate
. Transactions
started by the replay process have been committed or rolled back prior to the invocation of this method.
Note that IncomingMessageHandler.onIncomingMessages(org.axonframework.eventhandling.Cluster,
org.axonframework.domain.EventMessage[])
may be invoked during or after the invocation of this method. These
messages must be dispatched by this handler to prevent message loss.
This method is invoked in the thread that executes the replay processprocessBacklog
in interface IncomingMessageHandler
destination
- The destination cluster to dispatch backlogged messages toCopyright © 2010-2013. All Rights Reserved.