Index (messaging 0.1.0-dev.16588.1.5e60f9f3aa7f API)

A B C D E F G H I K L M N O P R S T V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ACCEPTED - Enum constant in enum class dev.moonbridge.messaging.SendResult: The destination accepted the event into its bounded processing queue.

B

backend(String) - Static method in class dev.moonbridge.messaging.Endpoint
BACKEND_NAME_BYTES - Static variable in class dev.moonbridge.messaging.protocol.ControlHandshakeLimits
backendEpoch() - Method in class dev.moonbridge.messaging.session.ForwardedSessionProof.Claims
backendName() - Method in class dev.moonbridge.messaging.Endpoint: Returns null for the proxy endpoint.
backendName() - Method in class dev.moonbridge.messaging.session.ForwardedSessionProof.Claims
BACKPRESSURED - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
BACKPRESSURED - Enum constant in enum class dev.moonbridge.messaging.SendResult: The destination could not accept the event because a bounded queue was full.

C

channel() - Method in class dev.moonbridge.messaging.Message
channel(String) - Method in interface dev.moonbridge.messaging.Messaging: Gets a channel facade for an ASCII namespace:name channel.
close() - Method in class dev.moonbridge.messaging.internal.LocalMessaging
close() - Method in interface dev.moonbridge.messaging.Messaging
close() - Method in interface dev.moonbridge.messaging.Subscription
CLOSED - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
code() - Method in exception class dev.moonbridge.messaging.MessagingException
connectionId() - Method in class dev.moonbridge.messaging.session.ForwardedSessionProof.Claims
ControlHandshakeLimits - Class in dev.moonbridge.messaging.protocol: UTF-8 byte limits for the identity fields of a backend control-channel registration.
create(UUID, UUID, long, String, long, UUID, long, byte[]) - Static method in class dev.moonbridge.messaging.session.ForwardedSessionProof

D

decodeMessage(byte[]) - Static method in class dev.moonbridge.messaging.protocol.MessageCodec
decodeResponse(byte[]) - Static method in class dev.moonbridge.messaging.protocol.MessageCodec
DEFAULT_REQUEST_TIMEOUT - Static variable in class dev.moonbridge.messaging.internal.LocalMessaging
detail - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.Response
dev.moonbridge.messaging - package dev.moonbridge.messaging
dev.moonbridge.messaging.internal - package dev.moonbridge.messaging.internal
dev.moonbridge.messaging.protocol - package dev.moonbridge.messaging.protocol
dev.moonbridge.messaging.session - package dev.moonbridge.messaging.session

E

Endpoint - Class in dev.moonbridge.messaging: A logical messaging node.
equals(Object) - Method in class dev.moonbridge.messaging.Endpoint
error(long, MessagingException.Code, String) - Static method in class dev.moonbridge.messaging.protocol.MessageCodec
ERROR - Enum constant in enum class dev.moonbridge.messaging.protocol.MessageCodec.Response.Type
errorCode - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.Response
event(String, Endpoint, Endpoint, byte[]) - Static method in class dev.moonbridge.messaging.Message
EVENT - Enum constant in enum class dev.moonbridge.messaging.MessageKind
expiresAtEpochMillis() - Method in class dev.moonbridge.messaging.session.ForwardedSessionProof.Claims

F

FAILED - Enum constant in enum class dev.moonbridge.messaging.SendResult: Delivery failed for another reason; application execution may be unknown.
ForwardedSessionProof - Class in dev.moonbridge.messaging.session: Signed proof that a particular proxy session was forwarded to one backend.
ForwardedSessionProof.Claims - Class in dev.moonbridge.messaging.session

G

GAME_ADDRESS_BYTES - Static variable in class dev.moonbridge.messaging.protocol.ControlHandshakeLimits
GENERATION_BYTES - Static variable in class dev.moonbridge.messaging.protocol.ControlHandshakeLimits

H

handle(Message) - Method in interface dev.moonbridge.messaging.MessageHandler
HANDLER_FAILED - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
hashCode() - Method in class dev.moonbridge.messaging.Endpoint

I

id() - Method in class dev.moonbridge.messaging.Message
INSTANCE_ID_BYTES - Static variable in class dev.moonbridge.messaging.protocol.ControlHandshakeLimits
isProxy() - Method in class dev.moonbridge.messaging.Endpoint

K

KEY_ID_BYTES - Static variable in class dev.moonbridge.messaging.protocol.ControlHandshakeLimits
kind() - Method in class dev.moonbridge.messaging.Message

L

LocalMessaging - Class in dev.moonbridge.messaging.internal: Host-side scope registry and bounded local message dispatcher.
LocalMessaging(Endpoint, LocalMessaging.Outbound, Executor, ScheduledExecutorService) - Constructor for class dev.moonbridge.messaging.internal.LocalMessaging
LocalMessaging.Outbound - Interface in dev.moonbridge.messaging.internal: Host transport boundary.

M

