Sha256: 8689b0c34996f4312fcf572d1cf866c0ce2dcc0309ed496da755f77d885a085f
Contents?: true
Size: 805 Bytes
Versions: 8
Compression:
Stored size: 805 Bytes
Contents
module BBK
module AMQP
class Consumer
attr_reader connection: untyped
attr_reader queue_name: String
attr_reader queue: untyped
attr_reader options: Hash[String|Symbol, untyped]
attr_reader logger: Logger|BBK::Utils::_ProxyObject
def initialize: (untyped, ?queue_name: String?, **untyped) -> void
def protocols: () -> Array[String]
def run: (BBK::App::Dispatcher::MessageStream) -> void
def ack: (BBK::App::Dispatcher::_IncomingMessage, *untyped, ?answer: BBK::App::Dispatcher::_Message, **untyped) -> void
def nack: (BBK::App::Dispatcher::_IncomingMessage, *untyped, ?error: untyped, ?requeue: untyped, **untyped) -> void
def stop: () -> void
def close: () -> void
def sync?: () -> bool
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems