diff options
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java index eb6cc06f52..00942d6445 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java @@ -147,7 +147,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j false, // internal true, // nowait false, // passive - _session.getTicket(), // ticket + 0, // ticket destination.getExchangeClass()); // type _protocolHandler.writeFrame(declare); @@ -462,7 +462,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j immediate, // immediate mandatory, // mandatory destination.getRoutingKey(), // routingKey - _session.getTicket()); // ticket + 0); // ticket message.prepareForSending(); ByteBuffer payload = message.getData(); |