/dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/t/ |
H A D | 027_bad_socket_detection.t | 13 ok !$helper->exchange_delete, "no socket, no exchange_delete";
|
/dports/net/py-txamqp/txAMQP-0.8.2/src/txamqp/test/ |
H A D | test_exchange.py | 348 yield c2.exchange_delete(exchange="test_different_declared_type_exchange") 369 yield c2.exchange_delete(
|
H A D | test_queue.py | 84 yield channel.exchange_delete(exchange="test-exchange")
|
/dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/t/lib/NAR/ |
H A D | Helper.pm | 205 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 D | kombu.transport.virtual.rst | 59 .. automethod:: exchange_delete
|
/dports/devel/p5-Test-Net-RabbitMQ/Test-Net-RabbitMQ-0.13/t/ |
H A D | queue.t | 46 lives_ok { $mq->exchange_delete(1, 'bind-twice') } 'ex';
|
/dports/devel/py-pika/pika-1.1.0/tests/acceptance/ |
H A D | blocking_adapter_test.py | 807 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 D | async_adapter_tests.py | 585 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 D | Changes | 15 * Partially implemented exchange_delete() and queue_delete() methods. These
|
H A D | README.md | 104 exchange_delete($channel, $exchange, $options)
|
/dports/net/py-kombu/kombu-4.6.11/t/ |
H A D | mocks.py | 82 def exchange_delete(self, *args, **kwargs): member in Channel
|
/dports/net/py-rabbitpy/rabbitpy-1.0.0/rabbitpy/ |
H A D | amqp.py | 239 def exchange_delete(self, exchange='', if_unused=False, member in AMQP
|
/dports/net/py-txamqp/txAMQP-0.8.2/src/txamqp/ |
H A D | testlib.py | 152 yield ch.exchange_delete(exchange=ex)
|
/dports/devel/p5-Test-Net-RabbitMQ/Test-Net-RabbitMQ-0.13/lib/Test/Net/ |
H A D | RabbitMQ.pm | 209 sub exchange_delete { method in Test::Net::RabbitMQ
|
/dports/net/py-kombu/kombu-4.6.11/t/unit/transport/virtual/ |
H A D | test_base.py | 242 c.exchange_delete(ex) 249 c.exchange_delete(ex)
|
/dports/devel/py-pika/pika-1.1.0/tests/unit/ |
H A D | channel_tests.py | 334 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 D | channel.py | 858 def exchange_delete(self, exchange, if_unused=False, member in Channel
|
/dports/net/py-kombu/kombu-4.6.11/kombu/ |
H A D | entity.py | 289 return self.channel.exchange_delete(exchange=self.name,
|
/dports/net/py-kombu/kombu-4.6.11/kombu/transport/ |
H A D | qpid.py | 734 def exchange_delete(self, exchange_name, **kwargs): member in Channel
|
/dports/devel/py-pika/pika-1.1.0/pika/adapters/ |
H A D | blocking_connection.py | 2391 def exchange_delete(self, exchange=None, if_unused=False): member in BlockingChannel 2403 self._impl.exchange_delete(
|
H A D | twisted_connection.py | 825 def exchange_delete(self, exchange=None, if_unused=False): member in TwistedChannel
|
/dports/net/py-amqp/amqp-2.6.1/amqp/ |
H A D | channel.py | 617 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 D | routing.rst | 457 See :meth:`amqp:Channel.exchange_delete <amqp.channel.Channel.exchange_delete>`
|
/dports/net/py-amqp/amqp-2.6.1/t/unit/ |
H A D | test_channel.py | 157 self.c.exchange_delete('foo')
|
/dports/net/py-amqp/amqp-2.6.1/t/integration/ |
H A D | test_integration.py | 1066 ret = ch.exchange_delete('foo')
|