MAX_CHANNEL_BYTES - Static variable in class dev.moonbridge.messaging.Message
MAX_FRAME_BYTES - Static variable in class dev.moonbridge.messaging.protocol.MessageCodec
MAX_IN_FLIGHT - Static variable in class dev.moonbridge.messaging.internal.LocalMessaging
MAX_LIFETIME_MILLIS - Static variable in class dev.moonbridge.messaging.session.ForwardedSessionProof
MAX_NODE_BYTES - Static variable in class dev.moonbridge.messaging.protocol.MessageCodec
MAX_PAYLOAD_BYTES - Static variable in class dev.moonbridge.messaging.Message
MAX_PUBLISH_RESULTS - Static variable in class dev.moonbridge.messaging.protocol.MessageCodec
MAX_REQUEST_TIMEOUT - Static variable in class dev.moonbridge.messaging.internal.LocalMessaging
MAX_TIMEOUT_MILLIS - Static variable in class dev.moonbridge.messaging.protocol.MessageCodec
message - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.IncomingMessage
message - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.Response
message(long, long, Message) - Static method in class dev.moonbridge.messaging.protocol.MessageCodec: Returns a message frame body (the transport adds the outer 4-byte length prefix).
Message - Class in dev.moonbridge.messaging: Immutable message envelope shared by the proxy and Java 8 backend clients.
Message(UUID, MessageKind, String, Endpoint, Endpoint, UUID, byte[]) - Constructor for class dev.moonbridge.messaging.Message: Creates a decoded message.
MESSAGE - Static variable in class dev.moonbridge.messaging.protocol.MessageCodec
MessageChannel - Interface in dev.moonbridge.messaging: Operations and subscriptions for one named application channel.
MessageCodec - Class in dev.moonbridge.messaging.protocol: Binary message frames shared by proxy-core and Java 8 backend clients.
MessageCodec.IncomingMessage - Class in dev.moonbridge.messaging.protocol: Decoded inbound message with its hop-local acknowledgement operation and deadline.
MessageCodec.Response - Class in dev.moonbridge.messaging.protocol: Decoded response.
MessageCodec.Response.Type - Enum Class in dev.moonbridge.messaging.protocol
MessageHandler - Interface in dev.moonbridge.messaging: Handles one request and asynchronously supplies its reply payload.
messageId() - Method in class dev.moonbridge.messaging.PublishResult
messageId() - Method in class dev.moonbridge.messaging.SendReceipt
MessageKind - Enum Class in dev.moonbridge.messaging: Transport-level message semantics, independent of the application payload.
Messaging - Interface in dev.moonbridge.messaging: Messaging facade owned by one plugin scope.
MessagingException - Exception Class in dev.moonbridge.messaging: A failure with a stable messaging-layer category.
MessagingException(MessagingException.Code, String) - Constructor for exception class dev.moonbridge.messaging.MessagingException
MessagingException(MessagingException.Code, String, Throwable) - Constructor for exception class dev.moonbridge.messaging.MessagingException
MessagingException.Code - Enum Class in dev.moonbridge.messaging
MIN_TIMEOUT_MILLIS - Static variable in class dev.moonbridge.messaging.protocol.MessageCodec

N

name() - Method in interface dev.moonbridge.messaging.MessageChannel
NO_HANDLER - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
NO_SUBSCRIBER - Enum constant in enum class dev.moonbridge.messaging.SendResult: The destination is reachable but has no local event subscriber for this channel.
nonce() - Method in class dev.moonbridge.messaging.session.ForwardedSessionProof.Claims
NOT_CONNECTED - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
NOT_CONNECTED - Enum constant in enum class dev.moonbridge.messaging.SendResult: The destination was not connected when routing was attempted.

O

onRequest(MessageHandler) - Method in interface dev.moonbridge.messaging.MessageChannel: Registers the single request handler for this channel on this node.
openScope(String) - Method in class dev.moonbridge.messaging.internal.LocalMessaging: Opens an exclusively named plugin scope using the host's default callback executor.
openScope(String, Executor) - Method in class dev.moonbridge.messaging.internal.LocalMessaging: Opens an exclusively named plugin scope using the supplied callback executor.
operationId - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.IncomingMessage
operationId - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.Response

P

payload() - Method in class dev.moonbridge.messaging.Message: Returns a defensive copy of the payload.
playerId() - Method in class dev.moonbridge.messaging.session.ForwardedSessionProof.Claims
PROPERTY_NAME - Static variable in class dev.moonbridge.messaging.session.ForwardedSessionProof
PROTOCOL_ERROR - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
proxy() - Static method in class dev.moonbridge.messaging.Endpoint
proxyEpoch() - Method in class dev.moonbridge.messaging.session.ForwardedSessionProof.Claims
publish(byte[]) - Method in interface dev.moonbridge.messaging.MessageChannel: Publishes one event to the current eligible online endpoints, including the publisher.
publish(Message) - Method in interface dev.moonbridge.messaging.internal.LocalMessaging.Outbound
PUBLISH - Enum constant in enum class dev.moonbridge.messaging.protocol.MessageCodec.Response.Type
published(long, PublishResult) - Static method in class dev.moonbridge.messaging.protocol.MessageCodec
publishResult - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.Response
PublishResult - Class in dev.moonbridge.messaging: Per-endpoint queue acceptance results for a single published event.
PublishResult(UUID, Map) - Constructor for class dev.moonbridge.messaging.PublishResult

