From 0a0d784009eadd3d7679a8cb6a73258562616af7 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Tue, 30 Jan 2007 16:40:41 +0000 Subject: Separated the errata in the XML spec file and put them into a file amqp-errara.0-9.xml. Added this file to the codegen. Fixed minor codegen bug in which fields in merged classes have repeating ordinal numbers. Added missing mandatory field to Message.Transger in the new errata file. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501456 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'java/client') diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java index dba8049657..39c4c28baf 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java @@ -579,7 +579,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j Content data = new Content(Content.TypeEnum.INLINE_T, payload); - doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,immediate); + doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,mandatory,immediate); } else { // Reference message case // Sequence is as follows @@ -599,7 +599,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j // Message.Transfer Content data = new Content(Content.TypeEnum.REF_T, referenceId.getBytes()); - doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,immediate); + doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,mandatory,immediate); //Message.Append for(Iterator it = content.iterator(); it.hasNext();){ @@ -622,7 +622,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j } private void doMessageTransfer(MessageHeaders messageHeaders,AMQDestination destination, Content content, AbstractJMSMessage message, int deliveryMode, int priority, - long timeToLive, boolean immediate)throws JMSException{ + long timeToLive, boolean mandatory, boolean immediate)throws JMSException{ try { AMQMethodBody methodBody = MessageTransferBody.createMethodBody( @@ -638,6 +638,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j destination.getExchangeName(), // String exchange messageHeaders.getExpiration(), // long expiration immediate, // boolean immediate + mandatory, // boolean mandatory messageHeaders.getMessageId(), // String messageId (short)priority, // short priority message.getJMSRedelivered(), // boolean redelivered -- cgit v1.2.1