diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-13 15:44:04 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-13 15:44:04 +0100 |
| commit | 4883ff548fb8761684177e8fc77ee212e51a3a81 (patch) | |
| tree | 7f75065fa8a06bfeae6672efcc067e8afb55ce55 /include | |
| parent | 3a4cf175f8da0de9eca9619b218a18530c0ac55c (diff) | |
| download | rabbitmq-server-git-4883ff548fb8761684177e8fc77ee212e51a3a81.tar.gz | |
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.
Diffstat (limited to 'include')
| -rw-r--r-- | include/rabbit.hrl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/include/rabbit.hrl b/include/rabbit.hrl index bf68021702..e8255346c2 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}). |