diff options
| author | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-04-26 23:56:23 +0100 |
|---|---|---|
| committer | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-04-26 23:56:23 +0100 |
| commit | e954a0bf0d30c21b5563db2fd07e5d85d076edc2 (patch) | |
| tree | e260702b2a6782499cbc92b67cfbca2e439cc41a /examples/amqp_sendstring.c | |
| parent | e4614ed78b85be70a6bd973a857205c4b7dcd639 (diff) | |
| download | rabbitmq-c-github-ask-e954a0bf0d30c21b5563db2fd07e5d85d076edc2.tar.gz | |
Avoid stomping on flags during content properties encoding.
Diffstat (limited to 'examples/amqp_sendstring.c')
| -rw-r--r-- | examples/amqp_sendstring.c | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/examples/amqp_sendstring.c b/examples/amqp_sendstring.c index 6fe540d..77d8fd3 100644 --- a/examples/amqp_sendstring.c +++ b/examples/amqp_sendstring.c @@ -86,14 +86,19 @@ int main(int argc, char const * const *argv) { die_on_amqp_error(amqp_login(conn, "/", 131072, AMQP_SASL_METHOD_PLAIN, "guest", "guest"), "Logging in"); - die_on_error(amqp_basic_publish(conn, - amqp_cstring_bytes(exchange), - amqp_cstring_bytes(routingkey), - 0, - 0, - NULL, - amqp_cstring_bytes(messagebody)), - "Publishing"); + { + amqp_basic_properties_t props; + props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG; + props.content_type = amqp_cstring_bytes("text/plain"); + die_on_error(amqp_basic_publish(conn, + amqp_cstring_bytes(exchange), + amqp_cstring_bytes(routingkey), + 0, + 0, + &props, + amqp_cstring_bytes(messagebody)), + "Publishing"); + } printf("Waiting for frames...\n"); while (1) { |