class

LavinMQ::Shovel::Destination

Inherits Reference < Object

Instance methods

listener

The listener a Destination reports delivery Outcomes to (see OutcomeListener). Registered once by the Runner before starting. Defaults to a no-op so an unregistered or NoAck destination reports into the void rather than nil-checking.

Source
listener=(listener : OutcomeListener)

The listener a Destination reports delivery Outcomes to (see OutcomeListener). Registered once by the Runner before starting. Defaults to a no-op so an unregistered or NoAck destination reports into the void rather than nil-checking.

Source
push(msg) : Nil
Source
start
Source
started?
Source
stop
Source