Lines Matching defs:conn
35 amqp_connection_state_t conn;
130 s->conn = amqp_new_connection();
131 if (!s->conn) {
139 s->socket = amqp_tcp_socket_new(s->conn);
158 broker_reply = amqp_login(s->conn, vhost_decoded, 0, s->pkt_size, 0,
167 amqp_channel_open(s->conn, DEFAULT_CHANNEL);
168 broker_reply = amqp_get_rpc_reply(s->conn);
181 r = amqp_queue_declare(s->conn, DEFAULT_CHANNEL, amqp_empty_bytes,
183 broker_reply = amqp_get_rpc_reply(s->conn);
195 amqp_queue_bind(s->conn, DEFAULT_CHANNEL, queuename,
199 broker_reply = amqp_get_rpc_reply(s->conn);
206 amqp_basic_consume(s->conn, DEFAULT_CHANNEL, queuename, amqp_empty_bytes,
209 broker_reply = amqp_get_rpc_reply(s->conn);
223 amqp_channel_close(s->conn, DEFAULT_CHANNEL, server_msg);
225 amqp_connection_close(s->conn, server_msg);
227 amqp_destroy_connection(s->conn);
252 ret = amqp_basic_publish(s->conn, DEFAULT_CHANNEL, amqp_cstring_bytes(s->exchange),
277 amqp_maybe_release_buffers(s->conn);
278 broker_reply = amqp_consume_message(s->conn, &envelope, NULL, 0);
300 amqp_channel_close(s->conn, DEFAULT_CHANNEL, AMQP_REPLY_SUCCESS);
301 amqp_connection_close(s->conn, AMQP_REPLY_SUCCESS);
302 amqp_destroy_connection(s->conn);