You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2013/07/22 05:18:34 UTC
git commit: CAMEL-6534 Added two extra fields on the exchange with
thanks to Stephen
Updated Branches:
refs/heads/master 82222bc91 -> f3509ddc8
CAMEL-6534 Added two extra fields on the exchange with thanks to Stephen
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f3509ddc
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f3509ddc
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f3509ddc
Branch: refs/heads/master
Commit: f3509ddc8a2c85d6d5ec9e4d77f160910f44761c
Parents: 82222bc
Author: Willem Jiang <ni...@apache.org>
Authored: Mon Jul 22 11:16:12 2013 +0800
Committer: Willem Jiang <ni...@apache.org>
Committed: Mon Jul 22 11:17:03 2013 +0800
----------------------------------------------------------------------
.../component/rabbitmq/RabbitMQConsumer.java | 8 +++++++-
.../component/rabbitmq/RabbitMQEndpoint.java | 18 ++++++++++++++++++
2 files changed, 25 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/f3509ddc/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 d807df6..2f78d00 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
@@ -18,6 +18,7 @@
package org.apache.camel.component.rabbitmq;
import java.io.IOException;
+import java.util.HashMap;
import java.util.concurrent.ExecutorService;
import com.rabbitmq.client.AMQP;
@@ -58,7 +59,12 @@ public class RabbitMQConsumer extends DefaultConsumer {
channel = conn.createChannel();
log.debug("Using channel {}", channel);
- channel.exchangeDeclare(endpoint.getExchangeName(), "direct", true);
+ channel.exchangeDeclare(endpoint.getExchangeName(),
+ "direct",
+ endpoint.isDurable(),
+ endpoint.isAutoDelete(),
+ new HashMap<String, Object>());
+
channel.queueDeclare(endpoint.getQueue(), true, false, false, null);
channel.queueBind(endpoint.getQueue(), endpoint.getExchangeName(),
endpoint.getRoutingKey() == null ? "" : endpoint.getRoutingKey());
http://git-wip-us.apache.org/repos/asf/camel/blob/f3509ddc/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 933a954..d43a73e 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
@@ -47,6 +47,8 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
private int threadPoolSize = 10;
private int portNumber;
private boolean autoAck = true;
+ private boolean autoDelete = true;
+ private boolean durable = true;
private String queue = String.valueOf(UUID.randomUUID().toString().hashCode());
private String exchangeName;
private String routingKey;
@@ -93,6 +95,22 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
public String getQueue() {
return queue;
}
+
+ public boolean isAutoDelete() {
+ return autoDelete;
+ }
+
+ public void setAutoDelete(boolean autoDelete) {
+ this.autoDelete = autoDelete;
+ }
+
+ public boolean isDurable() {
+ return durable;
+ }
+
+ public void setDurable(boolean durable) {
+ this.durable = durable;
+ }
public String getRoutingKey() {
return routingKey;