I get a compilation error with latest code from master [INFO] ------------------------------------------------------------------------ [INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 12:48.409s [INFO] Finished at: Thu Aug 08 09:01:31 CEST 2013 [INFO] Final Memory: 259M/977M [INFO] ------------------------------------------------------------------------ [ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:2.5.1:testCompile (default-testCompile) on project camel-rabbitmq: Compilation failure [ERROR] /Users/davsclaus/workspace/camel/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java:[44,36] error: method createRabbitExchange in class RabbitMQEndpoint cannot be applied to given types; [ERROR] -> [Help 1]
On Thu, Aug 8, 2013 at 2:44 AM, <ningji...@apache.org> wrote: > Updated Branches: > refs/heads/master b36127fcf -> 7535b96c6 > > > CAMEL-6617 fixed the issue of RabbitMQConsumer doesn't put the body into > message > > > Project: http://git-wip-us.apache.org/repos/asf/camel/repo > Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7535b96c > Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7535b96c > Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7535b96c > > Branch: refs/heads/master > Commit: 7535b96c61811eedc6ee26c16151a0b92a08fe45 > Parents: b36127f > Author: Willem Jiang <ningji...@apache.org> > Authored: Thu Aug 8 08:43:50 2013 +0800 > Committer: Willem Jiang <ningji...@apache.org> > Committed: Thu Aug 8 08:43:50 2013 +0800 > > ---------------------------------------------------------------------- > .../org/apache/camel/component/rabbitmq/RabbitMQConsumer.java | 2 +- > .../org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java | 3 ++- > 2 files changed, 3 insertions(+), 2 deletions(-) > ---------------------------------------------------------------------- > > > http://git-wip-us.apache.org/repos/asf/camel/blob/7535b96c/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java > ---------------------------------------------------------------------- > diff --git > a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java > > b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java > index 0927f81..7ae8d12 100644 > --- > a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java > +++ > b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java > @@ -114,7 +114,7 @@ public class RabbitMQConsumer extends DefaultConsumer { > AMQP.BasicProperties properties, > byte[] body) throws IOException { > > - Exchange exchange = > consumer.endpoint.createRabbitExchange(envelope); > + Exchange exchange = > consumer.endpoint.createRabbitExchange(envelope, body); > log.trace("Created exchange [exchange={}]", new > Object[]{exchange}); > > try { > > http://git-wip-us.apache.org/repos/asf/camel/blob/7535b96c/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java > ---------------------------------------------------------------------- > diff --git > a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java > > b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java > index 2a7e2d6..ffb8515 100644 > --- > a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java > +++ > b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java > @@ -56,7 +56,7 @@ public class RabbitMQEndpoint extends DefaultEndpoint { > super(endpointUri, component); > } > > - public Exchange createRabbitExchange(Envelope envelope) { > + public Exchange createRabbitExchange(Envelope envelope, byte[] body) { > Exchange exchange = new DefaultExchange(getCamelContext(), > getExchangePattern()); > > Message message = new DefaultMessage(); > @@ -65,6 +65,7 @@ public class RabbitMQEndpoint extends DefaultEndpoint { > message.setHeader(RabbitMQConstants.ROUTING_KEY, > envelope.getRoutingKey()); > message.setHeader(RabbitMQConstants.EXCHANGE_NAME, > envelope.getExchange()); > message.setHeader(RabbitMQConstants.DELIVERY_TAG, > envelope.getDeliveryTag()); > + message.setBody(body); > > return exchange; > } > -- Claus Ibsen ----------------- Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
