[rabbitmq-discuss] Headers exchange with rabbitmq-c?

Mon Sep 24 13:22:15 BST 2012

So far I have tried this, without success:

     amqp_table_entry_t entries[1];
     amqp_table_t table;

     entries[0].key = amqp_cstring_bytes("test");
     entries[0].value.kind = AMQP_FIELD_KIND_UTF8;
     entries[0].value.value.bytes = amqp_cstring_bytes("test");

     table.num_entries = 1;
     table.entries = entries;
     qsort(table.entries, table.num_entries, sizeof(amqp_table_entry_t), 
&amqp_table_entry_cmp);

     amqp_basic_properties_t props;
     props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | 
AMQP_BASIC_DELIVERY_MODE_FLAG;
     props.content_type = amqp_cstring_bytes("text/plain");
     props.delivery_mode = 2; /* persistent delivery mode */
     props.headers = table;
     amqp_basic_publish(
             self->conn,
             1,
             amqp_cstring_bytes("test"),
             amqp_cstring_bytes(""),
             0,
             0,
             &props,
             amqp_cstring_bytes("test"));

On 09/24/12 13:30, Attila Nagy wrote:
> Hi,
>
> I would like to use headers exchange with rabbitmq-c, but I couldn't 
> yet find out how could I specify custom headers for a message.
> Could somebody help me out (and the others who asked this on the net) 
> with an example?
>
> Thanks,