Module io.fluxzero.sdk

Package io.fluxzero.sdk.modeling

Class DefaultEntityHelper.DeserializingMessageWithEntity

java.lang.Object

io.fluxzero.sdk.common.serialization.DeserializingMessage

io.fluxzero.sdk.modeling.DefaultEntityHelper.DeserializingMessageWithEntity

All Implemented Interfaces:

io.fluxzero.common.api.HasMetadata, HasMessage, HasEntity

Enclosing class:

DefaultEntityHelper

protected static class DefaultEntityHelper.DeserializingMessageWithEntity
extends DeserializingMessage
implements HasEntity

Decorates a DeserializingMessage with an associated entity.

Nested Class Summary

Nested classes/interfaces inherited from class io.fluxzero.sdk.common.serialization.DeserializingMessage

DeserializingMessage.MessageSpliterator

Field Summary

Fields inherited from class io.fluxzero.sdk.common.serialization.DeserializingMessage

messageFormatter

Fields inherited from interface io.fluxzero.sdk.common.HasMessage

warnedAboutMissingProperty

Fields inherited from interface io.fluxzero.common.api.HasMetadata

FINAL_CHUNK

Constructor Summary

Constructors

Constructor	Description
DeserializingMessageWithEntity(DeserializingMessage message, Entity<?> entity)

Method Summary

Methods inherited from class io.fluxzero.sdk.common.serialization.DeserializingMessage

apply, computeContextIfAbsent, computeForBatch, computeForBatchIfAbsent, getBatchResource, getBatchResourceOrDefault, getCurrent, getIndex, getMessageId, getMetadata, getOptionally, getPayload, getPayloadAs, getPayloadClass, getSerializedObject, getTimestamp, getType, handleBatch, isDeserialized, run, toMessage, toString, whenBatchCompletes, withData, withMetadata, withPayload

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.fluxzero.sdk.modeling.HasEntity

getEntity

Methods inherited from interface io.fluxzero.sdk.common.HasMessage

computeRoutingKey, getRoutingKey, getRoutingKey

Methods inherited from interface io.fluxzero.common.api.HasMetadata

chunked, lastChunk

Constructor Details

DeserializingMessageWithEntity

public DeserializingMessageWithEntity(DeserializingMessage message,
 Entity<?> entity)