Repository: qpid-jms Updated Branches: refs/heads/master 19b378bee -> 5b3d2038a
Set the content type as defined in the JMS mapping spec. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/ad17c6bf Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/ad17c6bf Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/ad17c6bf Branch: refs/heads/master Commit: ad17c6bf62be2119c8183efe0b708393e45a43f1 Parents: 19b378b Author: Timothy Bish <[email protected]> Authored: Tue Sep 30 14:35:09 2014 -0400 Committer: Timothy Bish <[email protected]> Committed: Tue Sep 30 14:35:09 2014 -0400 ---------------------------------------------------------------------- .../provider/amqp/message/AmqpJmsBytesMessageFacade.java | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/ad17c6bf/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsBytesMessageFacade.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsBytesMessageFacade.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsBytesMessageFacade.java index 53ff86c..0896eb0 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsBytesMessageFacade.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsBytesMessageFacade.java @@ -47,6 +47,7 @@ public class AmqpJmsBytesMessageFacade extends AmqpJmsMessageFacade implements J */ public AmqpJmsBytesMessageFacade(AmqpConnection connection) { super(connection); + setContentType(CONTENT_TYPE); setAnnotation(JMS_MSG_TYPE, JMS_BYTES_MESSAGE); } @@ -67,9 +68,6 @@ public class AmqpJmsBytesMessageFacade extends AmqpJmsMessageFacade implements J public AmqpJmsBytesMessageFacade copy() { AmqpJmsBytesMessageFacade copy = new AmqpJmsBytesMessageFacade(connection); copyInto(copy); - - copy.setContent(getContent().copy()); - return copy; } @@ -79,11 +77,6 @@ public class AmqpJmsBytesMessageFacade extends AmqpJmsMessageFacade implements J } @Override - public String getContentType() { - return CONTENT_TYPE; - } - - @Override public boolean isEmpty() { Binary payload = getBinaryFromBody(); return payload != null && payload.getLength() > 0; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
