| /dports/devel/amqp-cpp/AMQP-CPP-4.1.4/include/amqpcpp/ |
| H A D | channel.h | 243 …arget, const std::string &routingkey, const Table &arguments) { return _implementation->bindExchan… in bindExchange() argument
244 …d::string &target, const std::string &routingkey) { return _implementation->bindExchange(source, t… in bindExchange() argument
257 …urce, const std::string &routingkey, const Table &arguments) { return _implementation->unbindExcha… in unbindExchange() argument
258 …::string &source, const std::string &routingkey) { return _implementation->unbindExchange(target, … in unbindExchange() argument
307 …&queue, const std::string &routingkey, const Table &arguments) { return _implementation->bindQueue… in bindQueue() argument
308 …std::string &queue, const std::string &routingkey) { return _implementation->bindQueue(exchange, q… in bindQueue() argument
320 …ueue, const std::string &routingkey, const Table &arguments) { return _implementation->unbindQueu… in unbindQueue() argument
321 …td::string &queue, const std::string &routingkey) { return _implementation->unbindQueue(exchange, … in unbindQueue() argument
|
| H A D | message.h | 139 Message(std::string exchange, std::string routingkey) : in Message() argument
140 Envelope(nullptr, 0), _exchange(std::move(exchange)), _routingkey(std::move(routingkey)) in Message()
171 const std::string &routingkey() const in routingkey() function
|
| H A D | channelimpl.h | 313 …nst std::string &source, const std::string &target, const std::string &routingkey, const Table &ar…
326 …nst std::string &source, const std::string &target, const std::string &routingkey, const Table &ar…
361 …string &exchangeName, const std::string &queueName, const std::string &routingkey, const Table &ar…
374 …string &exchangeName, const std::string &queueName, const std::string &routingkey, const Table &ar…
|
| H A D | deferredextreceiver.h | 65 virtual void initialize(const std::string &exchange, const std::string &routingkey) override;
|
| H A D | deferredreceiver.h | 54 virtual void initialize(const std::string &exchange, const std::string &routingkey);
|
| H A D | callbacks.h | 61 …llback = std::function<void(const std::string &exchange, const std::string &routingkey)>;
|
| /dports/net/kamailio/kamailio-5.4.5/src/modules/rabbitmq/ |
| H A D | rabbitmq.c | 233 amqp_cstring_bytes(routingkey->s), 0, 0, &props, in ki_rabbitmq_publish()
263 str exchange, routingkey, messagebody, contenttype; in rabbitmq_publish() local
271 if(get_str_fparam(&routingkey, msg, (fparam_t *)in_routingkey) < 0) { in rabbitmq_publish()
286 return ki_rabbitmq_publish(msg, &exchange, &routingkey, &contenttype, in rabbitmq_publish()
291 str *routingkey, str *contenttype, str *messagebody, in rabbitmq_publish_consume_helper() argument
401 amqp_cstring_bytes(routingkey->s), 0, 0, &props, in rabbitmq_publish_consume_helper()
506 str *routingkey, str *contenttype, str *messagebody, str *dpv) in ki_rabbitmq_publish_consume() argument
521 return rabbitmq_publish_consume_helper(msg, exchange, routingkey, in ki_rabbitmq_publish_consume()
529 str exchange, routingkey, messagebody, contenttype; in rabbitmq_publish_consume() local
538 if(get_str_fparam(&routingkey, msg, (fparam_t *)in_routingkey) < 0) { in rabbitmq_publish_consume()
[all …]
|
| /dports/devel/amqp-cpp/AMQP-CPP-4.1.4/src/ |
| H A D | deferredextreceiver.cpp | 26 void DeferredExtReceiver::initialize(const std::string &exchange, const std::string &routingkey) in initialize() argument
29 DeferredReceiver::initialize(exchange, routingkey); in initialize()
32 if (_messageCallback) _message.construct(exchange, routingkey); in initialize()
|
| H A D | channelimpl.cpp | 314 …nst std::string &source, const std::string &target, const std::string &routingkey, const Table &ar… in bindExchange() argument
317 return push(ExchangeBindFrame(_id, target, source, routingkey, false, arguments)); in bindExchange()
331 …nst std::string &source, const std::string &target, const std::string &routingkey, const Table &ar… in unbindExchange() argument
334 return push(ExchangeUnbindFrame(_id, target, source, routingkey, false, arguments)); in unbindExchange()
387 …string &exchangeName, const std::string &queueName, const std::string &routingkey, const Table &ar… in bindQueue() argument
390 return push(QueueBindFrame(_id, queueName, exchangeName, routingkey, false, arguments)); in bindQueue()
404 …st std::string &exchange, const std::string &queue, const std::string &routingkey, const Table &ar… in unbindQueue() argument
407 return push(QueueUnbindFrame(_id, queue, exchange, routingkey, arguments)); in unbindQueue()
|
| H A D | deferredreceiver.cpp | 28 void DeferredReceiver::initialize(const std::string &exchange, const std::string &routingkey) in initialize() argument
31 if (_startCallback) _startCallback(exchange, routingkey); in initialize()
|
| H A D | exchangebindframe.h | 140 const std::string& routingkey() const in routingkey() function
|
| H A D | exchangeunbindframe.h | 140 const std::string& routingkey() const in routingkey() function
|
| /dports/net/rabbitmq-c-devel/rabbitmq-c-0.10.0/examples/ |
| H A D | amqp_sendstring.c | 50 char const *routingkey; in main() local
65 routingkey = argv[4]; in main()
92 amqp_cstring_bytes(routingkey), 0, 0, in main()
|
| H A D | amqp_rpc_sendstring_client.c | 52 char const *routingkey; in main() local
68 routingkey = argv[4]; in main()
133 amqp_cstring_bytes(routingkey), 0, 0, in main()
|
| /dports/net/rabbitmq-c/rabbitmq-c-0.11.0/examples/ |
| H A D | amqp_sendstring.c | 50 char const *routingkey; in main() local
65 routingkey = argv[4]; in main()
92 amqp_cstring_bytes(routingkey), 0, 0, in main()
|
| H A D | amqp_rpc_sendstring_client.c | 52 char const *routingkey; in main() local
68 routingkey = argv[4]; in main()
133 amqp_cstring_bytes(routingkey), 0, 0, in main()
|
| /dports/net/rabbitmq-c-devel/rabbitmq-c-0.10.0/ |
| H A D | README.md | 104 Delivery 1, exchange amq.direct routingkey test
|
| /dports/net/rabbitmq-c/rabbitmq-c-0.11.0/ |
| H A D | README.md | 121 Delivery 1, exchange amq.direct routingkey test
|
| /dports/net/kamailio/kamailio-5.4.5/src/modules/kazoo/ |
| H A D | README | 578 kazoo_query(exchange, routingkey, payload);
|
| /dports/devel/amqp-cpp/AMQP-CPP-4.1.4/ |
| H A D | README.md | 1025 * @param routingkey the routing key
|