org.apache.flink.statefun.sdk.java.message

Class EgressMessageWrapper

java.lang.Object

org.apache.flink.statefun.sdk.java.message.EgressMessageWrapper

All Implemented Interfaces:

EgressMessage

@Internal
public final class EgressMessageWrapper
extends java.lang.Object
implements EgressMessage

Constructor Summary

Constructors

Constructor and Description
EgressMessageWrapper(TypeName targetEgressId, TypedValue actualMessage)

Method Summary

Modifier and Type	Method and Description
Slice	egressMessageValueBytes()
TypeName	egressMessageValueType()
boolean	equals(java.lang.Object o)
int	hashCode()
TypeName	targetEgressId()
java.lang.String	toString()
TypedValue	typedValue()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

EgressMessageWrapper

public EgressMessageWrapper(TypeName targetEgressId,
                            TypedValue actualMessage)

Method Detail

targetEgressId

public TypeName targetEgressId()

Specified by:

targetEgressId in interface EgressMessage

egressMessageValueType

public TypeName egressMessageValueType()

Specified by:

egressMessageValueType in interface EgressMessage

egressMessageValueBytes

public Slice egressMessageValueBytes()

Specified by:

egressMessageValueBytes in interface EgressMessage

typedValue

public TypedValue typedValue()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object