You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2014/09/07 08:46:44 UTC
[3/3] git commit: CAMEL-7665: Fixed CS
CAMEL-7665: Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5db09a80
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5db09a80
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5db09a80
Branch: refs/heads/master
Commit: 5db09a8093003a43af81307984f56642d51edfd5
Parents: 4764b2c
Author: Claus Ibsen <da...@apache.org>
Authored: Sun Sep 7 08:45:30 2014 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sun Sep 7 08:45:30 2014 +0200
----------------------------------------------------------------------
.../camel/component/rabbitmq/RabbitMQConsumer.java | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/5db09a80/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 a793782..1fe0cd4 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
@@ -27,13 +27,12 @@ import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Envelope;
+import com.rabbitmq.client.ShutdownSignalException;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.impl.DefaultConsumer;
-import com.rabbitmq.client.ShutdownSignalException;
-
public class RabbitMQConsumer extends DefaultConsumer {
ExecutorService executor;
Connection conn;
@@ -84,7 +83,7 @@ public class RabbitMQConsumer extends DefaultConsumer {
}
/**
- * Add a consummer thread for given channel
+ * Add a consumer thread for given channel
*/
private void startConsumers() throws IOException {
// First channel used to declare Exchange and Queue
@@ -101,7 +100,7 @@ public class RabbitMQConsumer extends DefaultConsumer {
}
/**
- * Add a consummer thread for given channel
+ * Add a consumer thread for given channel
*/
private void startConsumer(Channel channel) throws IOException {
RabbitConsumer consumer = new RabbitConsumer(this, channel);
@@ -181,10 +180,10 @@ public class RabbitMQConsumer extends DefaultConsumer {
Exchange exchange = consumer.endpoint.createRabbitExchange(envelope, properties, body);
mergeAmqpProperties(exchange, properties);
log.trace("Created exchange [exchange={}]", exchange);
- long deliveryTag = 0;
+ long deliveryTag = 0;
try {
deliveryTag = envelope.getDeliveryTag();
- consumer.getProcessor().process(exchange);
+ consumer.getProcessor().process(exchange);
if (!consumer.endpoint.isAutoAck()) {
if (exchange.getException() == null) {
log.trace("Acknowledging receipt [delivery_tag={}]",