commit a879e1a7f149a86e3229f88e4ffe1739a7802fff
author rinrinne <rinrin.ne@gmail.com> Wed Jan 08 18:12:32 2014 +0900
committer rinrinne <rinrin.ne@gmail.com> Wed Jan 08 18:12:32 2014 +0900
tree 344a12c88fcdfaea041d3357d424ecc2a6845bb1
parent b25bc4f3d6bfa521e8505eb69a2b9268d232e489

Use fixed name instead random UUID in queue mode.

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 6915b2f..92ebd02 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
@@ -17,7 +17,6 @@
 
 import java.io.IOException;
 import java.net.URISyntaxException;
-import java.util.UUID;
 
 @Singleton
 public class AMQPSession implements ShutdownListener {
@@ -82,7 +81,7 @@
             exchangeType = EXCHANGE_TYPE_FANOUT;
             routingKey = pluginName;
           }
-          exchangeName = UUID.randomUUID().toString();
+          exchangeName = exchangeType + "-" + properties.getAMQPQueue();
           LOGGER.debug("Exchange type: " + exchangeType);
           LOGGER.debug("Declare exchange: " + exchangeName);
           ch.exchangeDeclare(exchangeName, exchangeType, true);