summaryrefslogtreecommitdiff
path: root/examples/amqp_unbind.c
diff options
context:
space:
mode:
Diffstat (limited to 'examples/amqp_unbind.c')
-rw-r--r--examples/amqp_unbind.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/examples/amqp_unbind.c b/examples/amqp_unbind.c
index 9a9a35c..e033702 100644
--- a/examples/amqp_unbind.c
+++ b/examples/amqp_unbind.c
@@ -38,14 +38,14 @@ int main(int argc, char const * const *argv) {
die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
"Logging in");
amqp_channel_open(conn, 1);
- die_on_amqp_error(amqp_rpc_reply, "Opening channel");
+ die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
amqp_queue_unbind(conn, 1,
amqp_cstring_bytes(queue),
amqp_cstring_bytes(exchange),
amqp_cstring_bytes(bindingkey),
AMQP_EMPTY_TABLE);
- die_on_amqp_error(amqp_rpc_reply, "Unbinding");
+ die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");