class

LavinMQ::Shovel::AMQPDestination

Inherits LavinMQ::Shovel::Destination < Reference < Object

Constructors

new(name : String, uri : URI, queue : String | Nil, exchange : String | Nil = nil, exchange_key : String | Nil = nil, ack_mode : LavinMQ::Shovel::AckMode = DEFAULT_ACK_MODE, direct_user : Auth::User | Nil = nil)
Source

Instance methods

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