Toggle navigation
Home
io.atomix.messaging.netty.InternalMessage to io.atomix.messaging.netty.InternalRequest
No. of Instances - 15
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
message.type()
to
message.subject()
message.type()
to
message.subject()
message.type()
to
message.subject()
executor.execute(() -> { byte[] responsePayload=null; InternalReply.Status status=InternalReply.Status.OK; try { responsePayload=handler.apply(message.sender(),message.payload()); } catch ( Exception e) { status=InternalReply.Status.ERROR_HANDLER_EXCEPTION; } connection.reply(message,status,Optional.ofNullable(responsePayload)); } )
to
executor.execute(() -> { byte[] responsePayload=null; InternalReply.Status status=InternalReply.Status.OK; try { responsePayload=handler.apply(message.sender(),message.payload()); } catch ( Exception e) { log.debug("An error occurred in a message handler: {}",e); status=InternalReply.Status.ERROR_HANDLER_EXCEPTION; } connection.reply(message,status,Optional.ofNullable(responsePayload)); } )
message.type()
to
message.subject()
Cascading Type Change (Different)
BiConsumer<InternalMessage,ServerConnection>
to
BiConsumer<InternalRequest,ServerConnection>
BiConsumer<InternalMessage,ServerConnection>
to
BiConsumer<InternalRequest,ServerConnection>
InternalMessage
to
InternalReply
BiConsumer<InternalMessage,ServerConnection>
to
BiConsumer<InternalRequest,ServerConnection>