Index (j7m-integrations 0.1.0-SNAPSHOT API)

A B C D E F H I J M O P Q R S T V W
All Classes and Interfaces|All Packages

A

ack(String, String, String, String, long, String, long, Instant) - Method in class org.j7m.middleware.integrations.TracedQueue: Acknowledges only a committed consumer effect and records confirmed acknowledgements.
address() - Method in class org.j7m.middleware.integrations.Observability: Exposes the actual scrape address.
aggregate() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns the value of the aggregate record component.
APPLICATION_HANDLER - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Optional annotated application work; distinct from middleware RPC.
apply(Connection, byte[]) - Method in interface org.j7m.middleware.integrations.JdbcDelivery.Mutation: Applies consumer effects on the exact caller connection.
attach() - Method in class org.j7m.middleware.integrations.Observability.DetachedSpan: Attaches this span on the current thread, independently of its eventual end.
attach(TraceCarrier) - Method in class org.j7m.middleware.integrations.Observability: Attaches extracted remote context for callbacks on the current thread.

B

buffered() - Method in class org.j7m.middleware.integrations.Observability: Returns bounded exporter occupancy for health diagnostics.

C

capacity() - Method in class org.j7m.middleware.integrations.Observability: Returns the configured queue limit.
capture() - Method in class org.j7m.middleware.integrations.Observability: Captures the current official OpenTelemetry context without baggage.
carrier() - Method in class org.j7m.middleware.integrations.Observability.DetachedSpan: Returns immutable W3C propagation data without vendor state.
carrier() - Method in class org.j7m.middleware.integrations.Observability.SpanScope: Returns this span's propagation metadata.
claim(String, String, String, String, long, long, Instant) - Method in class org.j7m.middleware.integrations.TracedQueue: Claims a delivery and records an actual queue claim observation.
close() - Method in class org.j7m.middleware.integrations.Observability: Stops telemetry without waiting for an unavailable collector; queued spans are counted dropped.
close() - Method in class org.j7m.middleware.integrations.Observability.SpanScope: Restores context and performs a nonblocking bounded export offer.
CLUSTER_STEP - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Fenced cluster lifecycle step.
consume(byte[], TracedQueue.Handler) - Method in class org.j7m.middleware.integrations.TracedQueue: Processes an encoded queue payload under its persisted remote parent.
consume(Connection, String, byte[], JdbcDelivery.Mutation, Instant) - Method in class org.j7m.middleware.integrations.JdbcDelivery: Inserts the inbox identity and applies consumer mutation in the caller's single transaction.
context() - Method in record class org.j7m.middleware.integrations.TracedQueue.Message: Returns the value of the context record component.

D

DB_INBOX - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Database consumer.
DB_OUTBOX - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Database relay.
deadLetters(String, Instant) - Method in class org.j7m.middleware.integrations.TracedQueue: Observes the actual retained dead-letter page without exporting identities.
decode(byte[]) - Static method in class org.j7m.middleware.integrations.TracedQueue: Decodes an immutable envelope, rejecting unsupported formats and trailing bytes.
digest() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns the value of the digest record component.
dropped() - Method in class org.j7m.middleware.integrations.Observability: Returns the cumulative number of spans discarded on overload/collector failure.

E

encode(TracedQueue.Message) - Static method in class org.j7m.middleware.integrations.TracedQueue: Encodes a bounded context envelope for a queue or transactional outbox.
end() - Method in class org.j7m.middleware.integrations.Observability.DetachedSpan: Ends once on any host thread and offers export without waiting for the collector.
enqueue(Connection, String, String, TracedQueue.Message, Instant, Instant) - Method in class org.j7m.middleware.integrations.JdbcDelivery: Appends an ordered message in the caller's application transaction.
envelope() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns independent encoded message bytes.
equals(Object) - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.integrations.TracedQueue.Message: Indicates whether some other object is "equal to" this one.
executionObserver() - Method in class org.j7m.middleware.integrations.Observability: Supplies automatic trace lifetimes for the production execution RPC/job/saga facades.

F

failed() - Method in class org.j7m.middleware.integrations.Observability.DetachedSpan: Marks failure without retaining an application exception or message.
failed() - Method in class org.j7m.middleware.integrations.Observability.SpanScope: Marks the span failed without retaining any throwable or sensitive message.

H

H2 - Enum constant in enum class org.j7m.middleware.integrations.JdbcDelivery.Dialect: Reference embedded/server relational database.
hashCode() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.integrations.TracedQueue.Message: Returns a hash code value for this object.

I

id() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns the value of the id record component.
initialize(Connection, JdbcDelivery.Dialect) - Static method in class org.j7m.middleware.integrations.JdbcDelivery: Creates additive integration tables; execute as an explicit migration on a dedicated connection.

J

JdbcDelivery - Class in org.j7m.middleware.integrations: JDBC transactional outbox/inbox for H2 and PostgreSQL using application-supplied drivers.
JdbcDelivery(String, Observability) - Constructor for class org.j7m.middleware.integrations.JdbcDelivery: Binds DB identities to one authenticated queue/inbox scope.
JdbcDelivery.Connections - Interface in org.j7m.middleware.integrations: Application-managed connection factory; every returned connection is independently owned.
JdbcDelivery.Dialect - Enum Class in org.j7m.middleware.integrations: Supported schema dialects; drivers are supplied by the hosting application.
JdbcDelivery.Mutation - Interface in org.j7m.middleware.integrations: Application mutation executed inside the same transaction as the inbox insertion.
JdbcDelivery.Pending - Record Class in org.j7m.middleware.integrations: Immutable persisted relay row.
JOB_RUN - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Durable job execution.
JOB_SUBMIT - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Durable job submission.

