Index (AceMQ AMQP Parent 0.5.0-SNAPSHOT API)

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

A

absent() - Static method in class org.acemq.amqp.transport.QueueCheck
ABSENT - Enum constant in enum org.acemq.amqp.transport.QueueCheck.Result: No queue by that name.
accept() - Static method in class org.acemq.amqp.api.Ack: The message was handled successfully and must not be delivered again.
accept() - Method in interface org.acemq.amqp.transport.Acknowledger: Acknowledges the message so the broker discards it.
AceFatalException - Exception Class in org.acemq.amqp.api: Signals a failure that retrying cannot fix, such as a message that will never be valid for this handler.
AceFatalException(String) - Constructor for exception class org.acemq.amqp.api.AceFatalException
AceFatalException(String, Throwable) - Constructor for exception class org.acemq.amqp.api.AceFatalException
AceHeaders - Class in org.acemq.amqp.api: The message header names that make up the AceMQ cross-language contract.
AceMq - Class in org.acemq.amqp.core: The entry point: one connection to one broker, and the publishers and consumers built on it.
AceMqActuator - Class in org.acemq.amqp.actuator: Serves AceMQ's metrics, health and version over HTTP.
AceMqException - Exception Class in org.acemq.amqp.api: Base type for every exception this library raises.
AceMqException(String) - Constructor for exception class org.acemq.amqp.api.AceMqException
AceMqException(String, Throwable) - Constructor for exception class org.acemq.amqp.api.AceMqException
AceRetryableException - Exception Class in org.acemq.amqp.api: Signals a failure worth retrying: the message is sound but the attempt did not succeed, typically because a dependency was briefly unavailable.
AceRetryableException(String) - Constructor for exception class org.acemq.amqp.api.AceRetryableException
AceRetryableException(String, Throwable) - Constructor for exception class org.acemq.amqp.api.AceRetryableException
Ack - Class in org.acemq.amqp.api: What should happen to a delivery once a handler has looked at it.
AckAwareHandler<T> - Interface in org.acemq.amqp.api: Handles one message and states the outcome explicitly.
acknowledged() - Method in class org.acemq.amqp.core.ConsumerGroup
acknowledged() - Method in interface org.acemq.amqp.core.MessageConsumer
acknowledger() - Method in class org.acemq.amqp.transport.PulledMessage
Acknowledger - Interface in org.acemq.amqp.transport: Settles one delivery.
actions() - Method in class org.acemq.amqp.api.TopologyPlan
ActuatorOptions - Class in org.acemq.amqp.actuator: How an AceMqActuator is exposed.
ActuatorOptions.Builder - Class in org.acemq.amqp.actuator: Collects the settings.
add(String, SecretKey) - Method in class org.acemq.amqp.crypto.Keyring.Builder: Adds a key that can be read with but not written with.
add(OutboxRecord) - Method in interface org.acemq.amqp.api.OutboxStore: Writes a message into the outbox, inside the caller's transaction.
add(OutboxRecord) - Method in class org.acemq.amqp.patterns.JdbcOutboxStore
advance() - Method in class org.acemq.amqp.api.RoutingSlip
advance() - Method in class org.acemq.amqp.core.Itinerary
advanceTo(int) - Method in class org.acemq.amqp.api.RoutingSlip
afterConfirm(PublishContext, PublishResult) - Method in interface org.acemq.amqp.api.PublishInterceptor: Called once the broker has confirmed the message.
afterHandle(ConsumeContext, Ack) - Method in interface org.acemq.amqp.api.ConsumeInterceptor: Called after the handler returns or throws, before the delivery is settled.
age() - Method in class org.acemq.amqp.api.Envelope: Returns the age of the message, measured from its first publish.
allowDevelopmentCertificates() - Method in class org.acemq.amqp.security.Security: Permits certificates the development generator produced.
allowUnroutable() - Method in class org.acemq.amqp.core.PublishOptions: Stops treating an unroutable message as a failure.
allowUnroutable() - Method in class org.acemq.amqp.transport.OutboundMessage.Builder: Allows the broker to drop the message when nothing is bound to receive it.
ALREADY_CONFIRMED - Enum constant in enum org.acemq.amqp.api.IdempotencyStore.ClaimResult: The work is done; the delivery is a duplicate and may be acknowledged.
alwaysConfirmed() - Method in class org.acemq.amqp.core.PublishOptions: Confirms every publish and checks it for a return, even on a connection made withoutPublisherConfirms().
alwaysConfirmed() - Method in class org.acemq.amqp.transport.OutboundMessage: Whether this must be confirmed and checked for a return even on a connection made without publisher confirms.
alwaysConfirmed() - Method in class org.acemq.amqp.transport.OutboundMessage.Builder: Confirms this publish and checks it for a return even on a connection made without publisher confirms.
answered() - Method in class org.acemq.amqp.core.Responder: How many requests were answered, counted before each reply left.
application(String, String) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder: What the application calls itself, reported by /acemq-info.
applicationName() - Method in class org.acemq.amqp.actuator.ActuatorOptions
applicationVersion() - Method in class org.acemq.amqp.actuator.ActuatorOptions
apply(Topology, ApplyMode) - Method in class org.acemq.amqp.core.TopologyPlanner: Applies a topology in the requested mode.
ApplyMode - Enum in org.acemq.amqp.api: How much a topology apply is allowed to do.
arguments() - Method in class org.acemq.amqp.api.Topology.QueueSpec
as(String) - Method in class org.acemq.amqp.core.DefaultPublisher: The same destination, written in a named format.
as(Codec) - Method in class org.acemq.amqp.core.ConsumerOptions: Reads this queue with one named format instead of whatever arrives.
as(Codec) - Method in class org.acemq.amqp.core.DefaultPublisher: The same destination, written with a codec of the caller's own.
as(Codec) - Method in class org.acemq.amqp.core.StreamOptions
as(Codec) - Method in class org.acemq.amqp.core.StreamReader
asBytes() - Method in class org.acemq.amqp.core.DefaultPublisher
asJson() - Method in class org.acemq.amqp.core.DefaultPublisher
asText() - Method in class org.acemq.amqp.core.DefaultPublisher
asXml() - Method in class org.acemq.amqp.core.DefaultPublisher
asYaml() - Method in class org.acemq.amqp.core.DefaultPublisher
at(long) - Static method in class org.acemq.amqp.api.StreamOffset
at(String, String) - Static method in class org.acemq.amqp.core.Itinerary.Stop
at(String, String, String) - Static method in class org.acemq.amqp.core.Itinerary.Stop
at(Instant, String, String, Object) - Method in class org.acemq.amqp.patterns.Scheduler: Delivers a message at a moment.
attachToGlobalRegistry() - Method in class org.acemq.amqp.actuator.ActuatorOptions
attachToGlobalRegistry(boolean) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder: Whether a registry the actuator creates is added to Micrometer's global registry.
attempt() - Method in class org.acemq.amqp.api.Envelope
attempt() - Method in interface org.acemq.amqp.api.Message: Convenience accessor for the delivery attempt.
attempt(int) - Method in class org.acemq.amqp.api.Envelope.Builder
ATTEMPT - Static variable in class org.acemq.amqp.api.AceHeaders: Delivery attempt counter, starting at 1 and incremented by the retry engine.
attempts() - Method in class org.acemq.amqp.api.OutboxRecord
authority() - Method in class org.acemq.amqp.security.dev.DevelopmentCertificates.Result
autoDetect(String) - Static method in class org.acemq.amqp.core.Telemetries
AvroCodec - Class in org.acemq.amqp.codec.avro: Reads and writes Avro.

B

beforeHandle(ConsumeContext) - Method in interface org.acemq.amqp.api.ConsumeInterceptor: Called after the payload is decoded and before the handler runs.
beforePublish(PublishContext) - Method in interface org.acemq.amqp.api.PublishInterceptor: Called before the payload is encoded, with whatever the previous interceptor returned.
bind(String, String, String) - Method in class org.acemq.amqp.api.Topology.Builder
bind(String, String, String) - Method in class org.acemq.amqp.core.AceMq: Binds a queue to an exchange.
bindAddress() - Method in class org.acemq.amqp.actuator.ActuatorOptions
bindAddress(String) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder: The interface to listen on.
bindings() - Method in class org.acemq.amqp.api.Topology
bindQueue(String, String, String) - Method in interface org.acemq.amqp.transport.TransportConnection: Binds a queue to an exchange.
block(String, String) - Static method in class org.acemq.amqp.test.InMemoryTransport: Makes a named broker refuse publishes, the way a real one does under a memory or disk alarm.
blockedReason() - Method in class org.acemq.amqp.core.AceMq
blockedReason() - Method in interface org.acemq.amqp.transport.TransportConnection
blockedTimeout() - Method in class org.acemq.amqp.transport.ConnectionConfig
blockedTimeout(Duration) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder: How long a publish waits for a blocked broker to resume before it is refused.
body() - Method in class org.acemq.amqp.transport.InboundDelivery
body() - Method in class org.acemq.amqp.transport.OutboundMessage
body(byte[]) - Static method in class org.acemq.amqp.transport.OutboundMessage
body(byte[]) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
broker() - Method in class org.acemq.amqp.security.dev.DevelopmentCertificates.Result
brokerRungs() - Method in class org.acemq.amqp.api.RetryPolicy: The delays this policy needs a rung queue for, in the order the schedule reaches them.
brokerWaitThreshold() - Method in class org.acemq.amqp.api.RetryPolicy
build() - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder
build() - Method in class org.acemq.amqp.api.Envelope.Builder
build() - Method in class org.acemq.amqp.api.Topology.Builder
build() - Method in class org.acemq.amqp.core.PipelineBuilder: Declares the topology and starts a consumer group per step.
build() - Method in class org.acemq.amqp.crypto.Keyring.Builder
build() - Method in class org.acemq.amqp.patterns.Saga.Builder
build() - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
build() - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
builder() - Static method in class org.acemq.amqp.actuator.ActuatorOptions
builder() - Static method in interface org.acemq.amqp.crypto.Keyring
Builder() - Constructor for class org.acemq.amqp.api.Envelope.Builder
Builder() - Constructor for class org.acemq.amqp.api.Topology.Builder
Builder() - Constructor for class org.acemq.amqp.transport.ConnectionConfig.Builder
Builder() - Constructor for class org.acemq.amqp.transport.OutboundMessage.Builder
BuiltInCodecProviders - Class in org.acemq.amqp.core: The two formats that need no library, announced to the registry.
BuiltInCodecProviders.Bytes - Class in org.acemq.amqp.core: Announces BytesCodec as bytes.
BuiltInCodecProviders.Text - Class in org.acemq.amqp.core: Announces StringCodec as text.
byName(String) - Static method in class org.acemq.amqp.core.Codecs: string is accepted as another name for text, which stays the canonical one: it is what the .NET and Ruby libraries call the same codec, and a name copied from one of them should not fail here.
Bytes() - Constructor for class org.acemq.amqp.core.BuiltInCodecProviders.Bytes
BytesCodec - Class in org.acemq.amqp.core: Passes bytes through untouched.
BytesCodec() - Constructor for class org.acemq.amqp.core.BytesCodec

C

