Home
last modified time | relevance | path

Searched refs:exchange_delete (Results 1 – 25 of 31) sorted by relevance

12

/dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/t/
H A D027_bad_socket_detection.t13 ok !$helper->exchange_delete, "no socket, no exchange_delete";
/dports/net/py-txamqp/txAMQP-0.8.2/src/txamqp/test/
H A Dtest_exchange.py348 yield c2.exchange_delete(exchange="test_different_declared_type_exchange")
369 yield c2.exchange_delete(
H A Dtest_queue.py84 yield channel.exchange_delete(exchange="test-exchange")
/dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/t/lib/NAR/
H A DHelper.pm205 sub exchange_delete { subroutine
217 $self->mq->exchange_delete( $self->{channel}, $exchange, { if_unused => 0 } );
570 $self->exchange_delete(undef, $exchange);
/dports/net/py-kombu/kombu-4.6.11/docs/reference/
H A Dkombu.transport.virtual.rst59 .. automethod:: exchange_delete
/dports/devel/p5-Test-Net-RabbitMQ/Test-Net-RabbitMQ-0.13/t/
H A Dqueue.t46 lives_ok { $mq->exchange_delete(1, 'bind-twice') } 'ex';
/dports/devel/py-pika/pika-1.1.0/tests/acceptance/
H A Dblocking_adapter_test.py807 self.addCleanup(connection.channel().exchange_delete, name)
816 frame = ch.exchange_delete(name)
952 self.addCleanup(connection.channel().exchange_delete, exg_name)
1443 self.addCleanup(connection.channel().exchange_delete, exg_name)
1477 self.addCleanup(connection.channel().exchange_delete, exg_name)
1527 self.addCleanup(connection.channel().exchange_delete, exg_name)
1581 self.addCleanup(connection.channel().exchange_delete, exg_name)
1650 self.addCleanup(connection.channel().exchange_delete, exg_name)
1724 self.addCleanup(connection.channel().exchange_delete, exg_name)
1862 self.addCleanup(connection.channel().exchange_delete, exg_name)
[all …]
H A Dasync_adapter_tests.py585 self.channel.exchange_delete(self.name, callback=self.on_exchange_delete)
609 channel.exchange_delete(self.name)
624 self.channel.exchange_delete(self.name)
/dports/devel/p5-Test-Net-RabbitMQ/Test-Net-RabbitMQ-0.13/
H A DChanges15 * Partially implemented exchange_delete() and queue_delete() methods. These
H A DREADME.md104 exchange_delete($channel, $exchange, $options)
/dports/net/py-kombu/kombu-4.6.11/t/
H A Dmocks.py82 def exchange_delete(self, *args, **kwargs): member in Channel
/dports/net/py-rabbitpy/rabbitpy-1.0.0/rabbitpy/
H A Damqp.py239 def exchange_delete(self, exchange='', if_unused=False, member in AMQP
/dports/net/py-txamqp/txAMQP-0.8.2/src/txamqp/
H A Dtestlib.py152 yield ch.exchange_delete(exchange=ex)
/dports/devel/p5-Test-Net-RabbitMQ/Test-Net-RabbitMQ-0.13/lib/Test/Net/
H A DRabbitMQ.pm209 sub exchange_delete { method in Test::Net::RabbitMQ
/dports/net/py-kombu/kombu-4.6.11/t/unit/transport/virtual/
H A Dtest_base.py242 c.exchange_delete(ex)
249 c.exchange_delete(ex)
/dports/devel/py-pika/pika-1.1.0/tests/unit/
H A Dchannel_tests.py334 self.obj.exchange_delete(callback_mock,
880 self.obj.exchange_delete, exchange='foo')
884 self.assertRaises(TypeError, self.obj.exchange_delete,
892 self.obj.exchange_delete('foo', callback=mock_callback)
901 self.obj.exchange_delete('foo', callback=None)
/dports/net/py-amqplib/amqplib-1.0.2/amqplib/client_0_8/
H A Dchannel.py858 def exchange_delete(self, exchange, if_unused=False, member in Channel
/dports/net/py-kombu/kombu-4.6.11/kombu/
H A Dentity.py289 return self.channel.exchange_delete(exchange=self.name,
/dports/net/py-kombu/kombu-4.6.11/kombu/transport/
H A Dqpid.py734 def exchange_delete(self, exchange_name, **kwargs): member in Channel
/dports/devel/py-pika/pika-1.1.0/pika/adapters/
H A Dblocking_connection.py2391 def exchange_delete(self, exchange=None, if_unused=False): member in BlockingChannel
2403 self._impl.exchange_delete(
H A Dtwisted_connection.py825 def exchange_delete(self, exchange=None, if_unused=False): member in TwistedChannel
/dports/net/py-amqp/amqp-2.6.1/amqp/
H A Dchannel.py617 def exchange_delete(self, exchange, if_unused=False, nowait=False, member in Channel
/dports/devel/py-celery/celery-4.4.7/docs/userguide/
H A Drouting.rst457 See :meth:`amqp:Channel.exchange_delete <amqp.channel.Channel.exchange_delete>`
/dports/net/py-amqp/amqp-2.6.1/t/unit/
H A Dtest_channel.py157 self.c.exchange_delete('foo')
/dports/net/py-amqp/amqp-2.6.1/t/integration/
H A Dtest_integration.py1066 ret = ch.exchange_delete('foo')

12