org.gradle.messaging.remote.internal.protocol

Class DiscoveryProtocolSerializer

java.lang.Object

org.gradle.messaging.remote.internal.protocol.DiscoveryProtocolSerializer

All Implemented Interfaces:

MessageSerializer<DiscoveryMessage>

public class DiscoveryProtocolSerializer
extends java.lang.Object
implements MessageSerializer<DiscoveryMessage>

Field Summary

Fields

Modifier and Type	Field and Description
static byte	CHANNEL_AVAILABLE
static byte	CHANNEL_UNAVAILABLE
static byte	LOOKUP_REQUEST
static byte	PROTOCOL_VERSION

Constructor Summary

Constructors

Constructor and Description
DiscoveryProtocolSerializer()

Method Summary

Methods

Modifier and Type	Method and Description
DiscoveryMessage	read(java.io.DataInputStream inputStream, InetEndpoint localAddress, InetEndpoint remoteAddress)
void	write(DiscoveryMessage message, java.io.DataOutputStream outputStream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PROTOCOL_VERSION

public static final byte PROTOCOL_VERSION

See Also:

Constant Field Values

LOOKUP_REQUEST

public static final byte LOOKUP_REQUEST

See Also:

Constant Field Values

CHANNEL_AVAILABLE

public static final byte CHANNEL_AVAILABLE

See Also:

Constant Field Values

CHANNEL_UNAVAILABLE

public static final byte CHANNEL_UNAVAILABLE

See Also:

Constant Field Values

Constructor Detail

DiscoveryProtocolSerializer

public DiscoveryProtocolSerializer()

Method Detail

read

public DiscoveryMessage read(java.io.DataInputStream inputStream,
                    InetEndpoint localAddress,
                    InetEndpoint remoteAddress)
                      throws java.lang.Exception

Specified by:

read in interface MessageSerializer<DiscoveryMessage>

Throws:

java.lang.Exception

write

public void write(DiscoveryMessage message,
         java.io.DataOutputStream outputStream)
           throws java.lang.Exception

Specified by:

write in interface MessageSerializer<DiscoveryMessage>

Throws:

java.lang.Exception