Index

C D E H I M N O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values

C

channel(Destination) - Method in class com.iantapply.relay.core.ChannelRouter

Resolves the publication channel for a destination.

channelName() - Method in enum class com.iantapply.relay.core.RelayConfig.NodeRole

Returns the lower-case name used in transport channels.

ChannelRouter - Class in com.iantapply.relay.core

Maps logical destinations and node roles to namespaced transport channels.

ChannelRouter(String) - Constructor for class com.iantapply.relay.core.ChannelRouter

Creates a router for one Redis namespace.

close() - Method in class com.iantapply.relay.core.DefaultMessagingService

close() - Method in class com.iantapply.relay.core.InMemoryTransport

close() - Method in interface com.iantapply.relay.core.MessageTransport

Stops publication and reception and releases transport resources.

com.iantapply.relay.core - package com.iantapply.relay.core

Routing, envelope validation, dispatch, and transport contracts for Relay.

connected() - Method in class com.iantapply.relay.core.InMemoryTransport

connected() - Method in interface com.iantapply.relay.core.MessageTransport

Reports current transport connectivity.

contentType() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the contentType record component.

correlationId() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the correlationId record component.

createdAt() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the createdAt record component.

CURRENT_SCHEMA - Static variable in record class com.iantapply.relay.core.WireEnvelope

Current Relay envelope schema version.

D

decode(byte[], Instant) - Method in class com.iantapply.relay.core.EnvelopeCodec

Deserializes and validates an envelope relative to the supplied clock value.

DefaultMessagingService - Class in com.iantapply.relay.core

Default typed messaging implementation backed by a pluggable MessageTransport.

DefaultMessagingService(RelayConfig, MessageTransport, Logger) - Constructor for class com.iantapply.relay.core.DefaultMessagingService

Starts a messaging service and its transport subscriptions.

destination() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the destination record component.

dispatchQueueCapacity() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the dispatchQueueCapacity record component.

dispatchQueueDrops() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the dispatchQueueDrops record component.

dispatchQueueSize() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the dispatchQueueSize record component.

dispatchWorkers() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the dispatchWorkers record component.

E

encode(WireEnvelope) - Method in class com.iantapply.relay.core.EnvelopeCodec

Validates and serializes an envelope as UTF-8 JSON.

EnvelopeCodec - Class in com.iantapply.relay.core

Encodes, decodes, and validates Relay's JSON wire envelope.

EnvelopeCodec(int, Duration) - Constructor for class com.iantapply.relay.core.EnvelopeCodec

Creates an envelope codec with inbound and outbound limits.

equals(Object) - Method in record class com.iantapply.relay.core.RelayConfig

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class com.iantapply.relay.core.RelayMetrics

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class com.iantapply.relay.core.WireEnvelope

Indicates whether some other object is "equal to" this one.

H

handlerFailures() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the handlerFailures record component.

hashCode() - Method in record class com.iantapply.relay.core.RelayConfig

Returns a hash code value for this object.

hashCode() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns a hash code value for this object.

hashCode() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns a hash code value for this object.

headers() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the headers record component.

I

id() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the id record component.

InMemoryTransport - Class in com.iantapply.relay.core

Deterministic transport for contract tests and local embedding.

InMemoryTransport() - Constructor for class com.iantapply.relay.core.InMemoryTransport

Creates a disconnected in-memory transport.

M

MAXIMUM_HEADER_KEY_LENGTH - Static variable in class com.iantapply.relay.core.EnvelopeCodec

Maximum length of an application header name.

MAXIMUM_HEADER_VALUE_LENGTH - Static variable in class com.iantapply.relay.core.EnvelopeCodec

Maximum length of an application header value.

MAXIMUM_HEADERS - Static variable in class com.iantapply.relay.core.EnvelopeCodec

Maximum number of application headers accepted in one envelope.

maximumMessageAge() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the maximumMessageAge record component.

maximumPayloadBytes() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the maximumPayloadBytes record component.

messagesPublished() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the messagesPublished record component.

messagesReceived() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the messagesReceived record component.

messagesRejected() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the messagesRejected record component.

MessageTransport - Interface in com.iantapply.relay.core

Byte-oriented publish/subscribe transport used by Relay's typed messaging layer.

metrics() - Method in class com.iantapply.relay.core.DefaultMessagingService

Returns cumulative operational counters and current transport state.

N

namespace() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the namespace record component.

nodeId() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the nodeId record component.

O

origin() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the origin record component.

