Searched refs:_create_exchange (Results 1 – 5 of 5) sorted by relevance
/dports/net/py-rabbitpy/rabbitpy-1.0.0/rabbitpy/ |
H A D | simple.py | 187 _create_exchange(uri, exchange_name, exchange.DirectExchange, durable) 201 _create_exchange(uri, exchange_name, exchange.FanoutExchange, durable) 215 _create_exchange(uri, exchange_name, exchange.HeadersExchange, durable) 229 _create_exchange(uri, exchange_name, exchange.TopicExchange, durable) 247 def _create_exchange(uri, exchange_name, exchange_class, durable): function
|
/dports/devel/py-celery/celery-4.4.7/celery/backends/ |
H A D | rpc.py | 133 self.exchange = self._create_exchange( 150 def _create_exchange(self, name, type='direct', delivery_mode=2): member in RPCBackend
|
H A D | amqp.py | 75 self.exchange = self._create_exchange( 81 def _create_exchange(self, name, type='direct', delivery_mode=2): member in AMQPBackend
|
/dports/devel/py-celery/celery-4.4.7/t/unit/backends/ |
H A D | test_rpc.py | 98 ex = self.b._create_exchange('name')
|
/dports/net/py-kombu/kombu-4.6.11/kombu/ |
H A D | entity.py | 610 self._create_exchange(nowait=nowait, channel=channel) 615 def _create_exchange(self, nowait=False, channel=None): member in Queue
|