Commit 1403f1e2 authored by Guillaume Surrel's avatar Guillaume Surrel
Browse files

Add noAck property.

parent f32c99f3
......@@ -47,8 +47,10 @@ public class Deliver implements Serializable {
public long proxyId;
public String queueName;
public long msgId;
public boolean noAck;
public Deliver(AMQP.Basic.Deliver deliver, BasicProperties properties, byte[] body, long msgId, short serverId, long proxyId, String queueName) {
public Deliver(AMQP.Basic.Deliver deliver, BasicProperties properties, byte[] body, long msgId,
short serverId, long proxyId, String queueName, boolean noAck) {
this.deliver = deliver;
this.properties = properties;
this.body = body;
......@@ -56,6 +58,7 @@ public class Deliver implements Serializable {
this.proxyId = proxyId;
this.queueName = queueName;
this.msgId = msgId;
this.noAck = noAck;
}
}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment