Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
Class and Description |
---|
BackPressureStrategy
Back-pressure algorithm interface.
|
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
MessageOut |
MessagingService.Verb |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
MessageOut |
Class and Description |
---|
MessagingService.Verb |
OutboundTcpConnectionPool |
Class and Description |
---|
AsyncOneResponse
A callback specialized for returning a value from a single target; that is, this is for messages
that we only send to one recipient.
|
BackPressureState
Interface meant to track the back-pressure state per replica host.
|
BackPressureStrategy
Back-pressure algorithm interface.
|
CallbackInfo
Encapsulates the callback information.
|
IAsyncCallback
implementors of IAsyncCallback need to make sure that any public methods
are threadsafe with respect to response() being called from the message
service.
|
IAsyncCallbackWithFailure |
IMessageSink |
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
MessageOut |
MessagingService |
MessagingService.SocketThread |
MessagingService.Verb |
MessagingServiceMBean
MBean exposing MessagingService metrics plus allowing to enable/disable back-pressure.
|
OutboundTcpConnection |
OutboundTcpConnectionPool |
PingMessage
A backport of the version from 4.0, intentionnaly added as versions 4.0 or greater aren't guaranteed
to know the c* versions they communicate with before they connect.
|
Class and Description |
---|
IAsyncCallback
implementors of IAsyncCallback need to make sure that any public methods
are threadsafe with respect to response() being called from the message
service.
|
IAsyncCallbackWithFailure |
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
Class and Description |
---|
MessageOut |
Class and Description |
---|
IAsyncCallback
implementors of IAsyncCallback need to make sure that any public methods
are threadsafe with respect to response() being called from the message
service.
|
IAsyncCallbackWithFailure |
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
Class and Description |
---|
IAsyncCallback
implementors of IAsyncCallback need to make sure that any public methods
are threadsafe with respect to response() being called from the message
service.
|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
Class and Description |
---|
IncomingStreamingConnection
Thread to consume stream init messages.
|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
MessageIn |
Class and Description |
---|
MessagingServiceMBean
MBean exposing MessagingService metrics plus allowing to enable/disable back-pressure.
|
Class and Description |
---|
MessageIn |
Class and Description |
---|
AsyncOneResponse
A callback specialized for returning a value from a single target; that is, this is for messages
that we only send to one recipient.
|
Copyright © 2020 The Apache Software Foundation