Toggle navigation
Home
io.axoniq.axonhub.client.util.GrpcObjectSerializer to io.axoniq.axonhub.client.util.GrpcPayloadSerializer
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'AxonFramework'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
QueryResponse.newBuilder().setPayload(payloadSerializer.apply(initialResult.getPayload())).putAllMetaData(metadataSerializer.apply(initialResult.getMetaData())).setMessageIdentifier(initialResult.getIdentifier()).setRequestIdentifier(subscriptionId)
to
QueryResponse.newBuilder().setPayload(payloadSerializer.apply(initialResult)).putAllMetaData(metadataSerializer.apply(initialResult.getMetaData())).setMessageIdentifier(initialResult.getIdentifier()).setRequestIdentifier(subscriptionId)
QueryUpdate.newBuilder().setPayload(payloadSerializer.apply(update.getPayload())).putAllMetaData(metadataSerializer.apply(update.getMetaData())).setMessageIdentifier(update.getIdentifier()).setClientName(conf.getClientName())
to
QueryUpdate.newBuilder().setPayload(payloadSerializer.apply(update)).putAllMetaData(metadataSerializer.apply(update.getMetaData())).setMessageIdentifier(update.getIdentifier()).setClientName(conf.getClientName())
QueryRequest.newBuilder().setTimestamp(System.currentTimeMillis()).setMessageIdentifier(message.getIdentifier()).setQuery(message.getQueryName()).setClientId(conf.getClientName()).setComponentName(conf.getComponentName()).setPayload(payloadSerializer.apply(message.getPayload())).setResponseType(responseTypeSerializer.apply(message.getResponseType())).putAllMetaData(metadataSerializer.apply(message.getMetaData()))
to
QueryRequest.newBuilder().setTimestamp(System.currentTimeMillis()).setMessageIdentifier(message.getIdentifier()).setQuery(message.getQueryName()).setClientId(conf.getClientName()).setComponentName(conf.getComponentName()).setPayload(payloadSerializer.apply(message)).setResponseType(responseTypeSerializer.apply(message.getResponseType())).putAllMetaData(metadataSerializer.apply(message.getMetaData()))