Package org.axonframework.axonserver.connector.command

Class GrpcBackedCommandMessage<C>

java.lang.Object

org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage<C>

Type Parameters:

C - a generic specifying the payload type of the wrapped CommandMessage

All Implemented Interfaces:

Serializable, org.axonframework.commandhandling.CommandMessage<C>, org.axonframework.messaging.Message<C>

public class GrpcBackedCommandMessage<C>
extends Object
implements org.axonframework.commandhandling.CommandMessage<C>

Wrapper that allows clients to access a gRPC Command as a CommandMessage.

Since:

4.0

Author:

Marc Gathier

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
GrpcBackedCommandMessage(io.axoniq.axonserver.grpc.command.Command command, org.axonframework.serialization.Serializer serializer)	Instantiate a GrpcBackedCommandMessage with the given command and using the provided Serializer to be able to retrieve the payload and MetaData from it.

Method Summary

Modifier and Type	Method	Description
GrpcBackedCommandMessage<C>	andMetaData(Map<String,?> metaData)
String	getCommandName()
String	getIdentifier()
org.axonframework.messaging.MetaData	getMetaData()
C	getPayload()
Class<C>	getPayloadType()
GrpcBackedCommandMessage<C>	withMetaData(Map<String,?> metaData)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.messaging.Message

serializeMetaData, serializePayload

Constructor Details

GrpcBackedCommandMessage

public GrpcBackedCommandMessage(io.axoniq.axonserver.grpc.command.Command command,
 org.axonframework.serialization.Serializer serializer)

Instantiate a GrpcBackedCommandMessage with the given command and using the provided Serializer to be able to retrieve the payload and MetaData from it.

Parameters:

command - the Command which is being wrapped as a CommandMessage

serializer - the Serializer used to deserialize the payload and MetaData from the given command

Method Details

getCommandName

public String getCommandName()

Specified by:

getCommandName in interface org.axonframework.commandhandling.CommandMessage<C>

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface org.axonframework.messaging.Message<C>

getMetaData

public org.axonframework.messaging.MetaData getMetaData()

Specified by:

getMetaData in interface org.axonframework.messaging.Message<C>

getPayload

public C getPayload()

Specified by:

getPayload in interface org.axonframework.messaging.Message<C>

getPayloadType

public Class<C> getPayloadType()

Specified by:

getPayloadType in interface org.axonframework.messaging.Message<C>

withMetaData

public GrpcBackedCommandMessage<C> withMetaData(@Nonnull
 Map<String,?> metaData)

Specified by:

withMetaData in interface org.axonframework.commandhandling.CommandMessage<C>

Specified by:

withMetaData in interface org.axonframework.messaging.Message<C>

andMetaData

public GrpcBackedCommandMessage<C> andMetaData(@Nonnull
 Map<String,?> metaData)

Specified by:

andMetaData in interface org.axonframework.commandhandling.CommandMessage<C>

Specified by:

andMetaData in interface org.axonframework.messaging.Message<C>