Index

A B C D E H I L M N O Q R S T
All Classes and Interfaces|All Packages

A

ack(QueueName, MessageId, AckOptions) - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

B

build() - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Builds and recovers the queue service.

C

clock() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns the value of the clock record component.

clock(Clock) - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Sets the clock.

close() - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

D

deadLettered() - Method in record class org.j7m.middleware.messaging.MessagingHealth

Returns the value of the deadLettered record component.

directory(Path) - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Sets a directory for a new file durable log.

durableLog() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns the value of the durableLog record component.

durableLog(DurableLog) - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Sets an existing durable log.

DurableQueueBuilder - Class in org.j7m.middleware.messaging

Builder for LogBackedDurableQueue.

DurableQueueBuilder() - Constructor for class org.j7m.middleware.messaging.DurableQueueBuilder

Creates a builder.

DurableQueueConfig - Record Class in org.j7m.middleware.messaging

Immutable durable queue configuration.

DurableQueueConfig(DurableLog, QueueOptions, OutboxOptions, InboxOptions, Clock) - Constructor for record class org.j7m.middleware.messaging.DurableQueueConfig

Creates a borrowed-log configuration using the default event payload limit derived from the supplied durable log.

DurableQueueConfig(DurableLog, QueueOptions, OutboxOptions, InboxOptions, Clock, boolean, long) - Constructor for record class org.j7m.middleware.messaging.DurableQueueConfig

Creates validated configuration.

DurableQueueFactory - Class in org.j7m.middleware.messaging

Factory for durable queue services.

E

enqueue(QueueName, QueueMessage, EnqueueOptions) - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

equals(Object) - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

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

equals(Object) - Method in record class org.j7m.middleware.messaging.MessagingHealth

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

H

hashCode() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns a hash code value for this object.

hashCode() - Method in record class org.j7m.middleware.messaging.MessagingHealth

Returns a hash code value for this object.

health() - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

Returns lightweight health.

I

inboxOptions() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns the value of the inboxOptions record component.

inboxOptions(InboxOptions) - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Sets inbox options.

inboxStatus() - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

L

lastError() - Method in record class org.j7m.middleware.messaging.MessagingHealth

Returns the value of the lastError record component.

lease(QueueName, ConsumerId, LeaseOptions) - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

LogBackedDurableQueue - Class in org.j7m.middleware.messaging

Local durable-log-backed queue, outbox, and inbox implementation.

LogBackedDurableQueue(DurableQueueConfig) - Constructor for class org.j7m.middleware.messaging.LogBackedDurableQueue

Opens and recovers a log-backed queue.

M

maxEventPayloadBytes() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns the value of the maxEventPayloadBytes record component.

MessagingHealth - Record Class in org.j7m.middleware.messaging

Lightweight messaging health summary.

MessagingHealth(boolean, long, long, String) - Constructor for record class org.j7m.middleware.messaging.MessagingHealth

Creates health summary.

N

nack(QueueName, MessageId, NackOptions) - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

O

open() - Method in record class org.j7m.middleware.messaging.MessagingHealth

Returns the value of the open record component.

open(Path) - Static method in class org.j7m.middleware.messaging.DurableQueueFactory

Opens a log-backed durable queue rooted at the directory.

org.j7m.messaging - module org.j7m.messaging

J7M native durable queue and outbox/inbox primitives.

org.j7m.middleware.messaging - package org.j7m.middleware.messaging

outboxOptions() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns the value of the outboxOptions record component.

outboxOptions(OutboxOptions) - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Sets outbox options.

outboxStatus() - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

ownedDurableLog(DurableLog) - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Sets an existing durable log that will be closed by the queue.

ownsDurableLog() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns the value of the ownsDurableLog record component.

Q

queueOptions() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns the value of the queueOptions record component.

queueOptions(QueueOptions) - Method in class org.j7m.middleware.messaging.DurableQueueBuilder

Sets queue options.

queues() - Method in record class org.j7m.middleware.messaging.MessagingHealth

Returns the value of the queues record component.

R

record(QueueName, QueueMessage, EnqueueOptions) - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

record(DedupeKey, String, InboxOptions) - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

recover() - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

Replays durable messaging events and rebuilds state.

recoveryReport() - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

Returns the latest recovery report.

relayPending() - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

S

status(QueueName) - Method in class org.j7m.middleware.messaging.LogBackedDurableQueue

T

toString() - Method in record class org.j7m.middleware.messaging.DurableQueueConfig

Returns a string representation of this record class.

toString() - Method in record class org.j7m.middleware.messaging.MessagingHealth

Returns a string representation of this record class.

A B C D E H I L M N O Q R S T
All Classes and Interfaces|All Packages