R

receiveEvent(Message) - Method in class dev.moonbridge.messaging.internal.LocalMessaging: Enqueues an inbound event for each active local listener.
receiveRequest(Message, Duration) - Method in class dev.moonbridge.messaging.internal.LocalMessaging: Dispatches an inbound request and completes with its correlated reply.
REJECTED - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
REJECTED - Enum constant in enum class dev.moonbridge.messaging.SendResult: The destination or proxy rejected the event, for example due to policy or protocol validation.
reply(long, Message) - Static method in class dev.moonbridge.messaging.protocol.MessageCodec
reply(Message, Endpoint, byte[]) - Static method in class dev.moonbridge.messaging.Message
REPLY - Enum constant in enum class dev.moonbridge.messaging.MessageKind
REPLY - Enum constant in enum class dev.moonbridge.messaging.protocol.MessageCodec.Response.Type
replyTo() - Method in class dev.moonbridge.messaging.Message
request(Endpoint, byte[]) - Method in interface dev.moonbridge.messaging.MessageChannel: Sends a request to one endpoint and returns its correlated reply.
request(Endpoint, byte[], Duration) - Method in interface dev.moonbridge.messaging.MessageChannel: Sends a request to one endpoint and returns its correlated reply.
request(Message, Duration) - Method in interface dev.moonbridge.messaging.internal.LocalMessaging.Outbound
request(String, Endpoint, Endpoint, byte[]) - Static method in class dev.moonbridge.messaging.Message
REQUEST - Enum constant in enum class dev.moonbridge.messaging.MessageKind
RESPONSE - Static variable in class dev.moonbridge.messaging.protocol.MessageCodec
result() - Method in class dev.moonbridge.messaging.SendReceipt
results() - Method in class dev.moonbridge.messaging.PublishResult

S

send(Endpoint, byte[]) - Method in interface dev.moonbridge.messaging.MessageChannel: Sends a one-way event to one endpoint.
send(Message) - Method in interface dev.moonbridge.messaging.internal.LocalMessaging.Outbound
SEND - Enum constant in enum class dev.moonbridge.messaging.protocol.MessageCodec.Response.Type
SendReceipt - Class in dev.moonbridge.messaging: Message identity and target-side queue acceptance for a one-way send.
SendReceipt(UUID, SendResult) - Constructor for class dev.moonbridge.messaging.SendReceipt
sendResult - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.Response
sendResult(long, SendResult) - Static method in class dev.moonbridge.messaging.protocol.MessageCodec
SendResult - Enum Class in dev.moonbridge.messaging: Delivery status reported for one event destination.
source() - Method in class dev.moonbridge.messaging.Message
subscribe(Consumer) - Method in interface dev.moonbridge.messaging.MessageChannel: Adds a local listener for events.
Subscription - Interface in dev.moonbridge.messaging: Handle for one local listener or request handler.
subscriptions() - Method in class dev.moonbridge.messaging.internal.LocalMessaging: Returns a snapshot of channels and their current local subscription flags.

T

target() - Method in class dev.moonbridge.messaging.Message
TIMED_OUT - Enum constant in enum class dev.moonbridge.messaging.MessagingException.Code
TIMED_OUT - Enum constant in enum class dev.moonbridge.messaging.SendResult: No acceptance receipt arrived before the deadline; the event may still have been delivered.
timeoutMillis - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.IncomingMessage
toString() - Method in class dev.moonbridge.messaging.Endpoint
type - Variable in class dev.moonbridge.messaging.protocol.MessageCodec.Response

V

validateChannel(String) - Static method in class dev.moonbridge.messaging.Message
valueOf(String) - Static method in enum class dev.moonbridge.messaging.MessageKind: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class dev.moonbridge.messaging.MessagingException.Code: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class dev.moonbridge.messaging.protocol.MessageCodec.Response.Type: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class dev.moonbridge.messaging.SendResult: Returns the enum constant of this class with the specified name.
values() - Static method in enum class dev.moonbridge.messaging.MessageKind: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class dev.moonbridge.messaging.MessagingException.Code: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class dev.moonbridge.messaging.protocol.MessageCodec.Response.Type: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class dev.moonbridge.messaging.SendResult: Returns an array containing the constants of this enum class, in the order they are declared.
verify(String, byte[], String, UUID, long, UUID, long) - Static method in class dev.moonbridge.messaging.session.ForwardedSessionProof: Returns empty for malformed, expired, misrouted, or unauthenticated proofs.

A B C D E F G H I K L M N O P R S T V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form