| /dports/net/py-amqplib/amqplib-1.0.2/tests/client_0_8/ |
| H A D | test_channel.py | 65 self.ch.basic_publish(msg, routing_key=qname)
89 self.ch.basic_publish(msg, 'amq.direct', routing_key=my_routing_key)
100 self.ch.basic_publish(msg, 'amq.direct', routing_key=my_routing_key)
110 self.ch.basic_publish(msg, 'amq.direct', routing_key=my_routing_key)
120 self.ch.basic_publish(msg, 'amq.direct', routing_key=my_routing_key)
131 self.ch.basic_publish(msg, 'amq.direct', routing_key=my_routing_key)
212 self.ch.basic_publish(msg, routing_key=qname)
228 self.ch.basic_publish(msg, 'unittest.fanout')
266 self.ch.basic_publish(msg, 'unittest.fanout')
267 self.ch.basic_publish(msg, 'unittest.fanout', immediate=True)
[all …]
|
| /dports/net/py-txamqp/txAMQP-0.8.2/src/txamqp/test/ |
| H A D | test_basic.py | 159 channel.basic_publish(routing_key="test-queue-4", content=Content("One"))
163 channel.basic_publish(routing_key="test-queue-4", content=Content("Two"))
189 channel.basic_publish(routing_key="test-ack-queue", content=Content("One"))
235 channel.basic_publish(routing_key="test-requeue", content=Content("One"))
236 channel.basic_publish(routing_key="test-requeue", content=Content("Two"))
238 channel.basic_publish(routing_key="test-requeue", content=Content("Four"))
239 channel.basic_publish(routing_key="test-requeue", content=Content("Five"))
392 channel.basic_publish(routing_key="test-get", content=msg)
426 channel.basic_publish(routing_key="test-get", content=msg)
494 channel.basic_publish(routing_key="test-get-bin", content=msg_binary)
[all …]
|
| H A D | test_queue.py | 40 channel.basic_publish(exchange="test-exchange", routing_key="key", content=Content("one"))
41 channel.basic_publish(exchange="test-exchange", routing_key="key", content=Content("two"))
42 channel.basic_publish(exchange="test-exchange", routing_key="key", content=Content("three"))
55 channel.basic_publish(exchange="test-exchange", routing_key="key", content=Content("four"))
167 channel.basic_publish(routing_key="delete-me", content=Content("a"))
168 channel.basic_publish(routing_key="delete-me", content=Content("b"))
169 channel.basic_publish(routing_key="delete-me", content=Content("c"))
217 channel.basic_publish(routing_key="delete-me-2", content=Content("message"))
|
| H A D | test_tx.py | 160 channel.basic_publish(routing_key=name_a, content=Content("Message %d" % i))
162 channel.basic_publish(routing_key=key, exchange="amq.direct", content=Content("Message 6"))
163 channel.basic_publish(routing_key=topic, exchange="amq.topic", content=Content("Message 7"))
190 …channel.basic_publish(routing_key=topic, exchange="amq.topic", content=Content("TxMessage %d" % i))
192 … channel.basic_publish(routing_key=key, exchange="amq.direct", content=Content("TxMessage 6"))
193 channel.basic_publish(routing_key=name_a, content=Content("TxMessage 7"))
205 … channel.basic_publish(routing_key="commit-overlapping", content=Content("Message %d" % i))
|
| H A D | test_exchange.py | 72 self.channel.basic_publish(exchange=ex, routing_key="a.b")
73 self.channel.basic_publish(exchange=ex, routing_key="a.b.x.y")
74 self.channel.basic_publish(exchange=ex, routing_key="x.a.b.x")
75 self.channel.basic_publish(exchange=ex, routing_key="a.b")
86 self.channel.basic_publish(exchange=ex) # No headers, won't deliver
295 …self.channel.basic_publish(exchange="amq.match", content=Content("foobar", properties={'headers': …
|
| H A D | test_broker.py | 71 ch.basic_publish(routing_key="myqueue", content=Content(body))
79 ch.basic_publish(routing_key="otherqueue", content=Content(body))
108 …channel.basic_publish(exchange="test-exchange", routing_key="key", content=Content(body), immediat…
125 channel.basic_publish(exchange="test-exchange", routing_key="key", content=Content(body))
160 …channel.basic_publish(routing_key="flow_test_queue", content=Content("abcdefghijklmnopqrstuvwxyz"))
|
| H A D | test_example.py | 84 channel.basic_publish(exchange="test",
|
| H A D | test_testlib.py | 55 self.channel.basic_publish(routing_key="full")
|
| /dports/devel/py-pika/pika-1.1.0/tests/acceptance/ |
| H A D | blocking_adapter_test.py | 1660 ch.basic_publish(exg_name, routing_key='',
2322 ch.basic_publish('',
2329 channel.basic_publish(
2369 ch.basic_publish('',
2374 ch.basic_publish('',
2425 ch.basic_publish('',
2430 ch.basic_publish('',
2479 ch.basic_publish('',
2484 ch.basic_publish('',
2543 lambda: ch.basic_publish(
[all …]
|
| H A D | twisted_adapter_tests.py | 422 d = self.channel.basic_publish(*args, **kwargs)
429 self.pika_channel.basic_publish.assert_called_once_with(
438 d = self.channel.basic_publish(None, None, None)
439 self.pika_channel.basic_publish.assert_not_called()
496 d = self.channel.basic_publish("testexch", "testrk", "testbody")
516 d = self.channel.basic_publish("testexch", "testrk", "testbody")
538 d = self.channel.basic_publish("testexch", "testrk", "testbody")
569 d = self.channel.basic_publish("testexch", "testrk", "testbody")
597 d1 = self.channel.basic_publish("testexch", "testrk", "testbody1")
598 d2 = self.channel.basic_publish("testexch", "testrk", "testbody2")
|
| /dports/devel/py-pika/pika-1.1.0/examples/ |
| H A D | publish.py | 21 channel.basic_publish(
28 channel.basic_publish(
35 channel.basic_publish(
|
| H A D | direct_reply_to.py | 49 channel.basic_publish(
61 ch.basic_publish('', routing_key=properties.reply_to, body='Polo')
|
| H A D | heartbeat_and_blocked_timeouts.py | 39 chan.basic_publish('', 'my-alphabet-queue', "abc")
|
| H A D | producer.py | 47 main_channel.basic_publish(
|
| /dports/net/rabbitmq-c-devel/rabbitmq-c-0.10.0/tests/ |
| H A D | test_basic.c | 77 void basic_publish(amqp_connection_state_t connectionState_, in basic_publish() function
145 basic_publish(connection_state, msg_to_publish); in publish_and_basic_get_message()
187 basic_publish(connection_state, msg_to_publish); in publish_and_consume_message()
|
| /dports/net/rabbitmq-c/rabbitmq-c-0.11.0/tests/ |
| H A D | test_basic.c | 77 void basic_publish(amqp_connection_state_t connectionState_, in basic_publish() function
145 basic_publish(connection_state, msg_to_publish); in publish_and_basic_get_message()
187 basic_publish(connection_state, msg_to_publish); in publish_and_consume_message()
|
| /dports/www/kanboard/kanboard-1.2.21/libs/SimpleQueue/Adapter/ |
| H A D | AmqpQueueAdapter.php | 58 $this->channel->basic_publish($message, $this->exchange);
79 $this->channel->basic_publish($message, $this->exchange);
|
| /dports/devel/py-tinyrpc/tinyrpc-1.1.2/tinyrpc/transports/ |
| H A D | rabbitmq.py | 38 ch.basic_publish(exchange=self.exchange,
98 self.channel.basic_publish(
|
| /dports/devel/py-pika/pika-1.1.0/docs/examples/ |
| H A D | comparing_publishing_sync_async.rst | 16 channel.basic_publish('test_exchange',
37 channel.basic_publish('test_exchange',
|
| H A D | direct_reply_to.rst | 55 channel.basic_publish(
67 ch.basic_publish('', routing_key=properties.reply_to, body='Polo')
|
| H A D | tls_mutual_authentication.rst | 26 ch.basic_publish("", "foobar", "Hello, world!")
58 yield channel.basic_publish(
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_consistent_hash_exchange/examples/python/ |
| H A D | example1.py | 24 ch.basic_publish(exchange="e", routing_key=rk, body="")
|
| H A D | example2.py | 29 ch.basic_publish(exchange='e2',
|
| H A D | example3.py | 28 ch.basic_publish(exchange='e3',
|
| /dports/net/py-txamqp/txAMQP-0.8.2/src/txamqp/contrib/thrift/ |
| H A D | transport.py | 26 self.channel.basic_publish(exchange=self.exchange,
|