cancel() - Method in interface org.acemq.amqp.transport.Subscription: Stops delivery without waiting for anything in flight.
canDecode(String) - Method in interface org.acemq.amqp.api.Codec
canDecode(String) - Method in class org.acemq.amqp.codec.avro.AvroCodec
canDecode(String) - Method in class org.acemq.amqp.codec.json.JsonCodec
canDecode(String) - Method in class org.acemq.amqp.codec.protobuf.ProtobufCodec
canDecode(String) - Method in class org.acemq.amqp.codec.toml.TomlCodec
canDecode(String) - Method in class org.acemq.amqp.codec.xml.XmlCodec
canDecode(String) - Method in class org.acemq.amqp.codec.yaml.YamlCodec
canDecode(String) - Method in class org.acemq.amqp.core.BytesCodec
canDecode(String) - Method in class org.acemq.amqp.core.CompositeCodec
canDecode(String) - Method in class org.acemq.amqp.core.StringCodec
canDecode(String) - Method in class org.acemq.amqp.crypto.EncryptedCodec
canDecode(String) - Method in class org.acemq.amqp.patterns.ClaimCheckCodec
capabilities() - Method in class org.acemq.amqp.core.AceMq: Reports what the connected broker supports.
capabilities() - Method in class org.acemq.amqp.test.InMemoryTransport
capabilities() - Method in class org.acemq.amqp.transport.rabbitmq.RabbitMqTransport
capabilities() - Method in interface org.acemq.amqp.transport.Transport
Capability - Enum in org.acemq.amqp.api: A feature a broker either supports or does not.
CAUSATION - Static variable in class org.acemq.amqp.api.AceHeaders: Identifier of the message that caused this one to be published.
causationId() - Method in class org.acemq.amqp.api.Envelope
causationId() - Method in class org.acemq.amqp.api.OutboxRecord
causationId(String) - Method in class org.acemq.amqp.api.Envelope.Builder
causing(String) - Method in class org.acemq.amqp.api.Envelope: Returns a builder for a message caused by this one.
CertsMojo - Class in org.acemq.amqp.security.dev: Writes throwaway TLS certificates for local development.
CertsMojo() - Constructor for class org.acemq.amqp.security.dev.CertsMojo
changes() - Method in class org.acemq.amqp.api.TopologyPlan
Changing the partition count is not free - Search tag in class org.acemq.amqp.api.Partitioning: Section
checkQueue(String, QueueType, boolean, Map<String, Object>) - Method in interface org.acemq.amqp.transport.TransportConnection: Asks whether a queue that already exists would accept this declaration.
Choosing a format - Search tag in class org.acemq.amqp.core.DefaultPublisher: Section
claim() - Method in class org.acemq.amqp.api.Envelope: Where the payload is, when the application stores it outside the message.
claim(String) - Method in class org.acemq.amqp.api.Envelope.Builder
claim(String) - Method in interface org.acemq.amqp.api.IdempotencyStore: Takes ownership of a message identifier, if nobody else has it.
claim(String) - Method in class org.acemq.amqp.patterns.InMemoryIdempotencyStore
claim(String) - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore
CLAIM - Static variable in class org.acemq.amqp.api.AceHeaders: Where the payload is, when the application stores it outside the message.
claimBatch(int, Duration) - Method in interface org.acemq.amqp.api.OutboxStore: Takes a batch of unpublished messages for this relay to work on.
claimBatch(int, Duration) - Method in class org.acemq.amqp.patterns.JdbcOutboxStore
ClaimCheckCodec - Class in org.acemq.amqp.patterns: Keeps large payloads off the broker.
ClaimCheckStore - Interface in org.acemq.amqp.api: Where a payload too large for a broker actually goes.
CLAIMED - Enum constant in enum org.acemq.amqp.api.IdempotencyStore.ClaimResult: The caller owns the identifier and should do the work.
CLASSIC - Enum constant in enum org.acemq.amqp.transport.QueueType: A single-node queue.
classicQueue(String, Map<String, Object>) - Method in class org.acemq.amqp.api.Topology.Builder
classicQueueWithDeadLetter(String, Map<String, Object>) - Method in class org.acemq.amqp.api.Topology.Builder: A classic queue that dead-letters, with arguments of its own.
clear() - Method in class org.acemq.amqp.patterns.InMemoryClaimCheckStore: Empties the store, which is what a test between cases wants.
client() - Method in class org.acemq.amqp.security.dev.DevelopmentCertificates.Result
clientName() - Method in class org.acemq.amqp.transport.ConnectionConfig
clientName(String) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
close() - Method in class org.acemq.amqp.actuator.AceMqActuator: Stops the server and releases the port.
close() - Method in interface org.acemq.amqp.api.Publisher
close() - Method in interface org.acemq.amqp.api.Telemetry.Scope
close() - Method in class org.acemq.amqp.core.AceMq
close() - Method in class org.acemq.amqp.core.ConsumerGroup
close() - Method in class org.acemq.amqp.core.DefaultPublisher
close() - Method in interface org.acemq.amqp.core.MessageConsumer: Stops consuming, letting in-flight deliveries settle.
close() - Method in class org.acemq.amqp.core.OrderedQueue
close() - Method in class org.acemq.amqp.core.Pipeline
close() - Method in class org.acemq.amqp.core.Requester
close() - Method in class org.acemq.amqp.core.Responder
close() - Method in interface org.acemq.amqp.core.StreamConsumer
close() - Method in class org.acemq.amqp.patterns.OutboxRelay
close() - Method in class org.acemq.amqp.patterns.Scheduler
close() - Method in interface org.acemq.amqp.transport.Subscription: Stops delivery and releases broker resources.
close() - Method in interface org.acemq.amqp.transport.TransportConnection: Closes the connection, letting in-flight deliveries settle first.
close(Duration) - Method in class org.acemq.amqp.core.AceMq: Closes the connection, giving everything still working at most budget in total.
codec() - Method in class org.acemq.amqp.core.ConsumerOptions
codec() - Method in class org.acemq.amqp.core.DefaultPublisher
codec() - Method in class org.acemq.amqp.core.StreamOptions
Codec - Interface in org.acemq.amqp.api: Turns payloads into bytes and back.
CodecProvider - Interface in org.acemq.amqp.api: Announces a codec to the engine, so that a format can be chosen by name.
codecs() - Method in class org.acemq.amqp.core.CompositeCodec
Codecs - Class in org.acemq.amqp.core: Finds the codecs on the classpath and names the ones used by default.
compensated() - Method in class org.acemq.amqp.patterns.SagaResult
compensateWith(Consumer<T>) - Method in class org.acemq.amqp.patterns.Saga.Builder: Gives the most recently added step something that undoes it.
completed() - Method in class org.acemq.amqp.core.Pipeline
completed() - Method in class org.acemq.amqp.patterns.SagaResult
completedAt() - Method in class org.acemq.amqp.core.Itinerary.Stop
composite(Telemetry...) - Static method in class org.acemq.amqp.core.Telemetries: Combines several sinks into one.
CompositeCodec - Class in org.acemq.amqp.core: Writes in one format and reads several.
concurrency(int) - Method in class org.acemq.amqp.core.ConsumerGroupBuilder
concurrency(int) - Method in class org.acemq.amqp.core.PipelineBuilder
confirm(String) - Method in interface org.acemq.amqp.api.IdempotencyStore: Records that the work for a claimed identifier completed.
confirm(String) - Method in class org.acemq.amqp.patterns.InMemoryIdempotencyStore
confirm(String) - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore
confirmed(Duration) - Static method in class org.acemq.amqp.transport.ConfirmResult: The broker took responsibility for the message and something was bound to receive it.
ConfirmResult - Class in org.acemq.amqp.transport: The broker's answer to one publish.
confirmTimeout() - Method in class org.acemq.amqp.transport.ConnectionConfig
confirmTimeout(Duration) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
connect(String) - Static method in class org.acemq.amqp.core.AceMq: Connects to a broker, choosing the transport from the URL scheme.
connect(String, Telemetry) - Static method in class org.acemq.amqp.core.AceMq: Connects to a broker with an explicit telemetry sink.
connect(String, Telemetry, Codec) - Static method in class org.acemq.amqp.core.AceMq: Connects to a broker with an explicit telemetry sink and codec.
connect(String, Codec) - Static method in class org.acemq.amqp.core.AceMq: Connects to a broker, reading and writing payloads with the given codec.
connect(ConnectionConfig) - Static method in class org.acemq.amqp.core.AceMq: Connects to a broker with explicit settings.
connect(ConnectionConfig) - Method in class org.acemq.amqp.test.InMemoryTransport
connect(ConnectionConfig) - Method in class org.acemq.amqp.transport.rabbitmq.RabbitMqTransport
connect(ConnectionConfig) - Method in interface org.acemq.amqp.transport.Transport: Opens a connection.
connect(ConnectionConfig, Telemetry) - Static method in class org.acemq.amqp.core.AceMq: Connects with an explicit telemetry sink.
connect(ConnectionConfig, Telemetry, Codec) - Static method in class org.acemq.amqp.core.AceMq: Connects with an explicit telemetry sink and codec.
connection() - Method in class org.acemq.amqp.actuator.ActuatorOptions
connection(AceMq) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder: The connection /acemq-health reports on and /acemq-info describes.
ConnectionBlockedException - Exception Class in org.acemq.amqp.transport: The broker has stopped accepting publishes, and waiting for it to resume ran out of time.
ConnectionBlockedException(String, String) - Constructor for exception class org.acemq.amqp.transport.ConnectionBlockedException: Nothing was sent: the connection was already known to be blocked.
ConnectionBlockedException(String, String, boolean) - Constructor for exception class org.acemq.amqp.transport.ConnectionBlockedException
ConnectionConfig - Class in org.acemq.amqp.transport: Everything a transport needs in order to open a connection.
ConnectionConfig.Builder - Class in org.acemq.amqp.transport: Builds ConnectionConfig instances.
ConnectionSupplier - Interface in org.acemq.amqp.patterns: Hands back the JDBC connection the calling code is already using for its own work.
connectionTimeout() - Method in class org.acemq.amqp.transport.ConnectionConfig
connectionTimeout(Duration) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
CONSISTENT_HASH_ROUTING - Enum constant in enum org.acemq.amqp.api.Capability: Routing that distributes keys deterministically across queues.
consume(String, Class<T>, MessageHandler<T>) - Method in class org.acemq.amqp.core.AceMq: Starts consuming a queue.
consume(String, Class<T>, ConsumerOptions, MessageHandler<T>) - Method in class org.acemq.amqp.core.AceMq: Starts consuming a queue with explicit options.
consume(MessageHandler<T>) - Method in class org.acemq.amqp.core.OrderedQueue: Starts one consumer per partition.
consume(MessageHandler<T>) - Method in class org.acemq.amqp.core.StreamReader: Starts reading.
CONSUME_ATTEMPTS - Static variable in class org.acemq.amqp.api.MetricNames: Which attempt a delivery was, so a rising distribution shows a struggling dependency.
CONSUME_DURATION - Static variable in class org.acemq.amqp.api.MetricNames: Time spent in a handler, tagged with the outcome.
CONSUME_IN_FLIGHT - Static variable in class org.acemq.amqp.api.MetricNames: Deliveries currently in a handler, bounded by prefetch times concurrency.
CONSUME_TOTAL - Static variable in class org.acemq.amqp.api.MetricNames: Deliveries handled, tagged with the outcome.
ConsumeContext - Class in org.acemq.amqp.api: A message about to be handled, as an interceptor sees it.
ConsumeContext(String, Message<?>) - Constructor for class org.acemq.amqp.api.ConsumeContext
consumeGroup(String, Class<T>, MessageHandler<T>) - Method in class org.acemq.amqp.core.AceMq: Consumes a queue with several consumers, resizable while the application runs.
ConsumeInterceptor - Interface in org.acemq.amqp.api: Runs around every handler on a connection.
ConsumerGroup - Class in org.acemq.amqp.core: Several consumers on one queue, resized while the application runs.
ConsumerGroupBuilder<T> - Class in org.acemq.amqp.core: Says how many consumers to run and how much each may hold, and then starts them.
ConsumerOptions - Class in org.acemq.amqp.core: How a consumer should behave.
consumeStarted(String, Envelope) - Method in interface org.acemq.amqp.api.Telemetry: Called immediately before a handler runs.
CONTENT_TYPE - Static variable in class org.acemq.amqp.crypto.EncryptedCodec: Deliberately not ...+json, whatever the plaintext underneath is.
contentType() - Method in interface org.acemq.amqp.api.Codec
contentType() - Method in interface org.acemq.amqp.api.Message
contentType() - Method in class org.acemq.amqp.codec.avro.AvroCodec
contentType() - Method in class org.acemq.amqp.codec.json.JsonCodec
contentType() - Method in class org.acemq.amqp.codec.protobuf.ProtobufCodec
contentType() - Method in class org.acemq.amqp.codec.toml.TomlCodec
contentType() - Method in class org.acemq.amqp.codec.xml.XmlCodec
contentType() - Method in class org.acemq.amqp.codec.yaml.YamlCodec
contentType() - Method in class org.acemq.amqp.core.BytesCodec
contentType() - Method in class org.acemq.amqp.core.CompositeCodec
contentType() - Method in class org.acemq.amqp.core.StringCodec
contentType() - Method in class org.acemq.amqp.crypto.EncryptedCodec
contentType() - Method in class org.acemq.amqp.patterns.ClaimCheckCodec
contentType() - Method in class org.acemq.amqp.transport.InboundDelivery
contentType() - Method in class org.acemq.amqp.transport.OutboundMessage
contentType(String) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
CORRELATION - Static variable in class org.acemq.amqp.api.AceHeaders: Business correlation identifier, propagated unchanged across hops.
correlationId() - Method in class org.acemq.amqp.api.Envelope
correlationId() - Method in class org.acemq.amqp.api.OutboxRecord
correlationId(String) - Method in class org.acemq.amqp.api.Envelope.Builder
create() - Method in interface org.acemq.amqp.api.CodecProvider
create() - Method in class org.acemq.amqp.codec.json.JsonCodecProvider
create() - Method in class org.acemq.amqp.codec.toml.TomlCodecProvider
create() - Method in class org.acemq.amqp.codec.xml.XmlCodecProvider
create() - Method in class org.acemq.amqp.codec.yaml.YamlCodecProvider
create() - Method in class org.acemq.amqp.core.BuiltInCodecProviders.Bytes
create() - Method in class org.acemq.amqp.core.BuiltInCodecProviders.Text
CREATE - Enum constant in enum org.acemq.amqp.api.TopologyPlan.Kind: The item is missing and would be created.
CREATE_ONLY - Enum constant in enum org.acemq.amqp.api.ApplyMode: Create what is missing and leave everything else alone.
createdAt() - Method in class org.acemq.amqp.api.OutboxRecord
createSchemaIfAbsent() - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore: Creates the table if it is not already there.
createSchemaIfAbsent() - Method in class org.acemq.amqp.patterns.JdbcOutboxStore: Creates the outbox table if it is not already there.
createSchemaIfAbsent() - Method in class org.acemq.amqp.patterns.JdbcSchemaRegistry: Creates the table if it is not already there.
credentials() - Method in class org.acemq.amqp.security.Security
credentials(String, String) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
Credentials - Class in org.acemq.amqp.security: A username and a secret.
CredentialsProvider - Interface in org.acemq.amqp.security: Supplies the credentials to connect with, every time a connection is made.
current() - Method in class org.acemq.amqp.api.RoutingSlip
current() - Method in interface org.acemq.amqp.crypto.Keyring
current() - Method in class org.acemq.amqp.crypto.Keyring.StaticKeyring
current(String, SecretKey) - Method in class org.acemq.amqp.crypto.Keyring.Builder: Adds a key and makes it the one to write with.

D

