Repository: camel Updated Branches: refs/heads/camel-2.15.x d2484a4f8 -> 848815ff6
CAMEL-9506 Fixed the issue that STOMP producer cannot handle the stream object Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/848815ff Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/848815ff Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/848815ff Branch: refs/heads/camel-2.15.x Commit: 848815ff69389f439524255a743bc90996136379 Parents: d2484a4 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Wed Jan 13 10:20:16 2016 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Thu Jan 14 08:55:41 2016 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/stomp/StompEndpoint.java | 3 ++- .../java/org/apache/camel/component/stomp/StompProducerTest.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/848815ff/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java index 4adf20b..4baf9a5 100644 --- a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java +++ b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java @@ -131,7 +131,8 @@ public class StompEndpoint extends DefaultEndpoint { protected void send(final Exchange exchange, final AsyncCallback callback) { final StompFrame frame = new StompFrame(SEND); frame.addHeader(DESTINATION, StompFrame.encodeHeader(destination)); - frame.content(utf8(exchange.getIn().getBody().toString())); + //Fix for CAMEL-9506 leveraging the camel converter to do the change + frame.content(utf8(exchange.getIn().getBody(String.class))); connection.getDispatchQueue().execute(new Task() { @Override http://git-wip-us.apache.org/repos/asf/camel/blob/848815ff/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompProducerTest.java b/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompProducerTest.java index a4a75f9..c87d2d1 100644 --- a/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompProducerTest.java +++ b/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompProducerTest.java @@ -57,6 +57,7 @@ public class StompProducerTest extends StompBaseTest { for (int i = 0; i < numberOfMessages; i++) { try { StompFrame frame = subscribeConnection.receive(); + frame.contentAsString().startsWith("test message "); latch.countDown(); } catch (Exception e) { e.printStackTrace(); @@ -70,7 +71,7 @@ public class StompProducerTest extends StompBaseTest { Producer producer = context.getEndpoint("direct:foo").createProducer(); for (int i = 0; i < numberOfMessages; i++) { Exchange exchange = producer.createExchange(); - exchange.getIn().setBody("test message " + i); + exchange.getIn().setBody(("test message " + i).getBytes("UTF-8")); producer.process(exchange); } latch.await(20, TimeUnit.SECONDS);
