Package com.eqixiac.equinix.messaging.transport

package com.eqixiac.equinix.messaging.transport
Optional transport layer for the Equinix Messaging Gateway: EmgListener drives an EmgReceiver (peek-lock receive, explicit settlement) and feeds the transport-agnostic EmgMessageParser. This package has no third-party messaging dependency; the Azure Service Bus binding lives in com.eqixiac.equinix.messaging.transport.servicebus.
  • Class
    Description
    EmgDelivery
    One message received in peek-lock mode, together with its settlement operations.
    EmgListener
    Pulls messages from an EmgReceiver, parses them with EmgMessageParser, dispatches them to an EmgMessageHandler and settles each one explicitly: complete when the handler returns normally; abandon when the handler throws (the broker redelivers it; after the queue's max delivery count Service Bus dead-letters it itself); dead-letter with reason "EmgUnparseableMessage" when the body is not an EMG envelope (redelivery could never succeed).
    EmgReceiver
    A peek-lock receiver bound to one EMG queue (or topic subscription).