DEAD_LETTER_EXCHANGE - Static variable in class org.acemq.amqp.api.Topology: The exchange a queue's dead letters are reached through.
DEAD_LETTER_EXCHANGE_ARGUMENT - Static variable in class org.acemq.amqp.api.Topology: Where the broker sends a message this queue rejects or lets expire.
DEAD_LETTER_NATIVE - Enum constant in enum org.acemq.amqp.api.Capability: Native dead-letter routing configured on the queue.
DEAD_LETTER_ROUTING_KEY_ARGUMENT - Static variable in class org.acemq.amqp.api.Topology: What routing key it is sent under, which a direct exchange matches against its bindings.
DEAD_LETTERED_TOTAL - Static variable in class org.acemq.amqp.api.MetricNames: Messages sent to a dead-letter or parking queue, tagged with MetricNames.TAG_OUTCOME.
deadLetter(String) - Static method in class org.acemq.amqp.api.Ack: The message can never be handled by this consumer, so it goes straight to the dead-letter queue without consuming retry attempts.
deadLettered() - Method in interface org.acemq.amqp.core.MessageConsumer
declare() - Method in class org.acemq.amqp.core.OrderedQueueBuilder: Creates the exchange, the partition queues and the bindings.
declareExchange(String, String) - Method in class org.acemq.amqp.core.AceMq: Declares a durable exchange.
declareExchange(String, String, boolean) - Method in interface org.acemq.amqp.transport.TransportConnection: Declares an exchange, or verifies that an equivalent one exists.
declareQueue(String) - Method in class org.acemq.amqp.core.AceMq: Declares a durable quorum queue.
declareQueue(String, QueueType, boolean, Map<String, Object>) - Method in interface org.acemq.amqp.transport.TransportConnection: Declares a queue, or verifies that an equivalent one exists.
declareQueue(String, QueueType, Map<String, Object>) - Method in class org.acemq.amqp.core.AceMq: Declares a queue of a specific type.
declareStream(String, Duration, Long) - Method in class org.acemq.amqp.core.AceMq: Declares a stream: an append-only log that keeps messages until retention removes them.
declareStream(String, Duration, Long, Long) - Method in class org.acemq.amqp.core.AceMq: Declares a stream, saying how large each file on disk gets.
decode(byte[], Class<T>) - Method in interface org.acemq.amqp.api.Codec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.codec.avro.AvroCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.codec.json.JsonCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.codec.protobuf.ProtobufCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.codec.toml.TomlCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.codec.xml.XmlCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.codec.yaml.YamlCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.core.BytesCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.core.CompositeCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.core.StringCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.crypto.EncryptedCodec
decode(byte[], Class<T>) - Method in class org.acemq.amqp.patterns.ClaimCheckCodec
decode(byte[], Class<T>, String) - Method in interface org.acemq.amqp.api.Codec: Decodes a received message, told what the sender said it was.
decode(byte[], Class<T>, String) - Method in class org.acemq.amqp.codec.avro.AvroCodec
decode(byte[], Class<T>, String) - Method in class org.acemq.amqp.core.CompositeCodec
DEFAULT_BROKER_WAIT_THRESHOLD - Static variable in class org.acemq.amqp.api.RetryPolicy: Waits this long or longer are spent in the broker rather than in the consumer.
DEFAULT_FORMAT - Static variable in class org.acemq.amqp.core.Codecs: The format published in unless the application says otherwise.
DEFAULT_HEALTH_PATH - Static variable in class org.acemq.amqp.actuator.ActuatorOptions: Connection health, as JSON.
DEFAULT_INFO_PATH - Static variable in class org.acemq.amqp.actuator.ActuatorOptions: Library version, application version and transport capabilities, as JSON.
DEFAULT_KEYSTORE_PASSWORD - Static variable in class org.acemq.amqp.security.Security: What Security.fromKeystore(java.nio.file.Path) assumes when nothing says otherwise, and what acemq-security-dev writes.
DEFAULT_METRICS_PATH - Static variable in class org.acemq.amqp.actuator.ActuatorOptions: Prometheus text format.
DEFAULT_PORT - Static variable in class org.acemq.amqp.actuator.ActuatorOptions: The OpenTelemetry convention for a Prometheus endpoint, and what Go and .NET use.
DEFAULT_THRESHOLD - Static variable in class org.acemq.amqp.patterns.ClaimCheckCodec: Below this, payloads travel inline.
defaultMapper() - Static method in class org.acemq.amqp.codec.json.JsonCodec
defaultMapper() - Static method in class org.acemq.amqp.codec.toml.TomlCodec
defaultMapper() - Static method in class org.acemq.amqp.codec.xml.XmlCodec
defaultMapper() - Static method in class org.acemq.amqp.codec.yaml.YamlCodec
DefaultPublisher<T> - Class in org.acemq.amqp.core: Publishes to one destination, waiting for the broker to confirm every message.
defaults() - Static method in class org.acemq.amqp.core.ConsumerOptions
defaults() - Static method in class org.acemq.amqp.core.PublishOptions
defaults() - Static method in class org.acemq.amqp.core.StreamOptions
define() - Static method in class org.acemq.amqp.api.Topology
definition() - Method in class org.acemq.amqp.api.SchemaDefinition
definitionOf(Schema) - Static method in class org.acemq.amqp.codec.avro.AvroCodec
delay() - Method in class org.acemq.amqp.api.Ack
delay() - Method in class org.acemq.amqp.api.RetryPolicy.Wait
DELAYED_DELIVERY - Enum constant in enum org.acemq.amqp.api.Capability: Delivery deferred until a requested time, without occupying a consumer.
delegate() - Method in class org.acemq.amqp.crypto.EncryptedCodec
delegate() - Method in class org.acemq.amqp.patterns.ClaimCheckCodec
delete(String) - Method in interface org.acemq.amqp.api.ClaimCheckStore: Removes a payload.
delete(String) - Method in class org.acemq.amqp.patterns.FilesystemClaimCheckStore
delete(String) - Method in class org.acemq.amqp.patterns.InMemoryClaimCheckStore
deleteQueue(String) - Method in class org.acemq.amqp.core.AceMq: Removes a queue and its contents.
deleteQueue(String) - Method in interface org.acemq.amqp.transport.TransportConnection: Removes a queue and everything in it.
delivered() - Method in class org.acemq.amqp.patterns.Scheduler
delivery() - Method in class org.acemq.amqp.transport.PulledMessage
DeliveryListener - Interface in org.acemq.amqp.transport: Receives deliveries from a subscription.
describedAs(String) - Method in class org.acemq.amqp.core.PipelineBuilder: Describes the most recently declared step, for the humans reading the logs.
description() - Method in class org.acemq.amqp.api.TopologyPlan.Action
detail() - Method in class org.acemq.amqp.transport.ConfirmResult
detail() - Method in class org.acemq.amqp.transport.QueueCheck
DEVELOPMENT_MARKER - Static variable in class org.acemq.amqp.security.Security: Subject the development certificate generator stamps, so this library can refuse it.
DevelopmentCertificates - Class in org.acemq.amqp.security.dev: Generates a throwaway certificate authority and the certificates a local broker and client need, so that running with TLS on a developer's machine is one command rather than an afternoon with openssl.
DevelopmentCertificates() - Constructor for class org.acemq.amqp.security.dev.DevelopmentCertificates
DevelopmentCertificates.Result - Class in org.acemq.amqp.security.dev: What DevelopmentCertificates.generate(java.nio.file.Path, java.lang.String, char[], java.time.Duration) wrote.
differs(String) - Static method in class org.acemq.amqp.transport.QueueCheck
DIFFERS - Enum constant in enum org.acemq.amqp.transport.QueueCheck.Result: There, with settings that cannot be changed in place.
directory() - Method in class org.acemq.amqp.security.dev.DevelopmentCertificates.Result
disabled() - Static method in class org.acemq.amqp.security.Security
DISABLED - Enum constant in enum org.acemq.amqp.security.Security.Mode: No encryption at all.
done() - Method in class org.acemq.amqp.core.Itinerary
drain() - Method in class org.acemq.amqp.patterns.OutboxRelay: Publishes everything currently waiting, in batches.
drain(Duration) - Method in class org.acemq.amqp.core.ConsumerGroup: Stops every member, letting them finish what they hold.
drain(Duration) - Method in interface org.acemq.amqp.core.MessageConsumer: Stops taking new messages and waits for the ones in hand to finish.
drainConsumers(Duration) - Method in class org.acemq.amqp.core.AceMq: Stops every consumer taking new work and waits for what is in hand.
drainOnce() - Method in class org.acemq.amqp.patterns.OutboxRelay: Claims one batch and publishes it.
drainTimeout(Duration) - Method in class org.acemq.amqp.core.ConsumerGroup
drift() - Method in class org.acemq.amqp.api.TopologyPlan
DRIFT - Enum constant in enum org.acemq.amqp.api.TopologyPlan.Kind: The item exists with settings the topology disagrees with.
DRY_RUN - Enum constant in enum org.acemq.amqp.api.ApplyMode: Work out the plan and change nothing.
duplicates() - Method in interface org.acemq.amqp.core.MessageConsumer
durable() - Method in class org.acemq.amqp.api.Topology.ExchangeSpec
durable() - Method in class org.acemq.amqp.api.Topology.QueueSpec

E

empty() - Static method in class org.acemq.amqp.core.Itinerary
encode(Object) - Method in interface org.acemq.amqp.api.Codec
encode(Object) - Method in class org.acemq.amqp.codec.avro.AvroCodec
encode(Object) - Method in class org.acemq.amqp.codec.json.JsonCodec
encode(Object) - Method in class org.acemq.amqp.codec.protobuf.ProtobufCodec
encode(Object) - Method in class org.acemq.amqp.codec.toml.TomlCodec
encode(Object) - Method in class org.acemq.amqp.codec.xml.XmlCodec
encode(Object) - Method in class org.acemq.amqp.codec.yaml.YamlCodec
encode(Object) - Method in class org.acemq.amqp.core.BytesCodec
encode(Object) - Method in class org.acemq.amqp.core.CompositeCodec
encode(Object) - Method in class org.acemq.amqp.core.StringCodec
encode(Object) - Method in class org.acemq.amqp.crypto.EncryptedCodec
encode(Object) - Method in class org.acemq.amqp.patterns.ClaimCheckCodec
encodedAs(Codec) - Method in class org.acemq.amqp.core.PipelineBuilder: Publishes the most recent step's output in a named format.
EncryptedCodec - Class in org.acemq.amqp.crypto: Encrypts whatever another codec produced, so the broker holds ciphertext.
EncryptionKey - Class in org.acemq.amqp.crypto: A key and the name messages will refer to it by.
EncryptionKey(String, SecretKey) - Constructor for class org.acemq.amqp.crypto.EncryptionKey
endedEarly() - Method in class org.acemq.amqp.core.Pipeline
entered() - Method in class org.acemq.amqp.core.Pipeline
entryType() - Method in class org.acemq.amqp.core.Pipeline
envelope() - Method in class org.acemq.amqp.api.ConsumeContext
envelope() - Method in interface org.acemq.amqp.api.Message
envelope() - Method in class org.acemq.amqp.api.OutboxRecord: Rebuilds the envelope this record should be published with.
envelope() - Method in class org.acemq.amqp.api.PublishContext
Envelope - Class in org.acemq.amqp.api: The AceMQ metadata that travels with every message, independent of payload and broker.
Envelope.Builder - Class in org.acemq.amqp.api: Builds Envelope instances.
equals(Object) - Method in class org.acemq.amqp.core.Itinerary
equals(Object) - Method in class org.acemq.amqp.core.Itinerary.Stop
equals(Object) - Method in class org.acemq.amqp.api.Envelope
equals(Object) - Method in class org.acemq.amqp.api.OutboxRecord
equals(Object) - Method in class org.acemq.amqp.api.SchemaDefinition
equals(Object) - Method in class org.acemq.amqp.api.StreamOffset
equals(Object) - Method in class org.acemq.amqp.crypto.EncryptionKey
error() - Method in class org.acemq.amqp.api.Envelope: Why this message was dead-lettered or parked.
error(String) - Method in class org.acemq.amqp.api.Envelope.Builder
ERROR - Static variable in class org.acemq.amqp.api.AceHeaders: Why a message was dead-lettered.
evictions() - Method in class org.acemq.amqp.patterns.InMemoryIdempotencyStore
exchange() - Method in class org.acemq.amqp.api.OutboxRecord
exchange() - Method in class org.acemq.amqp.api.PublishContext
exchange() - Method in class org.acemq.amqp.api.Topology.BindingSpec
exchange() - Method in class org.acemq.amqp.core.Itinerary.Stop
exchange() - Method in class org.acemq.amqp.transport.InboundDelivery
exchange() - Method in class org.acemq.amqp.transport.OutboundMessage
exchange(String) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
exchange(String, String) - Method in class org.acemq.amqp.api.Topology.Builder
EXCHANGE_ROUTING - Enum constant in enum org.acemq.amqp.api.Capability: Publish to an exchange that routes to queues, rather than directly to a node.
exchanges() - Method in class org.acemq.amqp.api.Topology
execute() - Method in class org.acemq.amqp.security.dev.CertsMojo
expiration() - Method in class org.acemq.amqp.core.PublishOptions
expiration() - Method in class org.acemq.amqp.transport.OutboundMessage: How long the message stays worth delivering.
expiration(Duration) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder: Asks the broker to discard the message if it is still undelivered after this long.
expiringAfter(Duration) - Method in class org.acemq.amqp.core.PublishOptions: Discards the message if it has not been consumed within the given time.
expiry() - Method in class org.acemq.amqp.security.dev.DevelopmentCertificates.Result
exponential(int, Duration, double, Duration) - Static method in class org.acemq.amqp.api.RetryPolicy: Retries with an exponentially growing delay and an explicit multiplier.
exponential(int, Duration, Duration) - Static method in class org.acemq.amqp.api.RetryPolicy: Retries with a doubling delay, capped.

F

failed() - Method in class org.acemq.amqp.core.OrderedQueue
failed() - Method in interface org.acemq.amqp.core.StreamConsumer
failed() - Method in class org.acemq.amqp.patterns.OutboxRelay
failed(Throwable) - Method in interface org.acemq.amqp.api.Telemetry.Scope: Records that the operation threw.
failed(Duration, String) - Static method in class org.acemq.amqp.transport.ConfirmResult: The broker refused the message or never answered.
failedAt() - Method in class org.acemq.amqp.patterns.SagaResult
failure() - Method in exception class org.acemq.amqp.core.ResponderFailedException
failure() - Method in class org.acemq.amqp.patterns.SagaResult
Failure - Search tag in interface org.acemq.amqp.api.ConsumeInterceptor: Section
Failure - Search tag in interface org.acemq.amqp.api.PublishInterceptor: Section
FilesystemClaimCheckStore - Class in org.acemq.amqp.patterns: A claim-check store on a filesystem.
FilesystemClaimCheckStore(Path) - Constructor for class org.acemq.amqp.patterns.FilesystemClaimCheckStore
fingerprint() - Method in class org.acemq.amqp.api.SchemaDefinition
first() - Static method in class org.acemq.amqp.api.StreamOffset
FIRST_SEEN - Static variable in class org.acemq.amqp.api.AceHeaders: Epoch milliseconds of the first publish, used for age-based give-up.
firstSeen() - Method in class org.acemq.amqp.api.Envelope
firstSeen(Instant) - Method in class org.acemq.amqp.api.Envelope.Builder
fixed(int, Duration) - Static method in class org.acemq.amqp.api.RetryPolicy: Retries a fixed number of times with the same delay between each, with no jitter.
FIXED_CONTENT_TYPE - Static variable in class org.acemq.amqp.codec.avro.AvroCodec: Content type for a codec whose schema is fixed at construction.
forConsuming() - Static method in class org.acemq.amqp.core.Codecs: Every codec on the classpath, in the order they should be tried.
format() - Method in class org.acemq.amqp.api.SchemaDefinition
forOneDay() - Static method in class org.acemq.amqp.patterns.InMemoryIdempotencyStore
forPublishing() - Static method in class org.acemq.amqp.core.Codecs
from() - Method in class org.acemq.amqp.core.Replay
from(Instant) - Static method in class org.acemq.amqp.api.StreamOffset
from(Instant) - Method in class org.acemq.amqp.core.StreamOptions
from(Instant) - Method in class org.acemq.amqp.core.StreamReader
from(Map<String, Object>) - Static method in class org.acemq.amqp.api.RoutingSlip: Reads a slip off a message's headers.
from(Map<String, Object>) - Static method in class org.acemq.amqp.core.Itinerary: Reads an itinerary off a message's headers.
from(StreamOffset) - Method in class org.acemq.amqp.core.StreamReader
fromBase64(String) - Static method in class org.acemq.amqp.crypto.Keys: The usual way a key arrives from a secret store or an environment variable.
fromBytes(byte[]) - Static method in class org.acemq.amqp.crypto.Keys
fromEnvironment(String, String) - Static method in interface org.acemq.amqp.security.CredentialsProvider: Credentials from environment variables, re-read each time.
fromFile(Path) - Static method in interface org.acemq.amqp.security.CredentialsProvider: Credentials from a properties file, re-read each time.
fromFirst() - Method in class org.acemq.amqp.core.StreamOptions
fromFirst() - Method in class org.acemq.amqp.core.StreamReader
fromKeystore(Path) - Static method in class org.acemq.amqp.security.Security: TLS using the keystores in a directory, as written by the development generator or by your own tooling: keystore.p12 for this client, truststore.p12 for the certificates it will accept.
fromLast() - Method in class org.acemq.amqp.core.StreamOptions
fromLast() - Method in class org.acemq.amqp.core.StreamReader
fromLast(Duration) - Method in class org.acemq.amqp.core.StreamOptions
fromLast(Duration) - Method in class org.acemq.amqp.core.StreamReader
fromNext() - Method in class org.acemq.amqp.core.StreamOptions
fromNext() - Method in class org.acemq.amqp.core.StreamReader
fromOffset(long) - Method in class org.acemq.amqp.core.StreamOptions
fromOffset(long) - Method in class org.acemq.amqp.core.StreamReader

G

