diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-30 16:40:41 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-30 16:40:41 +0000 |
| commit | 0a0d784009eadd3d7679a8cb6a73258562616af7 (patch) | |
| tree | d9ff386f7ec63c4d75b11999840a4911459c7fc1 /java/client/src | |
| parent | db6f152f26ae8de79b1aec55a16af401b97548d9 (diff) | |
| download | qpid-python-0a0d784009eadd3d7679a8cb6a73258562616af7.tar.gz | |
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
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 7 |
1 files changed, 4 insertions, 3 deletions
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 |