| Package | Description |
|---|---|
| org.gradle.messaging.remote.internal | |
| org.gradle.messaging.remote.internal.protocol |
| Modifier and Type | Method and Description |
|---|---|
protected AsyncConnection<DiscoveryMessage> |
MessagingServices.createMulticastConnection() |
| Modifier and Type | Method and Description |
|---|---|
void |
GroupMessageFilter.dispatch(DiscoveryMessage message) |
void |
ChannelRegistrationProtocol.handleIncoming(DiscoveryMessage message) |
void |
ChannelLookupProtocol.handleIncoming(DiscoveryMessage message) |
void |
ChannelRegistrationProtocol.handleOutgoing(DiscoveryMessage message) |
void |
ChannelLookupProtocol.handleOutgoing(DiscoveryMessage message) |
| Modifier and Type | Method and Description |
|---|---|
void |
ChannelRegistrationProtocol.start(ProtocolContext<DiscoveryMessage> context) |
void |
ChannelLookupProtocol.start(ProtocolContext<DiscoveryMessage> context) |
| Constructor and Description |
|---|
DefaultIncomingBroadcast(MessageOriginator messageOriginator,
String group,
AsyncConnection<DiscoveryMessage> connection,
IncomingConnector<Message> incomingConnector,
ExecutorFactory executorFactory,
IdGenerator<?> idGenerator,
ClassLoader messagingClassLoader) |
DefaultOutgoingBroadcast(MessageOriginator messageOriginator,
String group,
AsyncConnection<DiscoveryMessage> connection,
OutgoingConnector<Message> outgoingConnector,
ExecutorFactory executorFactory,
IdGenerator<?> idGenerator,
ClassLoader messagingClassLoader) |
GroupMessageFilter(String group,
Dispatch<? super DiscoveryMessage> dispatch) |
| Modifier and Type | Class and Description |
|---|---|
class |
ChannelAvailable |
class |
ChannelUnavailable |
class |
LookupRequest |
class |
UnknownMessage |
| Modifier and Type | Method and Description |
|---|---|
DiscoveryMessage |
DiscoveryProtocolSerializer.read(DataInputStream inputStream,
InetEndpoint localAddress,
InetEndpoint remoteAddress) |
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryProtocolSerializer.write(DiscoveryMessage message,
DataOutputStream outputStream) |
Copyright © 2013. All rights reserved