Repository: camel Updated Branches: refs/heads/camel-2.16.x 267c297c9 -> 302c91d1a
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/302c91d1 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/302c91d1 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/302c91d1 Branch: refs/heads/camel-2.16.x Commit: 302c91d1a49ce8985950f7da53a034bd97951b88 Parents: 267c297 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Wed Jan 13 10:20:16 2016 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Wed Jan 13 10:26:01 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/302c91d1/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 344169f..e7dfe91 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/302c91d1/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);
