MCPcopy Create free account
hub / github.com/StackStorm/st2 / __init__

Method __init__

tools/queue_consumer.py:35–37  ·  view source on GitHub ↗
(self, connection, queue)

Source from the content-addressed store, hash-verified

33
34class QueueConsumer(ConsumerMixin):
35 def __init__(self, connection, queue):
36 self.connection = connection
37 self.queue = queue
38
39 def get_consumers(self, Consumer, channel):
40 return [

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected