diff options
| -rw-r--r-- | examples/amqp_sendstring.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/examples/amqp_sendstring.c b/examples/amqp_sendstring.c index a26cd3a..305811b 100644 --- a/examples/amqp_sendstring.c +++ b/examples/amqp_sendstring.c @@ -42,8 +42,9 @@ int main(int argc, char const * const *argv) { { amqp_basic_properties_t props; - props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG; + 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 die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes(exchange), |