Notice errors rather than sigsegv/sigbus

rabbitmq · Jun 5, 2010 · 3e5df50 · 3e5df50
1 parent edb0bb6
commit 3e5df50
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/tools/declare_queue.c b/tools/declare_queue.c
@@ -91,6 +91,9 @@ int main(int argc, const char **argv)
 							      0,
 							      0,
 							      AMQP_EMPTY_TABLE);
+	  if (reply == NULL) {
+	    die_rpc(amqp_get_rpc_reply(conn), "queue.declare");
+	  }
 	  write(1, reply->queue.bytes, reply->queue.len);
 	  write(1, "\n", strlen("\n"));
 	}

diff --git a/tools/delete_queue.c b/tools/delete_queue.c
@@ -91,6 +91,9 @@ int main(int argc, const char **argv)
 							    cstring_bytes(queue),
 							    if_unused,
 							    if_empty);
+	  if (reply == NULL) {
+	    die_rpc(amqp_get_rpc_reply(conn), "queue.delete");
+	  }
 	  printf("%u\n", reply->message_count);
 	}
 	close_connection(conn);