Class DefaultEntityHelper.MessageWithEntity

java.lang.Object

io.fluxzero.sdk.modeling.DefaultEntityHelper.MessageWithEntity

All Implemented Interfaces:

HasMessage, HasEntity

Enclosing class:

DefaultEntityHelper

protected static class DefaultEntityHelper.MessageWithEntity
extends Object
implements HasMessage, HasEntity

Wraps a message and its corresponding entity for use in interception or handler invocation.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHUNK_INDEX
static final String	FINAL_CHUNK
static final String	FIRST_CHUNK

Fields inherited from interface HasMessage

warnedAboutMissingProperty

Constructor Summary

Constructors

Constructor	Description
MessageWithEntity(Object payload, Entity<?> entity)
MessageWithEntity(Object payload, Entity<?> entity, boolean afterHandler)

Method Summary

Modifier and Type	Method	Description
default boolean	chunked()
default boolean	firstChunk()
io.fluxzero.common.api.Metadata	getMetadata()
<R> R	getPayload()	Retrieves the message payload, deserializing if necessary, cast to the expected type.
default boolean	lastChunk()
Message	toMessage()	Returns the underlying Message representation of this object.
DefaultEntityHelper.MessageWithEntity	withEntity(Entity<?> entity)

Methods inherited from class Object

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

Methods inherited from interface HasEntity

getEntity

Methods inherited from interface HasMessage

computeRoutingKey, getMessageId, getPayloadAs, getPayloadClass, getRoutingKey, getRoutingKey, getTimestamp

Field Details

FIRST_CHUNK

static final String FIRST_CHUNK

See Also:

• Constant Field Values

FINAL_CHUNK

static final String FINAL_CHUNK

See Also:

• Constant Field Values

CHUNK_INDEX

static final String CHUNK_INDEX

See Also:

• Constant Field Values

Constructor Details

MessageWithEntity

public MessageWithEntity(Object payload,
 Entity<?> entity)

MessageWithEntity

public MessageWithEntity(Object payload,
 Entity<?> entity,
 boolean afterHandler)

Method Details

withEntity

public DefaultEntityHelper.MessageWithEntity withEntity(Entity<?> entity)

getMetadata

public io.fluxzero.common.api.Metadata getMetadata()

toMessage

public Message toMessage()

Description copied from interface: HasMessage

Returns the underlying Message representation of this object.

Specified by:

toMessage in interface HasMessage

Returns:

the Message backing this instance

getPayload

public <R> R getPayload()

Description copied from interface: HasMessage

Retrieves the message payload, deserializing if necessary, cast to the expected type.

By default, this delegates to toMessage().getPayload().

Specified by:

getPayload in interface HasMessage

Type Parameters:

R - the expected payload type

Returns:

the deserialized payload

chunked

default boolean chunked()

lastChunk

default boolean lastChunk()

firstChunk

default boolean firstChunk()