summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_api.c
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2010-08-04 15:26:05 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2010-08-04 15:26:05 +0100
commit2e46c05c78a68b77378dc35d7e354b0777787a6b (patch)
tree4cee74aa2a7f047485bb37ef361d30d961f7663f /librabbitmq/amqp_api.c
parentd749b92411f971b8db8f6a1c2b4e4a01b072619f (diff)
parent731c5101b94d9ba35dbe6e4968e572656da3fdba (diff)
downloadrabbitmq-c-2e46c05c78a68b77378dc35d7e354b0777787a6b.tar.gz
merged default into bug22951
Diffstat (limited to 'librabbitmq/amqp_api.c')
-rw-r--r--librabbitmq/amqp_api.c5
1 files changed, 3 insertions, 2 deletions
diff --git a/librabbitmq/amqp_api.c b/librabbitmq/amqp_api.c
index 2b1ed54..27fe19a 100644
--- a/librabbitmq/amqp_api.c
+++ b/librabbitmq/amqp_api.c
@@ -269,12 +269,13 @@ amqp_basic_consume_ok_t *amqp_basic_consume(amqp_connection_state_t state,
amqp_bytes_t consumer_tag,
amqp_boolean_t no_local,
amqp_boolean_t no_ack,
- amqp_boolean_t exclusive)
+ amqp_boolean_t exclusive,
+ amqp_table_t filter)
{
state->most_recent_api_result =
AMQP_SIMPLE_RPC(state, channel, BASIC, CONSUME, CONSUME_OK,
amqp_basic_consume_t,
- 0, queue, consumer_tag, no_local, no_ack, exclusive, 0);
+ 0, queue, consumer_tag, no_local, no_ack, exclusive, 0, filter);
return RPC_REPLY(amqp_basic_consume_ok_t);
}