Author: rgodfrey
Date: Fri Feb 20 20:36:14 2015
New Revision: 1661212
URL: http://svn.apache.org/r1661212
Log:
QPID-6404 : [AMQP 1.0 JMS Client ] session.createMessage() should not attempt
to create a message with no body sections
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/AmqpMessageImpl.java
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/AmqpMessageImpl.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/AmqpMessageImpl.java?rev=1661212&r1=1661211&r2=1661212&view=diff
==============================================================================
---
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/AmqpMessageImpl.java
(original)
+++
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/AmqpMessageImpl.java
Fri Feb 20 20:36:14 2015
@@ -26,8 +26,10 @@ import java.util.List;
import java.util.ListIterator;
import org.apache.qpid.amqp_1_0.jms.AmqpMessage;
+import org.apache.qpid.amqp_1_0.type.Binary;
import org.apache.qpid.amqp_1_0.type.Section;
import org.apache.qpid.amqp_1_0.type.messaging.ApplicationProperties;
+import org.apache.qpid.amqp_1_0.type.messaging.Data;
import org.apache.qpid.amqp_1_0.type.messaging.DeliveryAnnotations;
import org.apache.qpid.amqp_1_0.type.messaging.Footer;
import org.apache.qpid.amqp_1_0.type.messaging.Header;
@@ -36,6 +38,8 @@ import org.apache.qpid.amqp_1_0.type.mes
public class AmqpMessageImpl extends MessageImpl implements AmqpMessage
{
+ private static final List<Section> EMPTY_MESSAGE =
+ Collections.<Section>singletonList(new Data(new Binary(new
byte[0])));
private List<Section> _sections;
protected AmqpMessageImpl(Header header,
@@ -57,7 +61,7 @@ public class AmqpMessageImpl extends Mes
new DeliveryAnnotations(new HashMap()),
new MessageAnnotations(new HashMap()), new Properties(), new
ApplicationProperties(new HashMap()), new Footer(Collections.EMPTY_MAP),
session);
- _sections = new ArrayList<Section>();
+ _sections = EMPTY_MESSAGE;
}
public int getSectionCount()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