generate() - Static method in class org.acemq.amqp.crypto.Keys
generate(Path, String, char[], Duration) - Method in class org.acemq.amqp.security.dev.DevelopmentCertificates: Writes a CA, a broker certificate, a client certificate and the two keystores AceMQ reads.
get() - Method in interface org.acemq.amqp.patterns.ConnectionSupplier
get() - Method in interface org.acemq.amqp.security.CredentialsProvider
get(String) - Method in interface org.acemq.amqp.api.ClaimCheckStore: Redeems a claim check.
get(String) - Method in class org.acemq.amqp.patterns.FilesystemClaimCheckStore
get(String) - Method in class org.acemq.amqp.patterns.InMemoryClaimCheckStore
giveUpAfter(Duration) - Method in class org.acemq.amqp.api.RetryPolicy: Returns a copy that abandons messages older than the given age.

H

haltedPartitions() - Method in class org.acemq.amqp.core.OrderedQueue
handle(Message<I>) - Method in interface org.acemq.amqp.api.Step
handle(Message<T>) - Method in interface org.acemq.amqp.api.AckAwareHandler
handle(Message<T>) - Method in interface org.acemq.amqp.api.MessageHandler
handled() - Method in class org.acemq.amqp.core.OrderedQueue
handled() - Method in interface org.acemq.amqp.core.StreamConsumer
hasChanges() - Method in class org.acemq.amqp.api.TopologyPlan
hasDrift() - Method in class org.acemq.amqp.api.TopologyPlan
hash(String) - Static method in class org.acemq.amqp.api.Partitioning
hashCode() - Method in class org.acemq.amqp.api.Envelope
hashCode() - Method in class org.acemq.amqp.api.OutboxRecord
hashCode() - Method in class org.acemq.amqp.api.SchemaDefinition
hashCode() - Method in class org.acemq.amqp.api.StreamOffset
hashCode() - Method in class org.acemq.amqp.core.Itinerary
hashCode() - Method in class org.acemq.amqp.core.Itinerary.Stop
hashCode() - Method in class org.acemq.amqp.crypto.EncryptionKey
hasUnresolved() - Method in class org.acemq.amqp.patterns.SagaResult
header(String, Object) - Method in class org.acemq.amqp.api.Envelope.Builder: Adds one application header.
header(String, Object) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
HEADER - Static variable in class org.acemq.amqp.core.Itinerary: The header the itinerary travels in: acemq-routing-slip.
headers() - Method in class org.acemq.amqp.api.Envelope
headers() - Method in interface org.acemq.amqp.api.Message
headers() - Method in class org.acemq.amqp.transport.InboundDelivery
headers() - Method in class org.acemq.amqp.transport.OutboundMessage
headers(Map<String, Object>) - Method in class org.acemq.amqp.api.Envelope.Builder
headers(Map<String, Object>) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
HEADERS_ROUTING - Enum constant in enum org.acemq.amqp.api.Capability: Routing decided by message headers rather than by routing key.
healthPath() - Method in class org.acemq.amqp.actuator.ActuatorOptions
healthPath(String) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder
hops() - Method in class org.acemq.amqp.patterns.Scheduler

I

id() - Method in class org.acemq.amqp.api.Envelope
id() - Method in class org.acemq.amqp.api.OutboxRecord
id() - Method in class org.acemq.amqp.crypto.EncryptionKey
id(String) - Method in class org.acemq.amqp.api.Envelope.Builder
ID - Static variable in class org.acemq.amqp.api.AceHeaders: Unique message identifier, and the default idempotency key.
idempotencyStore() - Method in class org.acemq.amqp.core.ConsumerOptions
IdempotencyStore - Interface in org.acemq.amqp.api: Remembers which messages have already been handled, so handling one twice does not happen twice.
IdempotencyStore.ClaimResult - Enum in org.acemq.amqp.api: What IdempotencyStore.tryClaim(java.lang.String) found.
idempotent(IdempotencyStore) - Method in class org.acemq.amqp.core.ConsumerOptions: Handles each message at most once, by remembering which have been handled.
idempotent(IdempotencyStore) - Method in class org.acemq.amqp.core.PipelineBuilder: Handles each message at most once at the most recently declared step.
idFor(SchemaDefinition) - Method in interface org.acemq.amqp.api.SchemaRegistry
idFor(SchemaDefinition) - Method in class org.acemq.amqp.codec.avro.InMemorySchemaRegistry
idFor(SchemaDefinition) - Method in class org.acemq.amqp.patterns.JdbcSchemaRegistry
in(Duration, String, String, Object) - Method in class org.acemq.amqp.patterns.Scheduler: Delivers a message after a delay.
IN_PROGRESS - Enum constant in enum org.acemq.amqp.api.IdempotencyStore.ClaimResult: Someone holds a live claim and has not confirmed it.
InboundDelivery - Class in org.acemq.amqp.transport: A message handed up from the broker, still encoded.
InboundDelivery(String, String, String, byte[], Map<String, Object>, String, String, boolean) - Constructor for class org.acemq.amqp.transport.InboundDelivery
InboundDelivery(String, String, String, byte[], Map<String, Object>, String, String, boolean, String) - Constructor for class org.acemq.amqp.transport.InboundDelivery
inFlight() - Method in class org.acemq.amqp.core.AceMq
inFlight() - Method in class org.acemq.amqp.core.ConsumerGroup
inFlight() - Method in interface org.acemq.amqp.core.MessageConsumer
inFlight() - Method in class org.acemq.amqp.core.Pipeline
infoPath() - Method in class org.acemq.amqp.actuator.ActuatorOptions
infoPath(String) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder
InMemoryClaimCheckStore - Class in org.acemq.amqp.patterns: A claim-check store in a map, for tests.
InMemoryClaimCheckStore() - Constructor for class org.acemq.amqp.patterns.InMemoryClaimCheckStore
InMemoryIdempotencyStore - Class in org.acemq.amqp.patterns: An idempotency store held in this process's memory, bounded by size and age.
InMemoryIdempotencyStore(Duration) - Constructor for class org.acemq.amqp.patterns.InMemoryIdempotencyStore
InMemoryIdempotencyStore(Duration, int) - Constructor for class org.acemq.amqp.patterns.InMemoryIdempotencyStore
InMemoryIdempotencyStore(Duration, int, Duration) - Constructor for class org.acemq.amqp.patterns.InMemoryIdempotencyStore
InMemorySchemaRegistry - Class in org.acemq.amqp.codec.avro: A registry held in this process's memory.
InMemorySchemaRegistry() - Constructor for class org.acemq.amqp.codec.avro.InMemorySchemaRegistry
InMemoryTransport - Class in org.acemq.amqp.test: A transport that runs entirely in the process, for tests that should not need Docker.
InMemoryTransport() - Constructor for class org.acemq.amqp.test.InMemoryTransport
insecure() - Static method in class org.acemq.amqp.security.Security: TLS with no verification at all.
INSECURE - Enum constant in enum org.acemq.amqp.security.Security.Mode: Encrypt and verify nothing.
intercept(ConsumeInterceptor) - Method in class org.acemq.amqp.core.AceMq: Runs something around every handler on this connection.
intercept(PublishInterceptor) - Method in class org.acemq.amqp.core.AceMq: Runs something around every publish on this connection.
isAccept() - Method in class org.acemq.amqp.api.Ack
isAceHeader(String) - Static method in class org.acemq.amqp.api.AceHeaders: Reports whether a header name belongs to AceMQ.
isActive() - Method in interface org.acemq.amqp.transport.Subscription
isAlwaysConfirmed() - Method in class org.acemq.amqp.core.PublishOptions
isBlocked() - Method in class org.acemq.amqp.core.AceMq: Whether the broker is currently refusing publishes.
isBlocked() - Method in interface org.acemq.amqp.transport.TransportConnection: Whether the broker is currently refusing publishes.
isComplete() - Method in class org.acemq.amqp.patterns.SagaResult
isConfirmed() - Method in class org.acemq.amqp.transport.ConfirmResult
isConfirmed(String) - Method in interface org.acemq.amqp.api.IdempotencyStore
isConfirmed(String) - Method in class org.acemq.amqp.patterns.InMemoryIdempotencyStore
isConfirmed(String) - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore
isConsumingPaused() - Method in class org.acemq.amqp.core.AceMq
isDeadLetter() - Method in class org.acemq.amqp.api.Ack
isFinished() - Method in class org.acemq.amqp.api.RoutingSlip
isFinished() - Method in class org.acemq.amqp.core.Itinerary
isFirstAttempt() - Method in interface org.acemq.amqp.api.Message: Reports whether this is the first time the message has been delivered.
isInBroker() - Method in class org.acemq.amqp.api.RetryPolicy.Wait
isOpen() - Method in class org.acemq.amqp.core.AceMq
isOpen() - Method in interface org.acemq.amqp.transport.TransportConnection
isPaused() - Method in interface org.acemq.amqp.core.MessageConsumer
isPublishingPaused() - Method in class org.acemq.amqp.core.AceMq
isRelease() - Method in class org.acemq.amqp.api.Ack
isRequeueOnFailure() - Method in class org.acemq.amqp.core.ConsumerOptions
isRetry() - Method in class org.acemq.amqp.api.Ack
isRouted() - Method in class org.acemq.amqp.transport.ConfirmResult
isRunning() - Method in interface org.acemq.amqp.core.MessageConsumer
isRunning() - Method in class org.acemq.amqp.core.Responder
isRunning() - Method in interface org.acemq.amqp.core.StreamConsumer
isRunning() - Method in class org.acemq.amqp.patterns.OutboxRelay
Itinerary - Class in org.acemq.amqp.core: An itinerary a message carries with it, naming every stop rather than every step.
Itinerary.Stop - Class in org.acemq.amqp.core: One stop on an itinerary.

J

JdbcIdempotencyStore - Class in org.acemq.amqp.patterns: An idempotency store in a database table, shared by every consumer that points at it.
JdbcIdempotencyStore(DataSource) - Constructor for class org.acemq.amqp.patterns.JdbcIdempotencyStore
JdbcIdempotencyStore(DataSource, Duration, Duration, String) - Constructor for class org.acemq.amqp.patterns.JdbcIdempotencyStore
JdbcOutboxStore - Class in org.acemq.amqp.patterns: An outbox kept in a relational table, in the same database as the work it accompanies.
JdbcOutboxStore(ConnectionSupplier, DataSource) - Constructor for class org.acemq.amqp.patterns.JdbcOutboxStore
JdbcOutboxStore(ConnectionSupplier, DataSource, String, int) - Constructor for class org.acemq.amqp.patterns.JdbcOutboxStore
JdbcSchemaRegistry - Class in org.acemq.amqp.patterns: A schema registry in a database table.
JdbcSchemaRegistry(DataSource) - Constructor for class org.acemq.amqp.patterns.JdbcSchemaRegistry
JdbcSchemaRegistry(DataSource, String) - Constructor for class org.acemq.amqp.patterns.JdbcSchemaRegistry
jitterFactor() - Method in class org.acemq.amqp.api.RetryPolicy
JsonCodec - Class in org.acemq.amqp.codec.json: Reads and writes JSON, using Jackson.
JsonCodec() - Constructor for class org.acemq.amqp.codec.json.JsonCodec: Uses a mapper configured as described above.
JsonCodec(ObjectMapper) - Constructor for class org.acemq.amqp.codec.json.JsonCodec
JsonCodecProvider - Class in org.acemq.amqp.codec.json: Announces JsonCodec to the engine as json.
JsonCodecProvider() - Constructor for class org.acemq.amqp.codec.json.JsonCodecProvider

K

keepingAttempts() - Method in class org.acemq.amqp.core.Replay: Returns a replay that leaves each message's attempt counter exactly as it was.
key() - Method in class org.acemq.amqp.crypto.EncryptionKey
keyedBy(Function<T, String>) - Method in class org.acemq.amqp.core.OrderedQueueBuilder
keyFor(String) - Method in interface org.acemq.amqp.crypto.Keyring
keyFor(String) - Method in class org.acemq.amqp.crypto.Keyring.StaticKeyring
keyIdOf(byte[]) - Static method in class org.acemq.amqp.crypto.EncryptedCodec: Reads which key a message needs, without needing the key.
keyOf(byte[]) - Static method in class org.acemq.amqp.patterns.ClaimCheckCodec: Reads the key a message refers to, without fetching it.
Keyring - Interface in org.acemq.amqp.crypto: The keys a service can write with and the keys it can read with.
Keyring.Builder - Class in org.acemq.amqp.crypto: Collects keys for a Keyring that does not change while the process runs.
Keyring.StaticKeyring - Class in org.acemq.amqp.crypto: A keyring over a fixed map.
Keys - Class in org.acemq.amqp.crypto: Getting an AES key from the shapes one usually arrives in.
keystorePassword(String) - Method in class org.acemq.amqp.security.Security
kind() - Method in class org.acemq.amqp.api.TopologyPlan.Action

L

last() - Static method in class org.acemq.amqp.api.StreamOffset
lastError() - Method in class org.acemq.amqp.api.OutboxRecord
lastHandledOffset() - Method in interface org.acemq.amqp.core.StreamConsumer
lastly(Duration) - Static method in class org.acemq.amqp.api.StreamOffset
latency() - Method in class org.acemq.amqp.api.PublishResult
latency() - Method in class org.acemq.amqp.transport.ConfirmResult

M

mandatory() - Method in class org.acemq.amqp.core.PublishOptions
mandatory() - Method in class org.acemq.amqp.transport.OutboundMessage
MARKER - Static variable in class org.acemq.amqp.security.dev.DevelopmentCertificates: Written into every subject, and refused by the library unless explicitly allowed.
markFailed(String, String) - Method in interface org.acemq.amqp.api.OutboxStore: Records that an attempt failed, so the message is tried again later.
markFailed(String, String) - Method in class org.acemq.amqp.patterns.JdbcOutboxStore
markPublished(String) - Method in interface org.acemq.amqp.api.OutboxStore: Records that a claimed message reached the broker and needs no further attention.
markPublished(String) - Method in class org.acemq.amqp.patterns.JdbcOutboxStore
matches() - Static method in class org.acemq.amqp.transport.QueueCheck
MATCHES - Enum constant in enum org.acemq.amqp.transport.QueueCheck.Result: The queue is there and would accept the declaration unchanged.
maxAttempts() - Method in class org.acemq.amqp.api.RetryPolicy
maxMessageAge() - Method in class org.acemq.amqp.api.RetryPolicy
maxOutstandingPublishes() - Method in class org.acemq.amqp.transport.ConnectionConfig: How many publishes may be waiting for a confirm at once.
maxOutstandingPublishes(int) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
mayHaveBeenPublished() - Method in exception class org.acemq.amqp.transport.ConnectionBlockedException: Whether this message might already be at the broker.
message() - Method in class org.acemq.amqp.api.ConsumeContext
Message<T> - Interface in org.acemq.amqp.api: A message as a handler sees it: the decoded payload plus everything known about how it arrived.
MessageConsumer - Interface in org.acemq.amqp.core: A running consumer.
messageCount(String) - Method in class org.acemq.amqp.core.AceMq: Counts the messages waiting in a queue.
messageCount(String) - Method in interface org.acemq.amqp.transport.TransportConnection: Counts the messages waiting in a queue.
messageDeadLettered(String, Envelope, String) - Method in interface org.acemq.amqp.api.Telemetry: Records that a message was given up on.
MessageHandler<T> - Interface in org.acemq.amqp.api: Handles one message.
messageId() - Method in class org.acemq.amqp.api.PublishResult
messageId() - Method in class org.acemq.amqp.transport.InboundDelivery
messageId() - Method in class org.acemq.amqp.transport.OutboundMessage
messageId(String) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
messageParked(String, Envelope, String) - Method in interface org.acemq.amqp.api.Telemetry: Records that a message was put in the parking lot because nothing could read it.
messageRetried(String, Envelope, Duration) - Method in interface org.acemq.amqp.api.Telemetry: Records that a message was sent for another attempt.
MetricNames - Class in org.acemq.amqp.api: The metric and span names AceMQ emits.
metrics() - Method in class org.acemq.amqp.actuator.AceMqActuator
metricsPath() - Method in class org.acemq.amqp.actuator.ActuatorOptions
metricsPath(String) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder: Where the metrics are served.
MicrometerSupport - Class in org.acemq.amqp.core: Creates the Micrometer sink, in a class of its own.
mode() - Method in class org.acemq.amqp.security.Security

