B E F H I M N P R S T U

B

Builder() - Constructor for class io.atomix.messaging.MessagingService.Builder

E

Endpoint - Class in io.atomix.messaging

Representation of a TCP/UDP communication end point.

Endpoint(InetAddress, int) - Constructor for class io.atomix.messaging.Endpoint

endpoint() - Method in interface io.atomix.messaging.MessagingService

Returns the local messaging service endpoint.

equals(Object) - Method in class io.atomix.messaging.Endpoint

F

from(String, int) - Static method in class io.atomix.messaging.Endpoint

Returns an endpoint for the given host/port.

H

hashCode() - Method in class io.atomix.messaging.Endpoint

host() - Method in class io.atomix.messaging.Endpoint

I

io.atomix.messaging - package io.atomix.messaging

Atomix messaging service.

M

ManagedMessagingService - Interface in io.atomix.messaging

Managed messaging service.

MessagingException - Exception in io.atomix.messaging

Top level exception for MessagingService failures.

MessagingException() - Constructor for exception io.atomix.messaging.MessagingException

MessagingException(String) - Constructor for exception io.atomix.messaging.MessagingException

MessagingException(String, Throwable) - Constructor for exception io.atomix.messaging.MessagingException

MessagingException(Throwable) - Constructor for exception io.atomix.messaging.MessagingException

MessagingException.NoRemoteHandler - Exception in io.atomix.messaging

Exception indicating no remote registered remote handler.

MessagingException.ProtocolException - Exception in io.atomix.messaging

Exception indicating failure due to invalid message structure such as an incorrect preamble.

MessagingException.RemoteHandlerFailure - Exception in io.atomix.messaging

Exception indicating handler failure.

MessagingService - Interface in io.atomix.messaging

Interface for low level messaging primitives.

MessagingService.Builder - Class in io.atomix.messaging

Messaging service builder.

N

NoRemoteHandler() - Constructor for exception io.atomix.messaging.MessagingException.NoRemoteHandler

P

port() - Method in class io.atomix.messaging.Endpoint

ProtocolException() - Constructor for exception io.atomix.messaging.MessagingException.ProtocolException

R

registerHandler(String, BiConsumer<Endpoint, byte[]>, Executor) - Method in interface io.atomix.messaging.MessagingService

Registers a new message handler for message type.

registerHandler(String, BiFunction<Endpoint, byte[], byte[]>, Executor) - Method in interface io.atomix.messaging.MessagingService

Registers a new message handler for message type.

registerHandler(String, BiFunction<Endpoint, byte[], CompletableFuture<byte[]>>) - Method in interface io.atomix.messaging.MessagingService

Registers a new message handler for message type.

RemoteHandlerFailure() - Constructor for exception io.atomix.messaging.MessagingException.RemoteHandlerFailure

S

sendAndReceive(Endpoint, String, byte[]) - Method in interface io.atomix.messaging.MessagingService

Sends a message asynchronously and expects a response.

sendAndReceive(Endpoint, String, byte[], Executor) - Method in interface io.atomix.messaging.MessagingService

Sends a message synchronously and expects a response.

sendAsync(Endpoint, String, byte[]) - Method in interface io.atomix.messaging.MessagingService

Sends a message asynchronously to the specified communication end point.

T

toString() - Method in class io.atomix.messaging.Endpoint

U

unregisterHandler(String) - Method in interface io.atomix.messaging.MessagingService

Unregister current handler, if one exists for message type.

B E F H I M N P R S T U