commit b25bc4f3d6bfa521e8505eb69a2b9268d232e489
author rinrinne <rinrin.ne@gmail.com> Wed Jan 08 17:33:24 2014 +0900
committer rinrinne <rinrin.ne@gmail.com> Wed Jan 08 17:33:24 2014 +0900
tree f88abafa266b62f1d38ef8e8b8e5ca64d19162a1
parent 0770f7f5af9ca39f4e9846e954aefccebe9643f5

Fix bind mode selection

src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
index e4bb8f0..6915b2f 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
@@ -47,7 +47,6 @@
   public void connect() {
     LOGGER.info("Connect to " + properties.getAMQPUri() + "...");
     ConnectionFactory factory = new ConnectionFactory();
-    exchangeName = UUID.randomUUID().toString();
     try {
       if (StringUtils.isNotEmpty(properties.getAMQPUri())) {
         factory.setUri(properties.getAMQPUri());
@@ -83,6 +82,7 @@
             exchangeType = EXCHANGE_TYPE_FANOUT;
             routingKey = pluginName;
           }
+          exchangeName = UUID.randomUUID().toString();
           LOGGER.debug("Exchange type: " + exchangeType);
           LOGGER.debug("Declare exchange: " + exchangeName);
           ch.exchangeDeclare(exchangeName, exchangeType, true);
@@ -92,7 +92,7 @@
           ch.queueBind(properties.getAMQPQueue(), exchangeName, routingKey);
           publishChannel = ch;
           LOGGER.info("Channel for queue \"" + properties.getAMQPQueue() + "\" opened.");
-        } else if (StringUtils.isNotEmpty(exchangeName)) {
+        } else if (StringUtils.isNotEmpty(properties.getAMQPExchange())) {
           LOGGER.info("Exchange mode");
           exchangeName = properties.getAMQPExchange();
           LOGGER.debug("Declare exchange: " + exchangeName);