M

Message(TraceCarrier, byte[]) - Constructor for record class org.j7m.middleware.integrations.TracedQueue.Message: Copies and bounds application bytes.

O

Observability - Class in org.j7m.middleware.integrations: Concrete W3C/OpenTelemetry propagation, bounded OTLP/HTTP JSON export and Prometheus scrape.
Observability(URI, InetSocketAddress, int) - Constructor for class org.j7m.middleware.integrations.Observability: Starts a concrete exporter and bounded scrape endpoint.
Observability.DetachedSpan - Class in org.j7m.middleware.integrations: Thread-safe application span lifetime.
Observability.Operation - Enum Class in org.j7m.middleware.integrations: Fixed low-cardinality operation vocabulary.
Observability.SpanScope - Class in org.j7m.middleware.integrations: Thread-confined span lifetime.
observe(PartitionEndpoint) - Method in class org.j7m.middleware.integrations.Observability: Wraps a real partition transport and observes committed migration/status responses.
open() - Method in interface org.j7m.middleware.integrations.JdbcDelivery.Connections: Opens a fresh connection.
org.j7m.integrations - module org.j7m.integrations: Relational delivery and interoperable telemetry integrations for distributed middleware.
org.j7m.middleware.integrations - package org.j7m.middleware.integrations

P

payload() - Method in record class org.j7m.middleware.integrations.TracedQueue.Message: Returns independent payload bytes.
pending(Connection, int) - Method in class org.j7m.middleware.integrations.JdbcDelivery: Selects only the first unsent message of each aggregate, preserving send order across relays.
Pending(String, String, String, long, byte[], String) - Constructor for record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Copies message bytes.
POSTGRESQL - Enum constant in enum class org.j7m.middleware.integrations.JdbcDelivery.Dialect: PostgreSQL with BYTEA payload storage.
process(byte[]) - Method in interface org.j7m.middleware.integrations.TracedQueue.Handler: Processes an application payload without implicit queue acknowledgement.
pruneSentPayloads(Connection, Instant) - Method in class org.j7m.middleware.integrations.JdbcDelivery: Removes only payloads already confirmed sent and past their retention time.

Q

QUEUE_CONSUME - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Queue processing.
QUEUE_SEND - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Queue publication.

R

relayOnce(JdbcDelivery.Connections, ReplicatedQueue, String, int, Instant) - Method in class org.j7m.middleware.integrations.JdbcDelivery: Publishes head rows at least once and marks only confirmed queue publications in short DB transactions.
RPC - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Remote invocation.
runJob(ExecutionResult, Callable) - Method in class org.j7m.middleware.integrations.Observability: Executes a claimed job callback under the original persisted producer context.

S

SAGA_STEP - Enum constant in enum class org.j7m.middleware.integrations.Observability.Operation: Saga activity.
scope() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns the value of the scope record component.
scrape() - Method in class org.j7m.middleware.integrations.Observability: Produces Prometheus text with a fixed vocabulary and no user-controlled labels.
send(String, String, String, TracedQueue.Message, int, Instant) - Method in class org.j7m.middleware.integrations.TracedQueue: Publishes a deterministic message envelope using a stable request/message identity.
sequence() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns the value of the sequence record component.
start(Observability.Operation) - Method in class org.j7m.middleware.integrations.Observability: Starts a child of the current thread's context.
start(Observability.Operation, TraceCarrier) - Method in class org.j7m.middleware.integrations.Observability: Starts an interoperable child span using an explicit parent.
startDetached(Observability.Operation, TraceCarrier) - Method in class org.j7m.middleware.integrations.Observability: Creates a thread-safe span lifetime independent of individual context attachment scopes.

T

toString() - Method in record class org.j7m.middleware.integrations.JdbcDelivery.Pending: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.integrations.TracedQueue.Message: Returns a string representation of this record class.
TracedQueue - Class in org.j7m.middleware.integrations: Real replicated-queue facade carrying a bounded, versioned W3C context envelope.
TracedQueue(ReplicatedQueue, Observability) - Constructor for class org.j7m.middleware.integrations.TracedQueue: Creates an instrumented facade over the real queue.
TracedQueue.Handler - Interface in org.j7m.middleware.integrations: Handler called under the persisted consumer context.
TracedQueue.Message - Record Class in org.j7m.middleware.integrations: Immutable delivery envelope.

V

valueOf(String) - Static method in enum class org.j7m.middleware.integrations.JdbcDelivery.Dialect: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.j7m.middleware.integrations.Observability.Operation: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.j7m.middleware.integrations.JdbcDelivery.Dialect: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.j7m.middleware.integrations.Observability.Operation: Returns an array containing the constants of this enum class, in the order they are declared.

W

watchConsensus(NetworkConsensusNode) - Method in class org.j7m.middleware.integrations.Observability: Registers real group progress and periodically tests quorum outside data/scrape paths.
watchExecution(ExecutionClient) - Method in class org.j7m.middleware.integrations.Observability: Polls real scope-authorized execution counters without exporting identities.
watchLease(ResourceEndpoint, String) - Method in class org.j7m.middleware.integrations.Observability: Registers real lease observations without exporting the resource key or owner.

A B C D E F H I J M O P Q R S T V W
All Classes and Interfaces|All Packages