P

PAPER - Enum constant in enum class com.iantapply.relay.core.RelayConfig.NodeRole

Paper game server.

parse(String) - Static method in enum class com.iantapply.relay.core.RelayConfig.NodeRole

Parses a case-insensitive role name.

payload() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns a defensive copy of the encoded application payload.

publish(Topic, Destination, T) - Method in class com.iantapply.relay.core.DefaultMessagingService

publish(Topic, Destination, T, PublishOptions) - Method in class com.iantapply.relay.core.DefaultMessagingService

publish(String, byte[]) - Method in class com.iantapply.relay.core.InMemoryTransport

publish(String, byte[]) - Method in interface com.iantapply.relay.core.MessageTransport

Publishes bytes to one transport channel.

publisherConnected() - Method in interface com.iantapply.relay.core.MessageTransport

Reports publication-side connectivity.

publisherConnected() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the publisherConnected record component.

R

reconnects() - Method in class com.iantapply.relay.core.InMemoryTransport

reconnects() - Method in interface com.iantapply.relay.core.MessageTransport

Returns the number of successful subscriber reconnections.

redisConnected() - Method in record class com.iantapply.relay.core.RelayMetrics

Reports whether both Redis connection roles are healthy.

redisReconnects() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the redisReconnects record component.

redisUri() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the redisUri record component.

RelayConfig - Record Class in com.iantapply.relay.core

Validated runtime configuration shared by Relay's platform adapters and core.

RelayConfig(String, RelayConfig.NodeRole, URI, String, int, int, int, Duration) - Constructor for record class com.iantapply.relay.core.RelayConfig

Validates all runtime settings.

RelayConfig.NodeRole - Enum Class in com.iantapply.relay.core

Platform roles understood by Relay routing.

RelayConfigResolver - Class in com.iantapply.relay.core

Resolves platform-neutral Relay settings and Redis credential precedence.

RelayMetrics - Record Class in com.iantapply.relay.core

Cumulative messaging counters accompanied by current queue and Redis state.

RelayMetrics(long, long, long, long, long, long, int, boolean, boolean) - Constructor for record class com.iantapply.relay.core.RelayMetrics

Creates an instance of a RelayMetrics record class.

resolve(Map, Path, String, RelayConfig.NodeRole) - Static method in class com.iantapply.relay.core.RelayConfigResolver

Resolves a validated configuration from flattened dotted keys.

role() - Method in record class com.iantapply.relay.core.RelayConfig

Returns the value of the role record component.

S

schema() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the schema record component.

start(Collection, BiConsumer) - Method in class com.iantapply.relay.core.InMemoryTransport

start(Collection, BiConsumer) - Method in interface com.iantapply.relay.core.MessageTransport

Starts receiving messages from a fixed set of channels.

status() - Method in class com.iantapply.relay.core.DefaultMessagingService

subscribe(Topic, MessageHandler) - Method in class com.iantapply.relay.core.DefaultMessagingService

subscriberConnected() - Method in interface com.iantapply.relay.core.MessageTransport

Reports subscription-side connectivity.

subscriberConnected() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns the value of the subscriberConnected record component.

subscriptions(RelayConfig) - Method in class com.iantapply.relay.core.ChannelRouter

Returns the channels a node must consume for broadcasts, its platform, and its node ID.

T

topic() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns the value of the topic record component.

toString() - Method in record class com.iantapply.relay.core.RelayConfig

Returns a string representation of this record class.

toString() - Method in record class com.iantapply.relay.core.RelayMetrics

Returns a string representation of this record class.

toString() - Method in record class com.iantapply.relay.core.WireEnvelope

Returns a string representation of this record class.

V

valueOf(String) - Static method in enum class com.iantapply.relay.core.RelayConfig.NodeRole

Returns the enum constant of this class with the specified name.

values() - Static method in enum class com.iantapply.relay.core.RelayConfig.NodeRole

Returns an array containing the constants of this enum class, in the order they are declared.

VELOCITY - Enum constant in enum class com.iantapply.relay.core.RelayConfig.NodeRole

Velocity proxy.

W

WireEnvelope - Record Class in com.iantapply.relay.core

Transport-neutral representation of one encoded Relay message.

WireEnvelope(int, MessageId, String, String, Destination, Instant, String, MessageId, Map, byte[]) - Constructor for record class com.iantapply.relay.core.WireEnvelope

Creates an envelope and defensively copies mutable data.

C D E H I M N O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values