From 26927ebf94c220a82e206350b3bb33def48aa8b7 Mon Sep 17 00:00:00 2001 From: Alexandru Scvortov Date: Fri, 13 Aug 2010 15:44:04 +0100 Subject: partial acks for persistent messages The publisher gets an ack in the following cases: - the broker receives a transient message (after the exchange has been resolved), - the broker sends the persistent message to a consumer (regardless of whether the consumer acks that message, rejects it, etc.). Still to do: - the broker writes the message to disk. --- include/rabbit.hrl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'include') diff --git a/include/rabbit.hrl b/include/rabbit.hrl index bf680217..e8255346 100644 --- a/include/rabbit.hrl +++ b/include/rabbit.hrl @@ -66,10 +66,10 @@ -record(listener, {node, protocol, host, port}). -record(basic_message, {exchange_name, routing_key, content, guid, - is_persistent}). + is_persistent, msg_seq_no, origin}). -record(ssl_socket, {tcp, ssl}). --record(delivery, {mandatory, immediate, txn, sender, message, msg_seq_no}). +-record(delivery, {mandatory, immediate, txn, sender, message}). -record(amqp_error, {name, explanation, method = none}). -record(event, {type, props, timestamp}). -- cgit v1.2.1