N

name() - Method in interface org.acemq.amqp.api.CodecProvider
name() - Method in class org.acemq.amqp.api.Topology.ExchangeSpec
name() - Method in class org.acemq.amqp.api.Topology.QueueSpec
name() - Method in class org.acemq.amqp.codec.json.JsonCodecProvider
name() - Method in class org.acemq.amqp.codec.toml.TomlCodecProvider
name() - Method in class org.acemq.amqp.codec.xml.XmlCodecProvider
name() - Method in class org.acemq.amqp.codec.yaml.YamlCodecProvider
name() - Method in class org.acemq.amqp.core.BuiltInCodecProviders.Bytes
name() - Method in class org.acemq.amqp.core.BuiltInCodecProviders.Text
name() - Method in class org.acemq.amqp.core.Itinerary.Stop
name() - Method in class org.acemq.amqp.core.OrderedQueue
name() - Method in class org.acemq.amqp.core.Pipeline
name() - Method in class org.acemq.amqp.test.InMemoryTransport
name() - Method in class org.acemq.amqp.transport.rabbitmq.RabbitMqTransport
name() - Method in interface org.acemq.amqp.transport.Transport
named(String) - Static method in class org.acemq.amqp.patterns.Saga
names() - Static method in class org.acemq.amqp.core.Codecs
next() - Method in class org.acemq.amqp.api.RoutingSlip
next() - Static method in class org.acemq.amqp.api.StreamOffset
next() - Method in class org.acemq.amqp.core.Itinerary
nextAttempt() - Method in class org.acemq.amqp.api.Envelope: Returns a copy of this envelope representing the next delivery attempt.
nextDelay(int, Duration) - Method in class org.acemq.amqp.api.RetryPolicy: How long to wait before the next attempt.
nextWait(int, Duration) - Method in class org.acemq.amqp.api.RetryPolicy: How long to wait before the next attempt, and where the message spends it.
none() - Static method in class org.acemq.amqp.api.RetryPolicy: A policy that never retries: one attempt, then the dead-letter queue.
NONE - Static variable in interface org.acemq.amqp.api.Telemetry: A telemetry sink that records nothing.
NONE - Static variable in interface org.acemq.amqp.api.Telemetry.Scope: A scope that records nothing.

O

of(Parser<T>) - Static method in class org.acemq.amqp.codec.protobuf.ProtobufCodec
of(Class<? extends SpecificRecord>) - Static method in class org.acemq.amqp.codec.avro.AvroCodec
of(Class<T>) - Static method in class org.acemq.amqp.codec.protobuf.ProtobufCodec: The same thing, given the class instead of its parser.
of(String) - Static method in class org.acemq.amqp.api.Envelope: Starts a new envelope for the given logical message type.
of(String, String) - Static method in class org.acemq.amqp.security.Credentials
of(String, String) - Static method in interface org.acemq.amqp.security.CredentialsProvider: Fixed credentials.
of(String, String, Envelope, String) - Static method in class org.acemq.amqp.api.OutboxRecord: A new record for a message that has not been attempted yet.
of(String, SecretKey) - Static method in interface org.acemq.amqp.crypto.Keyring
of(List<TopologyPlan.Action>) - Static method in class org.acemq.amqp.api.TopologyPlan
of(Codec...) - Static method in class org.acemq.amqp.core.CompositeCodec
of(TopologyPlan.Kind, String) - Static method in class org.acemq.amqp.api.TopologyPlan.Action
of(Itinerary.Stop...) - Static method in class org.acemq.amqp.core.Itinerary
of(Schema) - Static method in class org.acemq.amqp.codec.avro.AvroCodec
offset() - Method in class org.acemq.amqp.core.StreamOptions
on(AceMq) - Static method in class org.acemq.amqp.patterns.Scheduler
onDelivery(InboundDelivery, Acknowledger) - Method in interface org.acemq.amqp.transport.DeliveryListener
onError(ConsumeContext, Throwable) - Method in interface org.acemq.amqp.api.ConsumeInterceptor: Called when the handler threw, before ConsumeInterceptor.afterHandle(org.acemq.amqp.api.ConsumeContext, org.acemq.amqp.api.Ack).
onError(PublishContext, Throwable) - Method in interface org.acemq.amqp.api.PublishInterceptor: Called when a publish fails, including when another interceptor refused it.
onFailure() - Method in class org.acemq.amqp.core.StreamOptions
onFailure(OrderedQueue.OnFailure) - Method in class org.acemq.amqp.core.OrderedQueueBuilder
onFailure(OrderedQueue.OnFailure, int, Duration) - Method in class org.acemq.amqp.core.OrderedQueueBuilder
Only when it is worth it - Search tag in class org.acemq.amqp.patterns.ClaimCheckCodec: Section
OpenTelemetrySupport - Class in org.acemq.amqp.core: Creates the OpenTelemetry sink, in a class of its own.
options() - Method in class org.acemq.amqp.core.DefaultPublisher
options(ConsumerOptions) - Method in class org.acemq.amqp.core.ConsumerGroupBuilder
order() - Method in interface org.acemq.amqp.api.CodecProvider: Where this codec sits when several could read the same message.
order() - Method in interface org.acemq.amqp.api.ConsumeInterceptor
order() - Method in interface org.acemq.amqp.api.PublishInterceptor
order() - Method in class org.acemq.amqp.codec.json.JsonCodecProvider
order() - Method in class org.acemq.amqp.codec.toml.TomlCodecProvider
order() - Method in class org.acemq.amqp.codec.xml.XmlCodecProvider
order() - Method in class org.acemq.amqp.codec.yaml.YamlCodecProvider
order() - Method in class org.acemq.amqp.core.BuiltInCodecProviders.Bytes
order() - Method in class org.acemq.amqp.core.BuiltInCodecProviders.Text
ordered(String, Class<T>) - Method in class org.acemq.amqp.core.AceMq: A queue where messages sharing a key are handled in the order they were sent.
OrderedQueue<T> - Class in org.acemq.amqp.core: Messages that share a key are handled in the order they were sent.
OrderedQueue.OnFailure - Enum in org.acemq.amqp.core: What happens when a handler fails.
OrderedQueueBuilder<T> - Class in org.acemq.amqp.core: Says how a stream of messages is partitioned, and then declares it.
org.acemq.amqp.actuator - package org.acemq.amqp.actuator: A scrape surface for an application that has no HTTP server of its own.
org.acemq.amqp.api - package org.acemq.amqp.api: The public AceMQ AMQP API.
org.acemq.amqp.codec.avro - package org.acemq.amqp.codec.avro
org.acemq.amqp.codec.json - package org.acemq.amqp.codec.json
org.acemq.amqp.codec.protobuf - package org.acemq.amqp.codec.protobuf
org.acemq.amqp.codec.toml - package org.acemq.amqp.codec.toml: TOML payloads, for messages a person edits and a machine consumes.
org.acemq.amqp.codec.xml - package org.acemq.amqp.codec.xml
org.acemq.amqp.codec.yaml - package org.acemq.amqp.codec.yaml
org.acemq.amqp.core - package org.acemq.amqp.core: The protocol-agnostic engine.
org.acemq.amqp.crypto - package org.acemq.amqp.crypto: Payload encryption, for messages the broker itself should not be able to read.
org.acemq.amqp.patterns - package org.acemq.amqp.patterns: Distributed messaging patterns as things you configure rather than reimplement.
org.acemq.amqp.security - package org.acemq.amqp.security: How a connection is protected, and where its credentials come from.
org.acemq.amqp.security.dev - package org.acemq.amqp.security.dev
org.acemq.amqp.test - package org.acemq.amqp.test: Testing support for applications and for AceMQ itself.
org.acemq.amqp.transport - package org.acemq.amqp.transport: The contract a broker binding must satisfy.
org.acemq.amqp.transport.rabbitmq - package org.acemq.amqp.transport.rabbitmq: AMQP 0-9-1 transport backed by the RabbitMQ Java client.
origin() - Method in class org.acemq.amqp.api.Envelope
origin(String) - Method in class org.acemq.amqp.api.Envelope.Builder
ORIGIN - Static variable in class org.acemq.amqp.api.AceHeaders: Identifier of the publishing process, conventionally service@host.
OutboundMessage - Class in org.acemq.amqp.transport: A message on its way to the broker, already encoded.
OutboundMessage.Builder - Class in org.acemq.amqp.transport: Builds OutboundMessage instances.
OUTBOX_LAG - Static variable in class org.acemq.amqp.api.MetricNames: How long an outbox record waited between being committed and being published.
OUTBOX_TOTAL - Static variable in class org.acemq.amqp.api.MetricNames: Outbox records the relay has handled, tagged with MetricNames.TAG_OUTCOME.
outboxFailed(String, String, String) - Method in interface org.acemq.amqp.api.Telemetry: Called by the outbox relay when a record could not be published.
outboxPublished(String, String, Duration) - Method in interface org.acemq.amqp.api.Telemetry: Called by the outbox relay when a record reaches the broker.
OutboxRecord - Class in org.acemq.amqp.api: One message waiting in the outbox: where it is going, what it says, and how it has fared.
OutboxRecord(String, String, String, String, String, String, String, Instant, int, String) - Constructor for class org.acemq.amqp.api.OutboxRecord: Full constructor, used when reading a record back out of storage.
OutboxRelay - Class in org.acemq.amqp.patterns: Moves messages out of the outbox and into the broker.
OutboxRelay(AceMq, OutboxStore) - Constructor for class org.acemq.amqp.patterns.OutboxRelay
OutboxRelay(AceMq, OutboxStore, int, Duration, Duration) - Constructor for class org.acemq.amqp.patterns.OutboxRelay
OutboxStore - Interface in org.acemq.amqp.api: Holds messages that must be published if, and only if, the work that produced them was committed.
outcome(String) - Method in interface org.acemq.amqp.api.Telemetry.Scope: Records how the operation ended.
OUTCOME_ACKED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_ANSWERED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_COMPLETED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_CONFIRMED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_DEAD_LETTERED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_ENDED_EARLY - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_FAILED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_IN_PROGRESS - Static variable in class org.acemq.amqp.api.MetricNames: A delivery whose identifier another consumer has claimed and not yet confirmed.
OUTCOME_PARKED - Static variable in class org.acemq.amqp.api.MetricNames: A message set aside in the parking lot rather than the dead-letter queue.
OUTCOME_PUBLISHED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_REFUSED - Static variable in class org.acemq.amqp.api.MetricNames: A publish the library declined to send: nothing was written to the broker.
OUTCOME_REJECTED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_RETRIED - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_TIMED_OUT - Static variable in class org.acemq.amqp.api.MetricNames
OUTCOME_UNROUTABLE - Static variable in class org.acemq.amqp.api.MetricNames

P

