Lines Matching refs:broker_reply
70 amqp_rpc_reply_t broker_reply;
158 broker_reply = amqp_login(s->conn, vhost_decoded, 0, s->pkt_size, 0,
161 if (broker_reply.reply_type != AMQP_RESPONSE_NORMAL) {
168 broker_reply = amqp_get_rpc_reply(s->conn);
170 if (broker_reply.reply_type != AMQP_RESPONSE_NORMAL) {
183 broker_reply = amqp_get_rpc_reply(s->conn);
184 if (!r || broker_reply.reply_type != AMQP_RESPONSE_NORMAL) {
199 broker_reply = amqp_get_rpc_reply(s->conn);
200 if (broker_reply.reply_type != AMQP_RESPONSE_NORMAL) {
209 broker_reply = amqp_get_rpc_reply(s->conn);
210 if (broker_reply.reply_type != AMQP_RESPONSE_NORMAL) {
270 amqp_rpc_reply_t broker_reply;
278 broker_reply = amqp_consume_message(s->conn, &envelope, NULL, 0);
280 if (broker_reply.reply_type != AMQP_RESPONSE_NORMAL)