Home
last modified time | relevance | path

Searched refs:_create_exchange (Results 1 – 5 of 5) sorted by relevance

/dports/net/py-rabbitpy/rabbitpy-1.0.0/rabbitpy/
H A Dsimple.py187 _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 Drpc.py133 self.exchange = self._create_exchange(
150 def _create_exchange(self, name, type='direct', delivery_mode=2): member in RPCBackend
H A Damqp.py75 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 Dtest_rpc.py98 ex = self.b._create_exchange('name')
/dports/net/py-kombu/kombu-4.6.11/kombu/
H A Dentity.py610 self._create_exchange(nowait=nowait, channel=channel)
615 def _create_exchange(self, nowait=False, channel=None): member in Queue