parked() - Method in class org.acemq.amqp.core.Replay: Switches to the parking lot: messages that could not be decoded at all.
parse(String) - Static method in class org.acemq.amqp.core.Itinerary
partitionFor(String, int) - Static method in class org.acemq.amqp.api.Partitioning
Partitioning - Class in org.acemq.amqp.api: Decides which partition an ordering key belongs to.
partitions() - Method in class org.acemq.amqp.core.OrderedQueue
partitions(int) - Method in class org.acemq.amqp.core.OrderedQueueBuilder
password() - Method in class org.acemq.amqp.transport.ConnectionConfig
paths() - Method in class org.acemq.amqp.actuator.AceMqActuator
pause() - Method in interface org.acemq.amqp.core.MessageConsumer: Stops taking new messages, keeping the consumer able to start again.
pauseConsuming() - Method in class org.acemq.amqp.core.AceMq: Stops every consumer taking new work, reversibly.
pausePublishing() - Method in class org.acemq.amqp.core.AceMq: Refuses further publishes on this connection.
payload() - Method in interface org.acemq.amqp.api.Message
payload() - Method in class org.acemq.amqp.api.OutboxRecord
payload() - Method in class org.acemq.amqp.api.PublishContext
pending() - Method in class org.acemq.amqp.core.Replay: Counts what is waiting, without moving anything.
pendingCount() - Method in interface org.acemq.amqp.api.OutboxStore
pendingCount() - Method in class org.acemq.amqp.patterns.JdbcOutboxStore
persistent() - Method in class org.acemq.amqp.core.PublishOptions
persistent() - Method in class org.acemq.amqp.transport.OutboundMessage
pipeline(String, Class<T>) - Method in class org.acemq.amqp.core.AceMq: A chain of steps, each with its own queue.
Pipeline<T> - Class in org.acemq.amqp.core: A chain of steps, each its own queue.
PIPELINE_RUN_DURATION - Static variable in class org.acemq.amqp.api.MetricNames: How long a message had existed when it left a pipeline.
PIPELINE_RUN_TOTAL - Static variable in class org.acemq.amqp.api.MetricNames: Pipeline runs that finished, tagged with MetricNames.TAG_OUTCOME and MetricNames.TAG_STEP.
PipelineBuilder<T,C> - Class in org.acemq.amqp.core: Declares the steps of a pipeline, in order, threading the types along the chain.
pipelineRunFinished(String, String, String, Duration) - Method in interface org.acemq.amqp.api.Telemetry: Called when a message leaves a pipeline, whether it finished or stopped early.
plan(Topology) - Method in class org.acemq.amqp.core.TopologyPlanner: Works out what applying a topology would do, without doing any of it.
port() - Method in class org.acemq.amqp.actuator.AceMqActuator
port() - Method in class org.acemq.amqp.actuator.ActuatorOptions
port(int) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder: The port to listen on.
position() - Method in class org.acemq.amqp.api.RoutingSlip
POSITION - Static variable in class org.acemq.amqp.api.RoutingSlip: Which step is next, counting from zero.
prefetch() - Method in class org.acemq.amqp.core.ConsumerGroup
prefetch() - Method in class org.acemq.amqp.core.ConsumerOptions
prefetch() - Method in interface org.acemq.amqp.core.MessageConsumer
prefetch(int) - Method in class org.acemq.amqp.core.ConsumerGroup: Changes the prefetch of every member, and of members added later.
prefetch(int) - Method in class org.acemq.amqp.core.ConsumerGroupBuilder
prefetch(int) - Static method in class org.acemq.amqp.core.ConsumerOptions
prefetch(int) - Method in interface org.acemq.amqp.core.MessageConsumer: Changes how many unsettled deliveries this consumer may hold, while it is running.
prefetch(int) - Method in class org.acemq.amqp.core.OrderedQueueBuilder
prefetch(int) - Method in class org.acemq.amqp.core.PipelineBuilder
prefetch(int) - Method in class org.acemq.amqp.core.StreamOptions
prefetch(int) - Method in class org.acemq.amqp.core.StreamReader
prefetchCount() - Method in class org.acemq.amqp.core.StreamOptions
PREFIX - Static variable in class org.acemq.amqp.api.AceHeaders: The engine's namespace.
PRESENT - Enum constant in enum org.acemq.amqp.api.TopologyPlan.Kind: The item already exists and would be left alone.
priority() - Method in class org.acemq.amqp.core.PublishOptions
priority() - Method in class org.acemq.amqp.transport.OutboundMessage
priority(Integer) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder: Sets the priority this message is published with.
PRIORITY - Enum constant in enum org.acemq.amqp.api.Capability: Priority ordering within a queue.
propagationHeaders() - Method in interface org.acemq.amqp.api.Telemetry: Headers to add to an outgoing message so a trace continues across the broker.
ProtobufCodec - Class in org.acemq.amqp.codec.protobuf: Reads and writes Protocol Buffers.
PUBLISH_DURATION - Static variable in class org.acemq.amqp.api.MetricNames: Time from calling send to the broker confirming, tagged with the outcome.
PUBLISH_TOTAL - Static variable in class org.acemq.amqp.api.MetricNames: Messages published, tagged with the outcome.
PublishContext - Class in org.acemq.amqp.api: A message about to be published, as an interceptor sees it.
PublishContext(String, String, Envelope, Object) - Constructor for class org.acemq.amqp.api.PublishContext
published() - Method in class org.acemq.amqp.patterns.OutboxRelay
publisher(String, String) - Method in class org.acemq.amqp.core.AceMq: Creates a publisher for one destination.
publisher(String, String, Class<T>) - Method in class org.acemq.amqp.core.AceMq: Creates a publisher for one destination and one payload type.
publisher(String, String, Class<T>, PublishOptions) - Method in class org.acemq.amqp.core.AceMq: Creates a publisher that publishes on the caller's terms rather than the safe defaults.
Publisher<T> - Interface in org.acemq.amqp.api: Sends messages of one type to one destination.
PUBLISHER_CONFIRMS - Enum constant in enum org.acemq.amqp.api.Capability: Broker acknowledges that a published message was taken responsibility for.
publisherConfirms() - Method in class org.acemq.amqp.transport.ConnectionConfig
PublishFailedException - Exception Class in org.acemq.amqp.api: Raised when a publish did not result in a message the broker took responsibility for and could route.
PublishFailedException(String) - Constructor for exception class org.acemq.amqp.api.PublishFailedException
PublishFailedException(String, Throwable) - Constructor for exception class org.acemq.amqp.api.PublishFailedException
PublishingPausedException - Exception Class in org.acemq.amqp.api: Publishing was paused on this connection, so the message was not sent.
PublishingPausedException(String) - Constructor for exception class org.acemq.amqp.api.PublishingPausedException
PublishInterceptor - Interface in org.acemq.amqp.api: Runs around every publish on a connection.
PublishOptions - Class in org.acemq.amqp.core: How a message should be published.
PublishResult - Class in org.acemq.amqp.api: The outcome of one publish, after the broker has confirmed it.
PublishResult(String, boolean, Duration) - Constructor for class org.acemq.amqp.api.PublishResult
publishStarted(String, String, Envelope) - Method in interface org.acemq.amqp.api.Telemetry: Called immediately before a message is published.
PulledMessage - Class in org.acemq.amqp.transport: One message taken off a queue by TransportConnection.receive(java.lang.String, java.time.Duration), and the means to settle it.
PulledMessage(InboundDelivery, Acknowledger) - Constructor for class org.acemq.amqp.transport.PulledMessage
purgeExpired() - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore: Deletes rows nobody is bound by any more: confirmations past their retention, and claims whose lease has run out.
purgePublished(Duration) - Method in class org.acemq.amqp.patterns.JdbcOutboxStore: Removes published records older than the given age.
put(byte[]) - Method in interface org.acemq.amqp.api.ClaimCheckStore: Stores a payload.
put(byte[]) - Method in class org.acemq.amqp.patterns.FilesystemClaimCheckStore
put(byte[]) - Method in class org.acemq.amqp.patterns.InMemoryClaimCheckStore

Q

queue() - Method in class org.acemq.amqp.api.ConsumeContext
queue() - Method in interface org.acemq.amqp.api.Message
queue() - Method in class org.acemq.amqp.api.Topology.BindingSpec
queue() - Method in class org.acemq.amqp.core.ConsumerGroup
queue() - Method in interface org.acemq.amqp.core.MessageConsumer
queue() - Method in interface org.acemq.amqp.core.StreamConsumer
queue() - Method in class org.acemq.amqp.transport.InboundDelivery
queue() - Method in interface org.acemq.amqp.transport.Subscription
queue(String) - Method in class org.acemq.amqp.api.Topology.Builder: A durable quorum queue, which is the default everywhere in this library.
QueueCheck - Class in org.acemq.amqp.transport: What a broker says about a queue somebody is about to declare.
QueueCheck.Result - Enum in org.acemq.amqp.transport: Which of the four answers this is.
queueExists(String) - Method in interface org.acemq.amqp.transport.TransportConnection: Reports whether a queue exists, without creating or altering it.
queueFor(int) - Method in class org.acemq.amqp.core.OrderedQueue
queueFor(String) - Method in class org.acemq.amqp.core.Pipeline
queues() - Method in class org.acemq.amqp.api.Topology
queues() - Method in class org.acemq.amqp.core.OrderedQueue
QueueType - Enum in org.acemq.amqp.transport: The kind of queue to declare.
queueWithDeadLetter(String) - Method in class org.acemq.amqp.api.Topology.Builder: A durable quorum queue that dead-letters, together with the two queues its dead letters end up in and the exchange they are reached through.
quorum() - Method in class org.acemq.amqp.api.Topology.QueueSpec
QUORUM - Enum constant in enum org.acemq.amqp.transport.QueueType: A replicated queue with a consensus protocol.
QUORUM_QUEUES - Enum constant in enum org.acemq.amqp.api.Capability: Replicated queues with a consensus protocol.

R

rabbitMqConfiguration(Path) - Method in class org.acemq.amqp.security.dev.DevelopmentCertificates
RabbitMqTransport - Class in org.acemq.amqp.transport.rabbitmq: AMQP 0-9-1 transport backed by the RabbitMQ Java client.
RabbitMqTransport() - Constructor for class org.acemq.amqp.transport.rabbitmq.RabbitMqTransport
reason() - Method in class org.acemq.amqp.api.Ack
reason() - Method in exception class org.acemq.amqp.transport.ConnectionBlockedException
receive(String, Duration) - Method in interface org.acemq.amqp.transport.TransportConnection: Takes one message off a queue, or reports that there is none.
receivedAt() - Method in interface org.acemq.amqp.api.Message
redelivered() - Method in interface org.acemq.amqp.api.Message: Whether the broker set the AMQP redelivered flag on this delivery.
redelivered() - Method in class org.acemq.amqp.transport.InboundDelivery
register(int, SchemaDefinition) - Method in class org.acemq.amqp.codec.avro.InMemorySchemaRegistry: Registers a schema under an identifier of the caller's choosing.
registered(SchemaRegistry) - Static method in class org.acemq.amqp.codec.avro.AvroCodec
registered(SchemaRegistry, Schema) - Static method in class org.acemq.amqp.codec.avro.AvroCodec: As AvroCodec.registered(SchemaRegistry), but reading every message against a schema of your own rather than the writer's.
REGISTERED_CONTENT_TYPE - Static variable in class org.acemq.amqp.codec.avro.AvroCodec: Content type for a codec that writes a schema identifier into each message.
registry() - Method in class org.acemq.amqp.actuator.AceMqActuator: The registry the metrics are read from.
registry() - Method in class org.acemq.amqp.actuator.ActuatorOptions
registry(PrometheusMeterRegistry) - Method in class org.acemq.amqp.actuator.ActuatorOptions.Builder: A registry to scrape instead of one the actuator creates.
reject(boolean) - Method in interface org.acemq.amqp.transport.Acknowledger: Rejects the message.
rejected() - Method in class org.acemq.amqp.core.ConsumerGroup
rejected() - Method in interface org.acemq.amqp.core.MessageConsumer
release() - Static method in class org.acemq.amqp.api.Ack: This consumer will not handle the message, but another one should be given the chance.
release(String) - Method in interface org.acemq.amqp.api.IdempotencyStore: Gives up a claim without recording completion, so the message can be tried again.
release(String) - Method in class org.acemq.amqp.patterns.InMemoryIdempotencyStore
release(String) - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore
render() - Method in class org.acemq.amqp.api.TopologyPlan: Renders the plan the way a build log or a review wants to read it.
replay(int) - Method in class org.acemq.amqp.core.Replay: Moves up to a given number of messages back.
replay(int, Predicate<InboundDelivery>) - Method in class org.acemq.amqp.core.Replay: Moves messages matching a filter, leaving the rest in place.
replay(String) - Method in class org.acemq.amqp.core.AceMq: Moves failed messages back to the queue they failed in.
Replay - Class in org.acemq.amqp.core: Moves messages out of a dead-letter queue or parking lot and back to the queue they failed in.
REPLAY_COUNT - Static variable in class org.acemq.amqp.api.AceHeaders: How many times the message has been replayed.
replayAll() - Method in class org.acemq.amqp.core.Replay: Moves every waiting message back, stopping when the queue is empty.
replayCount() - Method in class org.acemq.amqp.api.Envelope
replayCount(int) - Method in class org.acemq.amqp.api.Envelope.Builder
REPLAYED_AT - Static variable in class org.acemq.amqp.api.AceHeaders: When the message was last replayed.
REPLAYED_FROM - Static variable in class org.acemq.amqp.api.AceHeaders: Queue a message was replayed from, set by the replay API for auditing.
replayedAt() - Method in class org.acemq.amqp.api.Envelope
replayedAt(Instant) - Method in class org.acemq.amqp.api.Envelope.Builder
replayedFrom() - Method in class org.acemq.amqp.api.Envelope: Where this message was replayed from, when it was.
replayedFrom(String) - Method in class org.acemq.amqp.api.Envelope.Builder
REPLY_TO - Static variable in class org.acemq.amqp.api.AceHeaders: Queue a request's reply should be sent to.
replyingTo(String) - Method in class org.acemq.amqp.core.DefaultPublisher: Names the queue a reply to this message should be sent to.
replyQueue() - Method in class org.acemq.amqp.core.Requester
replyTo() - Method in interface org.acemq.amqp.api.Message: Where the sender asked for a reply.
replyTo() - Method in class org.acemq.amqp.transport.InboundDelivery: Where the sender asked for a reply.
replyTo() - Method in class org.acemq.amqp.transport.OutboundMessage
replyTo(String) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder: Names the queue a reply should be sent to.
request(String, String, Q, Class<A>, Duration) - Method in class org.acemq.amqp.core.Requester: Asks, and waits.
REQUEST_DURATION - Static variable in class org.acemq.amqp.api.MetricNames: Round trip of a request/reply call, as the caller experienced it.
REQUEST_TOTAL - Static variable in class org.acemq.amqp.api.MetricNames: Request/reply calls, tagged with MetricNames.TAG_OUTCOME.
requestAsync(String, String, Q, Class<A>) - Method in class org.acemq.amqp.core.Requester: Asks, and hands back a future.
requester() - Method in class org.acemq.amqp.core.AceMq: Opens a requester for asking questions and waiting for answers.
Requester - Class in org.acemq.amqp.core: Asks a question and waits for the answer.
requestStarted(String, Envelope) - Method in interface org.acemq.amqp.api.Telemetry: Called once per request/reply round trip, around the wait for the answer.
RequestTimedOutException - Exception Class in org.acemq.amqp.core: No reply arrived in time.
RequestTimedOutException(String, Duration) - Constructor for exception class org.acemq.amqp.core.RequestTimedOutException
requeueOnFailure() - Method in class org.acemq.amqp.core.ConsumerOptions: Requeues a message when its handler fails.
required() - Static method in class org.acemq.amqp.security.Security
REQUIRED - Enum constant in enum org.acemq.amqp.security.Security.Mode: Encrypt, verify the chain, verify the hostname.
reset() - Static method in class org.acemq.amqp.test.InMemoryTransport: Discards every in-memory broker and its contents.
respond(String, Class<Q>, Function<Q, A>) - Method in class org.acemq.amqp.core.AceMq: Answers requests arriving on a queue.
respond(String, Class<Q>, ConsumerOptions, Function<Q, A>) - Method in class org.acemq.amqp.core.AceMq: As AceMq.respond(String, Class, java.util.function.Function), with consumer options.
Responder - Class in org.acemq.amqp.core: The other end of Requester: reads a request, computes an answer, sends it back.
RESPONDER_ERROR - Static variable in class org.acemq.amqp.api.AceHeaders: A responder's failure, carried back to the requester on the reply.
ResponderFailedException - Exception Class in org.acemq.amqp.core: The responder answered, and the answer was a failure.
ResponderFailedException(String, String) - Constructor for exception class org.acemq.amqp.core.ResponderFailedException
result() - Method in class org.acemq.amqp.transport.QueueCheck
resume() - Method in interface org.acemq.amqp.core.MessageConsumer: Starts taking messages again after MessageConsumer.pause().
resumeConsuming() - Method in class org.acemq.amqp.core.AceMq: Starts every paused consumer again.
resumePublishing() - Method in class org.acemq.amqp.core.AceMq: Allows publishing again.
Retention is the part that goes wrong - Search tag in interface org.acemq.amqp.api.ClaimCheckStore: Section
retried() - Method in class org.acemq.amqp.core.ConsumerGroup
retried() - Method in interface org.acemq.amqp.core.MessageConsumer
RETRIED_TOTAL - Static variable in class org.acemq.amqp.api.MetricNames: Messages sent to a retry queue.
Retries reorder, so the retry ladder is not available here - Search tag in class org.acemq.amqp.core.OrderedQueue: Section
retry(Duration, String) - Static method in class org.acemq.amqp.api.Ack: The attempt failed but is worth repeating, so the message goes to the next retry tier with its attempt counter incremented.
RETRY_IN_PLACE - Enum constant in enum org.acemq.amqp.core.OrderedQueue.OnFailure: Retry the same message, in the handler, with a delay between attempts.
retryPolicy() - Method in class org.acemq.amqp.core.ConsumerOptions
RetryPolicy - Class in org.acemq.amqp.api: When, and how often, a failed message should be tried again, and where the waiting happens.
RetryPolicy.Wait - Class in org.acemq.amqp.api: How long before the next attempt, and where the message spends it.
retryRungMissing(String, String, Duration) - Method in interface org.acemq.amqp.api.Telemetry: Records that a retry had to wait in the consumer because its rung queue is not there.
route() - Method in class org.acemq.amqp.api.Envelope: Where this message is going, when it is travelling a pipeline.
route(RoutingSlip) - Method in class org.acemq.amqp.api.Envelope.Builder
ROUTE - Static variable in class org.acemq.amqp.api.RoutingSlip: The ordered step names, comma-separated.
routed() - Method in class org.acemq.amqp.api.PublishResult
ROUTING_SLIP - Static variable in class org.acemq.amqp.api.AceHeaders: A self-describing itinerary: the stops a message still has to make, as JSON.
routingKey() - Method in interface org.acemq.amqp.api.Message
routingKey() - Method in class org.acemq.amqp.api.OutboxRecord
routingKey() - Method in class org.acemq.amqp.api.PublishContext
routingKey() - Method in class org.acemq.amqp.api.Topology.BindingSpec
routingKey() - Method in class org.acemq.amqp.core.Itinerary.Stop
routingKey() - Method in class org.acemq.amqp.transport.InboundDelivery
routingKey() - Method in class org.acemq.amqp.transport.OutboundMessage
routingKey(String) - Method in class org.acemq.amqp.transport.OutboundMessage.Builder
routingKeyFor(int) - Static method in class org.acemq.amqp.api.Partitioning
RoutingSlip - Class in org.acemq.amqp.api: Where a message is going, carried by the message.
run(T) - Method in class org.acemq.amqp.patterns.Saga: Runs the steps, compensating in reverse if one fails.
RUN_ID - Static variable in class org.acemq.amqp.api.RoutingSlip: Identifies one run through a pipeline, across every hop.
RUNG_MISSING - Static variable in class org.acemq.amqp.api.MetricNames: Retries that had to wait in the consumer because the rung queue they belonged in is not on the broker, tagged with MetricNames.TAG_QUEUE and MetricNames.TAG_RUNG.
runId() - Method in class org.acemq.amqp.api.RoutingSlip

