| 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) |
| Constructor and Description |
|---|
DefaultIncomingBroadcast(MessageOriginator messageOriginator,
java.lang.String group,
AsyncConnection<DiscoveryMessage> connection,
IncomingConnector<Message> incomingConnector,
ExecutorFactory executorFactory,
IdGenerator<?> idGenerator,
java.lang.ClassLoader messagingClassLoader) |
DefaultMultiChannelConnector(OutgoingConnector<Message> outgoingConnector,
IncomingConnector<Message> incomingConnector,
ExecutorFactory executorFactory,
java.lang.ClassLoader messagingClassLoader) |
DefaultMultiChannelConnector(OutgoingConnector<Message> outgoingConnector,
IncomingConnector<Message> incomingConnector,
ExecutorFactory executorFactory,
java.lang.ClassLoader messagingClassLoader) |
DefaultOutgoingBroadcast(MessageOriginator messageOriginator,
java.lang.String group,
AsyncConnection<DiscoveryMessage> connection,
OutgoingConnector<Message> outgoingConnector,
ExecutorFactory executorFactory,
IdGenerator<?> idGenerator,
java.lang.ClassLoader messagingClassLoader) |
HandshakeIncomingConnector(IncomingConnector<Message> connector,
java.util.concurrent.Executor executor) |
HandshakeOutgoingConnector(OutgoingConnector<Message> connector) |
MethodInvocationMarshallingDispatch(Dispatch<? super Message> dispatch) |
MethodInvocationUnmarshallingDispatch(Dispatch<? super Message> dispatch,
java.lang.ClassLoader classLoader) |
Router(java.util.concurrent.Executor executor,
DispatchFailureHandler<? super Message> failureHandler) |
| 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(java.lang.Object payload) |
Message |
AbstractPayloadMessage.withNestedPayload(java.lang.Object payload) |
Message |
Request.withPayload(java.lang.Object payload) |
abstract Message |
AbstractPayloadMessage.withPayload(java.lang.Object payload) |
Copyright © 2013. All rights reserved