Class AnnotationQueueConsumer

java.lang.Object
org.j7m.middleware.examples.annotation.AnnotationQueueConsumer
public final class AnnotationQueueConsumer extends Object
Annotation-first durable queue consumer example.

The queue-related annotations are descriptor metadata. The injected DurableQueue remains the public API that enforces leases, retry, dead-letter, outbox, and inbox semantics. The example avoids exposing queue payload bytes in status or audit output.

  • Constructor Details

    • AnnotationQueueConsumer

      @Inject public AnnotationQueueConsumer(@J7mResource("annotation-events") org.j7m.middleware.api.messaging.DurableQueue queue, AnnotationExampleAudit audit)
      Creates a consumer with a public durable queue capability.
      Parameters:
      queue - injected durable queue
      audit - safe audit collector

  • Method Details

    • consume

      @DurableQueueConsumer(queue="annotation-events") @InboxHandler @OutboxPublisher("annotation-outbox") @Backpressure(maxConcurrent=4) @Retry(maxAttempts=2) public String consume(String eventId)
      Consumes one queue message id.
      Parameters:
      eventId - public event id
      Returns:
      safe result

    • deadLetter

      @DeadLetterHandler public String deadLetter(String eventId)
      Handles a failed message as a safe dead-letter summary.
      Parameters:
      eventId - public event id
      Returns:
      safe dead-letter result