Changeset 98 for trunk/src/main/java/omq/common/broker/Broker.java

Timestamp:

10/08/13 10:49:46 (11 years ago)

Author:

stoda

Message:

0.5.6
Synchronized channel and reopening when they are closed

File:

• trunk/src/main/java/omq/common/broker/Broker.java (modified) (3 diffs)

trunk/src/main/java/omq/common/broker/Broker.java

@@ -27 +27 @@
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.QueueingConsumer;
+import com.rabbitmq.client.AMQP.BasicProperties;
 import com.rabbitmq.client.QueueingConsumer.Delivery;
 import com.rabbitmq.client.ShutdownListener;
@@ -125 +126 @@
          * @throws Exception
          */
-        public Channel getChannel() throws Exception {
+        public synchronized Channel getChannel() throws Exception {
                 return channel;
         }
@@ -135 +136 @@
          * @throws IOException
          */
-        public Channel getNewChannel() throws IOException {
+        public synchronized Channel getNewChannel() throws IOException {
                 return connection.createChannel();
+        }
+
+        /**
+         * 
+         */
+        public synchronized void publishMessge(String exchange, String routingKey, BasicProperties props, byte[] bytesRequest) throws IOException {
+                if (!channel.isOpen()) {
+                        logger.error("Broker's channel is closed opening a new one", channel.getCloseReason());
+                        channel = getNewChannel();
+                }
+                channel.basicPublish(exchange, routingKey, props, bytesRequest);
         }