S

Saga<T> - Class in org.acemq.amqp.patterns: A sequence of steps where each one knows how to undo itself.
Saga.Builder<T> - Class in org.acemq.amqp.patterns: Collects the steps of a Saga.
SagaResult - Class in org.acemq.amqp.patterns: What a saga did.
scaleTo(int) - Method in class org.acemq.amqp.core.ConsumerGroup: Grows or shrinks the group.
schedule() - Method in class org.acemq.amqp.api.RetryPolicy: The delays this policy uses, without jitter.
scheduled() - Method in class org.acemq.amqp.patterns.Scheduler
Scheduler - Class in org.acemq.amqp.patterns: Delivering a message later.
SchemaDefinition - Class in org.acemq.amqp.api: A schema as a registry sees it: some text, and enough about it to know what the text is.
SchemaDefinition(String, String, String) - Constructor for class org.acemq.amqp.api.SchemaDefinition
schemaFor(int) - Method in interface org.acemq.amqp.api.SchemaRegistry
schemaFor(int) - Method in class org.acemq.amqp.codec.avro.InMemorySchemaRegistry
schemaFor(int) - Method in class org.acemq.amqp.patterns.JdbcSchemaRegistry
SchemaRegistry - Interface in org.acemq.amqp.api: Turns a schema into a small integer and back.
scheme() - Method in class org.acemq.amqp.test.InMemoryTransport
scheme() - Method in class org.acemq.amqp.transport.ConnectionConfig
scheme() - Method in class org.acemq.amqp.transport.rabbitmq.RabbitMqTransport
scheme() - Method in interface org.acemq.amqp.transport.Transport
schemes() - Method in class org.acemq.amqp.transport.rabbitmq.RabbitMqTransport
schemes() - Method in interface org.acemq.amqp.transport.Transport: Every scheme this transport answers to.
secret() - Method in class org.acemq.amqp.security.Credentials
security() - Method in class org.acemq.amqp.transport.ConnectionConfig
security(Security) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
Security - Class in org.acemq.amqp.security: How a connection is protected.
Security.Mode - Enum in org.acemq.amqp.security: What a connection does about transport security.
SecurityConfigurationException - Exception Class in org.acemq.amqp.security: Something about the security configuration is wrong.
SecurityConfigurationException(String) - Constructor for exception class org.acemq.amqp.security.SecurityConfigurationException
SecurityConfigurationException(String, Throwable) - Constructor for exception class org.acemq.amqp.security.SecurityConfigurationException
send(Itinerary, T) - Method in class org.acemq.amqp.core.Pipeline
send(Itinerary, T, Envelope) - Method in class org.acemq.amqp.core.Pipeline: Sends a payload to the first stop of an itinerary the message carries with it.
send(OutboundMessage) - Method in interface org.acemq.amqp.transport.TransportConnection: Publishes one message and waits for the broker to confirm it.
send(T) - Method in interface org.acemq.amqp.api.Publisher: Publishes a message and waits for the broker to confirm it.
send(T) - Method in class org.acemq.amqp.core.DefaultPublisher
send(T) - Method in class org.acemq.amqp.core.OrderedQueue
send(T) - Method in class org.acemq.amqp.core.Pipeline: Sends a payload in at the first step.
send(T, Envelope) - Method in class org.acemq.amqp.core.OrderedQueue
send(T, Envelope) - Method in interface org.acemq.amqp.api.Publisher: Publishes a message built on an explicit envelope.
send(T, Envelope) - Method in class org.acemq.amqp.core.DefaultPublisher
send(T, Envelope) - Method in class org.acemq.amqp.core.Pipeline
sendAll(Collection<? extends T>) - Method in interface org.acemq.amqp.api.Publisher: Publishes a batch and waits for every confirm.
sendAll(Collection<? extends T>) - Method in class org.acemq.amqp.core.DefaultPublisher
sendAsync(OutboundMessage) - Method in interface org.acemq.amqp.transport.TransportConnection: Publishes one message without waiting for the broker to confirm it.
sendAsync(T) - Method in interface org.acemq.amqp.api.Publisher: Publishes without waiting for the broker to confirm.
sendAsync(T) - Method in class org.acemq.amqp.core.DefaultPublisher
sendAsync(T, Envelope) - Method in interface org.acemq.amqp.api.Publisher: Publishes without waiting, with an envelope of your own.
sendAsync(T, Envelope) - Method in class org.acemq.amqp.core.DefaultPublisher
SET_ASIDE_FAILED - Static variable in class org.acemq.amqp.api.MetricNames: Messages that could not be moved to a dead-letter or parking queue, tagged with MetricNames.TAG_QUEUE and MetricNames.TAG_TARGET.
setAsideFailed(String, String, String) - Method in interface org.acemq.amqp.api.Telemetry: Records that a message could not be moved to a dead-letter or parking queue.
setPrefetch(int) - Method in interface org.acemq.amqp.transport.Subscription: Changes how many unsettled deliveries this subscription may hold.
SHARED_PREFIX - Static variable in class org.acemq.amqp.api.AceHeaders: The namespace AceMQ defines but does not reserve.
SINGLE_ACTIVE_CONSUMER - Enum constant in enum org.acemq.amqp.api.Capability: At most one active consumer at a time, preserving order across failover.
size() - Method in class org.acemq.amqp.codec.avro.InMemorySchemaRegistry
size() - Method in class org.acemq.amqp.core.ConsumerGroup
size() - Method in class org.acemq.amqp.patterns.InMemoryClaimCheckStore
size() - Method in class org.acemq.amqp.patterns.InMemoryIdempotencyStore
size() - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore
size() - Method in class org.acemq.amqp.patterns.JdbcSchemaRegistry
SKIP - Enum constant in enum org.acemq.amqp.core.OrderedQueue.OnFailure: Give up on the message, acknowledge it, and carry on.
SKIP - Enum constant in enum org.acemq.amqp.core.StreamOptions.OnFailure: Pass over the message, count it, and carry on.
skipFailures() - Method in class org.acemq.amqp.core.StreamOptions: Carries on past a message whose handler failed.
skipFailures() - Method in class org.acemq.amqp.core.StreamReader: Carries on past a message whose handler failed, counting it.
skipped() - Method in class org.acemq.amqp.core.OrderedQueue
skipped() - Method in interface org.acemq.amqp.core.StreamConsumer
SPAN_PROCESS_SUFFIX - Static variable in class org.acemq.amqp.api.MetricNames: Span covering a handler running.
SPAN_PUBLISH_SUFFIX - Static variable in class org.acemq.amqp.api.MetricNames: Span covering a publish.
SPAN_REQUEST_SUFFIX - Static variable in class org.acemq.amqp.api.MetricNames: Span covering a whole request/reply round trip.
sslContext() - Method in class org.acemq.amqp.security.Security: Builds the context to connect with.
start() - Method in class org.acemq.amqp.core.ConsumerGroupBuilder
start() - Method in class org.acemq.amqp.patterns.OutboxRelay: Starts draining the outbox on a background thread.
start(ActuatorOptions) - Static method in class org.acemq.amqp.actuator.AceMqActuator: Starts an actuator.
start(AceMq) - Static method in class org.acemq.amqp.actuator.AceMqActuator: Starts an actuator on the default port and paths, reporting on one connection.
startOf(String...) - Static method in class org.acemq.amqp.api.RoutingSlip
startOf(List<String>) - Static method in class org.acemq.amqp.api.RoutingSlip
step(String) - Method in class org.acemq.amqp.core.Pipeline: The consumers running one step, so it can be scaled independently.
step(String, Class<O>, Step<C, O>) - Method in class org.acemq.amqp.core.PipelineBuilder: Adds a step to the end of the chain.
step(String, Consumer<T>) - Method in class org.acemq.amqp.patterns.Saga.Builder: Adds a step with no compensation.
Step<I,O> - Interface in org.acemq.amqp.api: One stage of a pipeline: a message in, the next payload out.
stepNames() - Method in class org.acemq.amqp.core.Pipeline
stepNames() - Method in class org.acemq.amqp.patterns.Saga
steps() - Method in class org.acemq.amqp.api.RoutingSlip
steps() - Method in class org.acemq.amqp.core.Itinerary
STOP - Enum constant in enum org.acemq.amqp.core.OrderedQueue.OnFailure: Stop this partition and leave the message on the queue.
STOP - Enum constant in enum org.acemq.amqp.core.StreamOptions.OnFailure: Stop the consumer and record why.
stoppedBy() - Method in interface org.acemq.amqp.core.StreamConsumer
stream(String, Class<T>) - Method in class org.acemq.amqp.core.AceMq: Reads a stream, starting where the returned reader is told to.
STREAM - Enum constant in enum org.acemq.amqp.transport.QueueType: An append-only, replayable log with consumer-held offsets.
StreamConsumer - Interface in org.acemq.amqp.core: A running read of a stream.
StreamOffset - Class in org.acemq.amqp.api: Where in a stream a consumer starts reading.
StreamOptions - Class in org.acemq.amqp.core: How a stream should be read.
StreamOptions.OnFailure - Enum in org.acemq.amqp.core: What to do when a handler throws.
StreamReader<T> - Class in org.acemq.amqp.core: Says where to start reading a stream, and then starts.
STREAMS - Enum constant in enum org.acemq.amqp.api.Capability: Append-only, replayable log semantics with consumer-held offsets.
StringCodec - Class in org.acemq.amqp.core: Reads and writes UTF-8 text.
StringCodec() - Constructor for class org.acemq.amqp.core.StringCodec
subject() - Method in class org.acemq.amqp.api.SchemaDefinition
subscribe(String, int, Map<String, Object>, DeliveryListener) - Method in interface org.acemq.amqp.transport.TransportConnection: Starts consuming a queue with broker-specific consumer arguments.
subscribe(String, int, DeliveryListener) - Method in interface org.acemq.amqp.transport.TransportConnection: Starts consuming a queue.
Subscription - Interface in org.acemq.amqp.transport: A live consumer registration.
supports(Capability) - Method in class org.acemq.amqp.core.AceMq

T

