| Package | Description |
|---|---|
| org.gradle.messaging.remote.internal | |
| org.gradle.messaging.remote.internal.protocol |
| Modifier and Type | Method and Description |
|---|---|
Connection<Message> |
HandshakeOutgoingConnector.connect(Address destinationAddress) |
protected IncomingConnector<Message> |
MessagingServices.createIncomingConnector() |
AsyncConnection<Message> |
Router.createLocalConnection() |
protected OutgoingConnector<Message> |
MessagingServices.createOutgoingConnector() |
AsyncConnection<Message> |
Router.createRemoteConnection() |
| Modifier and Type | Method and Description |
|---|---|
void |
MethodInvocationUnmarshallingDispatch.dispatch(Message message) |
void |
MethodInvocationMarshallingDispatch.dispatch(Message message) |
void |
WorkerProtocol.handleIncoming(Message message) |
void |
UnicastSendProtocol.handleIncoming(Message message) |
void |
SendProtocol.handleIncoming(Message message) |
void |
RemoteDisconnectProtocol.handleIncoming(Message message) |
void |
ReceiveProtocol.handleIncoming(Message message) |
void |
BufferingProtocol.handleIncoming(Message message) |
void |
BroadcastSendProtocol.handleIncoming(Message message) |
void |
WorkerProtocol.handleOutgoing(Message message) |
void |
UnicastSendProtocol.handleOutgoing(Message message) |
void |
SendProtocol.handleOutgoing(Message message) |
void |
RemoteDisconnectProtocol.handleOutgoing(Message message) |
void |
ReceiveProtocol.handleOutgoing(Message message) |
void |
BufferingProtocol.handleOutgoing(Message message) |
void |
BroadcastSendProtocol.handleOutgoing(Message message) |
| Modifier and Type | Method and Description |
|---|---|
Address |
HandshakeIncomingConnector.accept(Action<ConnectEvent<Connection<Message>>> action,
boolean allowRemote) |
void |
MessageHub.addConnection(Connection<Message> connection)
Adds an incoming connection.
|
void |
WorkerProtocol.start(ProtocolContext<Message> context) |
void |
UnicastSendProtocol.start(ProtocolContext<Message> context) |
void |
SendProtocol.start(ProtocolContext<Message> context) |
void |
RemoteDisconnectProtocol.start(ProtocolContext<Message> context) |
void |
ReceiveProtocol.start(ProtocolContext<Message> context) |
void |
BufferingProtocol.start(ProtocolContext<Message> context) |
void |
BroadcastSendProtocol.start(ProtocolContext<Message> context) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractPayloadMessage |
class |
ConnectRequest |
class |
ConsumerAvailable |
class |
ConsumerMessage |
class |
ConsumerReady |
class |
ConsumerStopped |
class |
ConsumerStopping |
class |
ConsumerUnavailable |
class |
EndOfStreamEvent |
class |
MessageCredits |
class |
MethodMetaInfo |
class |
ParticipantAvailable |
class |
ParticipantUnavailable |
class |
ProducerAvailable |
class |
ProducerMessage |
class |
ProducerReady |
class |
ProducerStopped |
class |
ProducerUnavailable |
class |
RemoteMethodInvocation |
class |
Request |
class |
StatelessMessage |
class |
WorkerStopped |
class |
WorkerStopping |
| Modifier and Type | Method and Description |
|---|---|
Message |
PayloadMessage.withNestedPayload(Object payload) |
Message |
AbstractPayloadMessage.withNestedPayload(Object payload) |
Message |
Request.withPayload(Object payload) |
abstract Message |
AbstractPayloadMessage.withPayload(Object payload) |
Copyright © 2013. All rights reserved