Toggle navigation
Home
org.axonframework.queryhandling.UpdateHandler to org.axonframework.queryhandling.FluxSinkWrapper
No. of Instances - 2
No. of Commits - 1
No. of Projects - {'AxonFramework'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
UpdateHandler<?,U>
to
FluxSinkWrapper<?>
Add or Remove Method invocation
updateHandler.onUpdate(update.getPayload())
to
doEmit(query,updateHandler,update)
monitorCallback.reportSuccess()
to
doEmit(query,updateHandler,update)
logger.error(format("An error happened while trying to emit an update to a query: %s.",query),e)
to
doEmit(query,updateHandler,update)
monitorCallback.reportFailure(e)
to
doEmit(query,updateHandler,update)
updateHandlers.remove(query)
to
doEmit(query,updateHandler,update)
updateHandler.onCompletedExceptionally(e)
to
doEmit(query,updateHandler,update)
(SubscriptionQueryMessage<?,?,U>)m
to
doEmit(query,updateHandler,update)
registeringSubscriptionQueryReadSafe
to
forEach
updateHandlers.remove(query).onCompleted()
to
updateHandlers.remove(query).complete()
registeringSubscriptionQueryReadSafe
to
forEach
updateHandlers.remove(query).onCompletedExceptionally(cause)
to
updateHandlers.remove(query).error(cause)
registeringSubscriptionQueryReadSafe
to
forEach