commit 50b9a8ec2aa8cd12c07c66128b50dc872d388853
author rinrinne <rinrin.ne@gmail.com> Mon Jan 06 19:23:10 2014 +0900
committer rinrinne <rinrin.ne@gmail.com> Mon Jan 06 19:23:10 2014 +0900
tree 42e6001af86744637ea01b3fb9cd1c3e57f06eb6
parent 08c92fb15ab4883aeb866df40602dba156bce834

Set basic properties to message

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 f9555f6..53b41f6 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
@@ -93,7 +93,8 @@
   public void sendMessage(String message) {
     if (publishChannel != null && publishChannel.isOpen()) {
       try {
-        publishChannel.basicPublish(exchangeName, properties.getAMQPRoutingKey(), null, message.getBytes(CharEncoding.UTF_8));
+        publishChannel.basicPublish(exchangeName, properties.getAMQPRoutingKey(), properties.getBasicProperties(),
+            message.getBytes(CharEncoding.UTF_8));
       } catch (Exception ex) {
         LOGGER.warn("#sendMessage: " + ex.toString());
       }