Repository: camel Updated Branches: refs/heads/master 9ce810f30 -> 6c0362d21
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/6c0362d2 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6c0362d2 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6c0362d2 Branch: refs/heads/master Commit: 6c0362d210c6524194212d208d743d37e13d745f Parents: 9ce810f 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:20:38 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/6c0362d2/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 c0b4d58..32f54b9 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 @@ -134,7 +134,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/6c0362d2/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);
