Changeset 22

Timestamp:

05/23/13 21:37:28 (11 years ago)

Author:

stoda

Message:

 

Location:

trunk/objectmq

Files:

• .classpath (modified) (1 diff)
• src/omq/common/broker/Broker.java (modified) (4 diffs)
• src/omq/common/util/OmqConnectionFactory.java (modified) (2 diffs)
• src/omq/exception/InitBrokerException.java (added)

trunk/objectmq/.classpath

@@ -6 +6 @@
         <classpathentry kind="lib" path="lib/commons-cli-1.1.jar"/>
         <classpathentry kind="lib" path="lib/commons-io-1.2.jar"/>
-        <classpathentry kind="lib" path="lib/rabbitmq-client.jar"/>
+        <classpathentry kind="lib" path="lib/rabbitmq-client.jar">
+                <attributes>
+                        <attribute name="javadoc_location" value="file:/home/sergi/Documentos/Sergi/Java/workspace/objectmq/lib/rabbitmq-java-client-javadoc-3.0.1/"/>
+                </attributes>
+        </classpathentry>
         <classpathentry kind="lib" path="lib/kryo-2.21-all.jar"/>
         <classpathentry kind="con" path="org.eclipse.jdt.junit.JUNIT_CONTAINER/4"/>

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

@@ -12 +12 @@
 import omq.common.util.Environment;
 import omq.common.util.OmqConnectionFactory;
+import omq.common.util.ParameterQueue;
 import omq.common.util.Serializer;
 import omq.exception.EnvironmentException;
+import omq.exception.InitBrokerException;
 import omq.exception.RemoteException;
 import omq.exception.SerializerException;
@@ -20 +22 @@
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.QueueingConsumer;
+import com.rabbitmq.client.QueueingConsumer.Delivery;
 
 public class Broker {
@@ -33 +37 @@
                         connection = OmqConnectionFactory.getNewConnection(env);
                         channel = connection.createChannel();
+                        try {
+                                tryConnection(env);
+                        } catch (Exception e) {
+                                channel.close();
+                                connection.close();
+                                throw new InitBrokerException("The connection didn't work");
+                        }
                 }
         }
@@ -104 +115 @@
         }
 
+        public static void tryConnection(Properties env) throws Exception {
+                Channel channel = connection.createChannel();
+                String message = "ping";
+
+                String exchange = env.getProperty(ParameterQueue.USER_NAME);
+                String queueName = exchange + "ping";
+                String routingKey = "routingKey";
+
+                channel.exchangeDeclare(exchange, "direct");
+                channel.queueDeclare(queueName, false, false, false, null);
+                channel.queueBind(queueName, exchange, routingKey);
+
+                channel.basicPublish(exchange, routingKey, null, message.getBytes());
+
+                QueueingConsumer consumer = new QueueingConsumer(channel);
+
+                channel.basicConsume(queueName, true, consumer);
+                Delivery delivery = consumer.nextDelivery(1000);
+
+                channel.exchangeDelete(exchange);
+                channel.queueDelete(queueName);
+
+                channel.close();
+
+                if (!message.equalsIgnoreCase(new String(delivery.getBody()))) {
+                        throw new Exception();
+                }
+        }
 }

trunk/objectmq/src/omq/common/util/OmqConnectionFactory.java

@@ -17 +17 @@
 public class OmqConnectionFactory {
         private static Connection connection;
+        private static int connectionTimeout = 2 * 1000;
 
         public static void init(Properties env) throws KeyManagementException, NoSuchAlgorithmException, IOException {
@@ -41 +42 @@
                 factory.setHost(host);
                 factory.setPort(port);
+                factory.setConnectionTimeout(connectionTimeout);
                 if (ssl) {
                         factory.useSslProtocol();