Package org.axonframework.axonserver.connector.util

Class GrpcPayloadSerializer

java.lang.Object

org.axonframework.axonserver.connector.util.GrpcPayloadSerializer

All Implemented Interfaces:

Function<org.axonframework.messaging.Message<?>,io.axoniq.axonserver.grpc.SerializedObject>

public class GrpcPayloadSerializer
extends Object
implements Function<org.axonframework.messaging.Message<?>,io.axoniq.axonserver.grpc.SerializedObject>

Mapping that translates a Message into a GRPC SerializedObject.

Since:

4.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor	Description
GrpcPayloadSerializer(org.axonframework.serialization.Serializer serializer)	Constructs a GrpcPayloadSerializer using the given serializer to serialize messages with

Method Summary

Modifier and Type	Method	Description
io.axoniq.axonserver.grpc.SerializedObject	apply(org.axonframework.messaging.Message message)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Details

GrpcPayloadSerializer

public GrpcPayloadSerializer(org.axonframework.serialization.Serializer serializer)

Constructs a GrpcPayloadSerializer using the given serializer to serialize messages with

Parameters:

serializer - the Serializer used to serialize messages with

Method Details

apply

public io.axoniq.axonserver.grpc.SerializedObject apply(org.axonframework.messaging.Message message)

Specified by:

apply in interface Function<org.axonframework.messaging.Message<?>,io.axoniq.axonserver.grpc.SerializedObject>