Repository: qpid-jms Updated Branches: refs/heads/master 1e6d38092 -> da34674fe
Remove code that was only needed for use with the JMS transformer sends. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/da34674f Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/da34674f Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/da34674f Branch: refs/heads/master Commit: da34674fec15da233724f94c700b6b830a64ab92 Parents: 1e6d380 Author: Timothy Bish <tabish...@gmail.com> Authored: Wed Oct 1 09:55:04 2014 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Wed Oct 1 09:55:04 2014 -0400 ---------------------------------------------------------------------- .../org/apache/qpid/jms/provider/amqp/AmqpFixedProducer.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/da34674f/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpFixedProducer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpFixedProducer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpFixedProducer.java index 73ef680..2c2f060 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpFixedProducer.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpFixedProducer.java @@ -26,7 +26,6 @@ import java.util.Set; import javax.jms.JMSException; import org.apache.qpid.jms.JmsDestination; -import org.apache.qpid.jms.message.JmsMessage; import org.apache.qpid.jms.message.JmsOutboundMessageDispatch; import org.apache.qpid.jms.message.facade.JmsMessageFacade; import org.apache.qpid.jms.meta.JmsProducerInfo; @@ -124,9 +123,6 @@ public class AmqpFixedProducer extends AmqpProducer { delivery.disposition(state); } - JmsMessage message = envelope.getMessage(); - message.setReadOnlyBody(true); - AmqpJmsMessageFacade amqpMessageFacade = (AmqpJmsMessageFacade) facade; Message amqpMessage = amqpMessageFacade.getAmqpMessage(); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
