Class RecursivePublicationGuard

java.lang.Object

io.fluxzero.sdk.publishing.RecursivePublicationGuard

All Implemented Interfaces:

DispatchInterceptor

public class RecursivePublicationGuard
extends Object
implements DispatchInterceptor

Prevents runaway recursive publication loops by carrying a publication depth in message metadata.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_DEPTH
static final String	PUBLICATION_DEPTH_METADATA_KEY

Fields inherited from interface DispatchInterceptor

defaultInterceptors, noOp

Constructor Summary

Constructors

Constructor	Description
RecursivePublicationGuard()
RecursivePublicationGuard(int maxPublicationDepth)

Method Summary

Modifier and Type	Method	Description
Message	interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts the dispatch of a message before it is serialized and published or locally handled.
protected int	nextDepth(MessageType messageType)
protected int	parseDepth(String value)
protected int	readDepth(Metadata metadata)

Methods inherited from class Object

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

Methods inherited from interface DispatchInterceptor

andThen, modifySerializedMessage, monitorDispatch

Field Details

PUBLICATION_DEPTH_METADATA_KEY

public static final String PUBLICATION_DEPTH_METADATA_KEY

See Also:

• Constant Field Values

DEFAULT_MAX_DEPTH

public static final int DEFAULT_MAX_DEPTH

See Also:

• Constant Field Values

Constructor Details

RecursivePublicationGuard

public RecursivePublicationGuard()

RecursivePublicationGuard

public RecursivePublicationGuard(int maxPublicationDepth)

Method Details

interceptDispatch

public Message interceptDispatch(Message message,
 MessageType messageType,
 String topic)

Description copied from interface: DispatchInterceptor

Intercepts the dispatch of a message before it is serialized and published or locally handled.

You may modify the message or return null to block dispatching. Throwing an exception also prevents dispatching.

Specified by:

interceptDispatch in interface DispatchInterceptor

Parameters:

message - the message to be dispatched

messageType - the type of the message (e.g., COMMAND, EVENT, etc.)

topic - the target topic or null if not applicable

Returns:

the modified message, the same message, or null to prevent dispatch

nextDepth

protected int nextDepth(MessageType messageType)

readDepth

protected int readDepth(Metadata metadata)

parseDepth

protected int parseDepth(String value)