From ed499c0211e32587d6b2e07ada690e5116d57f28 Mon Sep 17 00:00:00 2001 From: Florian Forster Date: Mon, 22 Mar 2010 19:52:09 +0100 Subject: [PATCH] amqp plugin: Fix a typo. --- src/amqp.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/amqp.c b/src/amqp.c index 0b470e10..512c3349 100644 --- a/src/amqp.c +++ b/src/amqp.c @@ -124,7 +124,7 @@ static int amqp_write(const data_set_t *ds, const value_list_t *vl, user_data_t return (1); } amqp_channel_open(conn, 1); - if (amqp_rpc_reply.reply_type != AMQP_RESPONSE_NORMAL) + if (reply.reply_type != AMQP_RESPONSE_NORMAL) { amqp_connection_close(conn, AMQP_REPLY_SUCCESS); amqp_destroy_connection(conn); -- 2.30.2