TAG_EXCHANGE - Static variable in class org.acemq.amqp.api.MetricNames: Exchange a message was published to; empty string for the default exchange.
TAG_MESSAGE_TYPE - Static variable in class org.acemq.amqp.api.MetricNames: Logical message type from the envelope.
TAG_OUTCOME - Static variable in class org.acemq.amqp.api.MetricNames: What happened.
TAG_PIPELINE - Static variable in class org.acemq.amqp.api.MetricNames: Pipeline a run belongs to.
TAG_QUEUE - Static variable in class org.acemq.amqp.api.MetricNames: Queue a delivery came from.
TAG_ROUTING_KEY - Static variable in class org.acemq.amqp.api.MetricNames: Routing key used, or the queue name when publishing without an exchange.
TAG_RUNG - Static variable in class org.acemq.amqp.api.MetricNames: The retry rung a wait belonged in, such as orders.new.retry.40s.
TAG_STEP - Static variable in class org.acemq.amqp.api.MetricNames: Step a pipeline run was at when it finished.
TAG_TARGET - Static variable in class org.acemq.amqp.api.MetricNames: Where a message was being set aside to when that failed: the dead-letter queue or the parking lot.
TAG_TRANSPORT - Static variable in class org.acemq.amqp.api.MetricNames: Transport short name, such as rabbitmq.
Telemetries - Class in org.acemq.amqp.core: Builds the telemetry sink for a connection.
telemetry() - Method in class org.acemq.amqp.core.AceMq
telemetry(MeterRegistry, String) - Static method in class org.acemq.amqp.core.MicrometerSupport: Records AceMQ activity into a registry you supply.
telemetry(OpenTelemetry, String) - Static method in class org.acemq.amqp.core.OpenTelemetrySupport: Emits spans through an OpenTelemetry instance you supply.
Telemetry - Interface in org.acemq.amqp.api: Where AceMQ reports what it is doing.
Telemetry.Scope - Interface in org.acemq.amqp.api: An operation in progress.
Text() - Constructor for class org.acemq.amqp.core.BuiltInCodecProviders.Text
The failure this has and the in-memory one does not - Search tag in class org.acemq.amqp.patterns.JdbcIdempotencyStore: Section
The HTTP server - Search tag in class org.acemq.amqp.actuator.AceMqActuator: Section
then(String, String) - Method in class org.acemq.amqp.core.Itinerary: Adds a stop to the end.
then(String, String, String) - Method in class org.acemq.amqp.core.Itinerary
These endpoints are unauthenticated - Search tag in class org.acemq.amqp.actuator.AceMqActuator: Section
timedOut() - Method in class org.acemq.amqp.core.Requester
to() - Method in class org.acemq.amqp.core.Replay
toBase64(SecretKey) - Static method in class org.acemq.amqp.crypto.Keys: For writing a generated key into a secret store.
toBuilder() - Method in class org.acemq.amqp.api.Envelope
toConsumerArgument() - Method in class org.acemq.amqp.api.StreamOffset: The value the broker expects as the x-stream-offset consumer argument.
toHeader() - Method in class org.acemq.amqp.core.Itinerary
toHeaders() - Method in class org.acemq.amqp.api.RoutingSlip
token(String) - Static method in class org.acemq.amqp.security.Credentials: A bearer token, as RabbitMQ's OAuth 2 support expects it.
TomlCodec - Class in org.acemq.amqp.codec.toml: Reads and writes TOML.
TomlCodec() - Constructor for class org.acemq.amqp.codec.toml.TomlCodec: Uses a mapper that ignores unknown keys and writes dates as text.
TomlCodec(ObjectMapper) - Constructor for class org.acemq.amqp.codec.toml.TomlCodec
TomlCodecProvider - Class in org.acemq.amqp.codec.toml: Announces TomlCodec to the engine as toml.
TomlCodecProvider() - Constructor for class org.acemq.amqp.codec.toml.TomlCodecProvider
TOPIC_WILDCARDS - Enum constant in enum org.acemq.amqp.api.Capability: Topic-style routing keys with wildcard bindings.
topology() - Method in class org.acemq.amqp.core.AceMq: Plans and applies a declared topology.
Topology - Class in org.acemq.amqp.api: A topology as data: what exchanges, queues and bindings should exist.
Topology.BindingSpec - Class in org.acemq.amqp.api: A binding that should exist.
Topology.Builder - Class in org.acemq.amqp.api: Builds a Topology.
Topology.ExchangeSpec - Class in org.acemq.amqp.api: An exchange that should exist.
Topology.QueueSpec - Class in org.acemq.amqp.api: A queue that should exist.
TopologyPlan - Class in org.acemq.amqp.api: What applying a Topology would do, worked out before anything is done.
TopologyPlan.Action - Class in org.acemq.amqp.api: One item of a plan.
TopologyPlan.Kind - Enum in org.acemq.amqp.api: What a plan proposes to do about one item.
TopologyPlanner - Class in org.acemq.amqp.core: Works out what a Topology would change before changing it.
toString() - Method in class org.acemq.amqp.api.ConsumeContext
toString() - Method in class org.acemq.amqp.api.Envelope
toString() - Method in class org.acemq.amqp.api.OutboxRecord
toString() - Method in class org.acemq.amqp.api.PublishContext
toString() - Method in class org.acemq.amqp.api.PublishResult
toString() - Method in class org.acemq.amqp.api.RetryPolicy
toString() - Method in class org.acemq.amqp.api.RetryPolicy.Wait
toString() - Method in class org.acemq.amqp.api.RoutingSlip
toString() - Method in class org.acemq.amqp.api.SchemaDefinition
toString() - Method in class org.acemq.amqp.api.StreamOffset
toString() - Method in class org.acemq.amqp.api.Topology
toString() - Method in class org.acemq.amqp.api.TopologyPlan.Action
toString() - Method in class org.acemq.amqp.api.TopologyPlan
toString() - Method in class org.acemq.amqp.codec.avro.AvroCodec
toString() - Method in class org.acemq.amqp.codec.json.JsonCodec
toString() - Method in class org.acemq.amqp.codec.protobuf.ProtobufCodec
toString() - Method in class org.acemq.amqp.codec.toml.TomlCodec
toString() - Method in class org.acemq.amqp.codec.xml.XmlCodec
toString() - Method in class org.acemq.amqp.codec.yaml.YamlCodec
toString() - Method in class org.acemq.amqp.core.BytesCodec
toString() - Method in class org.acemq.amqp.core.CompositeCodec
toString() - Method in class org.acemq.amqp.core.ConsumerGroup
toString() - Method in class org.acemq.amqp.core.ConsumerGroupBuilder
toString() - Method in class org.acemq.amqp.core.DefaultPublisher
toString() - Method in class org.acemq.amqp.core.Itinerary.Stop
toString() - Method in class org.acemq.amqp.core.Itinerary
toString() - Method in class org.acemq.amqp.core.OrderedQueue
toString() - Method in class org.acemq.amqp.core.OrderedQueueBuilder
toString() - Method in class org.acemq.amqp.core.Pipeline
toString() - Method in class org.acemq.amqp.core.PipelineBuilder
toString() - Method in class org.acemq.amqp.core.PublishOptions
toString() - Method in class org.acemq.amqp.core.Replay
toString() - Method in class org.acemq.amqp.core.StreamOptions
toString() - Method in class org.acemq.amqp.core.StreamReader
toString() - Method in class org.acemq.amqp.crypto.EncryptedCodec
toString() - Method in class org.acemq.amqp.crypto.EncryptionKey
toString() - Method in class org.acemq.amqp.crypto.Keyring.StaticKeyring
toString() - Method in class org.acemq.amqp.patterns.ClaimCheckCodec
toString() - Method in class org.acemq.amqp.patterns.FilesystemClaimCheckStore
toString() - Method in class org.acemq.amqp.patterns.InMemoryClaimCheckStore
toString() - Method in class org.acemq.amqp.patterns.JdbcIdempotencyStore
toString() - Method in class org.acemq.amqp.patterns.JdbcOutboxStore
toString() - Method in class org.acemq.amqp.patterns.JdbcSchemaRegistry
toString() - Method in class org.acemq.amqp.patterns.OutboxRelay
toString() - Method in class org.acemq.amqp.patterns.Saga
toString() - Method in class org.acemq.amqp.patterns.SagaResult
toString() - Method in class org.acemq.amqp.patterns.Scheduler
toString() - Method in class org.acemq.amqp.security.Credentials
toString() - Method in class org.acemq.amqp.security.Security
toString() - Method in class org.acemq.amqp.transport.ConfirmResult
toString() - Method in class org.acemq.amqp.transport.ConnectionConfig
toString() - Method in class org.acemq.amqp.transport.InboundDelivery
toString() - Method in class org.acemq.amqp.transport.OutboundMessage
toString() - Method in class org.acemq.amqp.transport.PulledMessage
toString() - Method in class org.acemq.amqp.transport.QueueCheck
TRACEPARENT - Static variable in class org.acemq.amqp.api.AceHeaders: W3C trace context.
TRACESTATE - Static variable in class org.acemq.amqp.api.AceHeaders: W3C trace state.
TRANSACTIONS - Enum constant in enum org.acemq.amqp.api.Capability: Multi-message transactions on the publishing side.
transientDelivery() - Static method in class org.acemq.amqp.core.PublishOptions: Messages the broker may keep in memory only.
transientDelivery() - Method in class org.acemq.amqp.transport.OutboundMessage.Builder: Marks the message transient, so a broker restart may lose it.
Transport - Interface in org.acemq.amqp.transport: A binding to one messaging protocol.
TransportConnection - Interface in org.acemq.amqp.transport: An open connection to one broker.
TransportException - Exception Class in org.acemq.amqp.transport: Raised when a broker interaction fails in a way the caller cannot correct.
TransportException(String) - Constructor for exception class org.acemq.amqp.transport.TransportException
TransportException(String, Throwable) - Constructor for exception class org.acemq.amqp.transport.TransportException
transportName() - Method in class org.acemq.amqp.core.AceMq
tryClaim(String) - Method in interface org.acemq.amqp.api.IdempotencyStore: Takes ownership of a message identifier, and says why not when it cannot.
TTL_PER_MESSAGE - Enum constant in enum org.acemq.amqp.api.Capability: Per-message time to live, as opposed to a queue-wide setting.
type() - Method in class org.acemq.amqp.api.Envelope
type() - Method in class org.acemq.amqp.api.OutboxRecord
type() - Method in class org.acemq.amqp.api.Topology.ExchangeSpec
type(String) - Method in class org.acemq.amqp.api.Envelope.Builder
TYPE - Static variable in class org.acemq.amqp.api.AceHeaders: Logical message type, for example order.placed.

U

unanswerable() - Method in class org.acemq.amqp.core.Responder: How many arrived with no reply-to, counted before the delivery is acknowledged.
unblock(String) - Static method in class org.acemq.amqp.test.InMemoryTransport: Makes a named broker accept publishes again, releasing every publisher waiting on it.
UNKNOWN - Enum constant in enum org.acemq.amqp.api.TopologyPlan.Kind: The item exists and this transport cannot say whether it matches.
unmatched() - Method in class org.acemq.amqp.core.Requester
unresolved() - Method in class org.acemq.amqp.patterns.SagaResult: The steps whose compensation failed.
unroutable(Duration, String) - Static method in class org.acemq.amqp.transport.ConfirmResult: The broker took responsibility for the message but nothing was bound to receive it.
unsupported() - Static method in class org.acemq.amqp.transport.QueueCheck
UNSUPPORTED - Enum constant in enum org.acemq.amqp.transport.QueueCheck.Result: This transport cannot tell.
url() - Method in class org.acemq.amqp.actuator.AceMqActuator: Where it is listening.
url() - Method in class org.acemq.amqp.transport.ConnectionConfig
url(String) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder
url(String) - Static method in class org.acemq.amqp.transport.ConnectionConfig
username() - Method in class org.acemq.amqp.security.Credentials
username() - Method in class org.acemq.amqp.transport.ConnectionConfig

V

VALIDATE - Enum constant in enum org.acemq.amqp.api.ApplyMode: Change nothing and fail if anything is missing.
valueOf(String) - Static method in enum org.acemq.amqp.api.ApplyMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.api.Capability: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.api.IdempotencyStore.ClaimResult: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.api.TopologyPlan.Kind: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.core.OrderedQueue.OnFailure: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.core.StreamOptions.OnFailure: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.security.Security.Mode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.transport.QueueCheck.Result: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.acemq.amqp.transport.QueueType: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.acemq.amqp.api.ApplyMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.api.Capability: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.api.IdempotencyStore.ClaimResult: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.api.TopologyPlan.Kind: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.core.OrderedQueue.OnFailure: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.core.StreamOptions.OnFailure: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.security.Security.Mode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.transport.QueueCheck.Result: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.acemq.amqp.transport.QueueType: Returns an array containing the constants of this enum type, in the order they are declared.
verifiesHostname() - Method in class org.acemq.amqp.security.Security
version() - Method in class org.acemq.amqp.api.Envelope
version(int) - Method in class org.acemq.amqp.api.Envelope.Builder
VERSION - Static variable in class org.acemq.amqp.api.AceHeaders: Schema version of the payload, as an integer.
virtualHost() - Method in class org.acemq.amqp.transport.ConnectionConfig
virtualHost(String) - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder

W

waited() - Method in exception class org.acemq.amqp.core.RequestTimedOutException
waitInBrokerFrom(Duration) - Method in class org.acemq.amqp.api.RetryPolicy: Returns a copy that moves the line between waiting here and waiting there.
waitsInBroker(Duration) - Method in class org.acemq.amqp.api.RetryPolicy: Whether a wait of this length belongs on a rung queue rather than in the consumer.
What is on the wire - Search tag in class org.acemq.amqp.crypto.EncryptedCodec: Section
What is on the wire - Search tag in class org.acemq.amqp.patterns.ClaimCheckCodec: Section
What it does not do - Search tag in class org.acemq.amqp.core.Replay: Section
What it does not do - Search tag in class org.acemq.amqp.patterns.JdbcIdempotencyStore: Section
What it does to a message - Search tag in class org.acemq.amqp.core.Replay: Section
What this actually costs - Search tag in class org.acemq.amqp.core.OrderedQueue: Section
What this does instead - Search tag in class org.acemq.amqp.patterns.Scheduler: Section
What this does not do - Search tag in class org.acemq.amqp.crypto.EncryptedCodec: Section
What this is not - Search tag in class org.acemq.amqp.patterns.Saga: Section
When compensation itself fails - Search tag in class org.acemq.amqp.patterns.Saga: Section
When to use it, and when not to - Search tag in class org.acemq.amqp.actuator.AceMqActuator: Section
Why not a per-message time to live - Search tag in class org.acemq.amqp.patterns.Scheduler: Section
Why this exists - Search tag in class org.acemq.amqp.actuator.AceMqActuator: Section
with(PublishOptions) - Method in class org.acemq.amqp.core.DefaultPublisher: The same destination, published differently.
withCredentials(CredentialsProvider) - Method in class org.acemq.amqp.security.Security
withEnvelope(Envelope) - Method in class org.acemq.amqp.api.PublishContext
withJitter(double) - Method in class org.acemq.amqp.api.RetryPolicy: Returns a copy with a different amount of randomness applied to each delay.
withOffset(StreamOffset) - Method in class org.acemq.amqp.core.StreamOptions
withoutPublisherConfirms() - Method in class org.acemq.amqp.transport.ConnectionConfig.Builder: Turns publisher confirms off for the caller's own publishers.
withPayload(R) - Method in interface org.acemq.amqp.api.Message: Returns a view of this message with a different payload, preserving all metadata.
withPriority(int) - Method in class org.acemq.amqp.core.PublishOptions: Publishes at the given priority.
withRetry(RetryPolicy) - Method in class org.acemq.amqp.core.ConsumerOptions: Retries failures on a schedule, never in a sleeping handler.
withRetry(RetryPolicy) - Method in class org.acemq.amqp.core.PipelineBuilder: Retries the most recently declared step on a schedule, never in a sleeping handler: the engine holds a short wait and the broker's queues hold a long one.
wrapping(Codec, ClaimCheckStore) - Static method in class org.acemq.amqp.patterns.ClaimCheckCodec
wrapping(Codec, ClaimCheckStore, int) - Static method in class org.acemq.amqp.patterns.ClaimCheckCodec
wrapping(Codec, Keyring) - Static method in class org.acemq.amqp.crypto.EncryptedCodec
Writes are atomic - Search tag in class org.acemq.amqp.patterns.FilesystemClaimCheckStore: Section

X

XmlCodec - Class in org.acemq.amqp.codec.xml: Reads and writes XML.
XmlCodec() - Constructor for class org.acemq.amqp.codec.xml.XmlCodec: Uses a mapper that ignores unknown elements and refuses external entities.
XmlCodec(XmlMapper) - Constructor for class org.acemq.amqp.codec.xml.XmlCodec
XmlCodecProvider - Class in org.acemq.amqp.codec.xml: Announces XmlCodec to the engine as xml.
XmlCodecProvider() - Constructor for class org.acemq.amqp.codec.xml.XmlCodecProvider

Y

YamlCodec - Class in org.acemq.amqp.codec.yaml: Reads and writes YAML.
YamlCodec() - Constructor for class org.acemq.amqp.codec.yaml.YamlCodec: Uses a mapper that writes block-style YAML and ignores unknown keys.
YamlCodec(ObjectMapper) - Constructor for class org.acemq.amqp.codec.yaml.YamlCodec
YamlCodecProvider - Class in org.acemq.amqp.codec.yaml: Announces YamlCodec to the engine as yaml.
YamlCodecProvider() - Constructor for class org.acemq.amqp.codec.yaml.YamlCodecProvider

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