Changeset 70 for trunk/src/test/java/omq/test/event/MessageTest.java

Timestamp:

06/28/13 12:41:11 (11 years ago)

Author:

stoda

Message:

MultiProxymq? added

File:

• trunk/src/test/java/omq/test/event/MessageTest.java (moved) (moved from trunk/src/test/java/omq/test/event/EventTest.java) (3 diffs)

trunk/src/test/java/omq/test/event/MessageTest.java

@@ -3 +3 @@
 import static org.junit.Assert.assertEquals;
 
+import java.util.Arrays;
+import java.util.Collection;
 import java.util.Properties;
 
@@ -9 +11 @@
 import omq.common.util.Serializer;
 
+import org.junit.After;
 import org.junit.BeforeClass;
 import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+import org.junit.runners.Parameterized.Parameters;
 
-public class EventTest {
-        private static EventTriggerImpl trigger;
+@RunWith(value = Parameterized.class)
+public class MessageTest {
+        private static final String NAME = "message";
+
+        private static Broker broker;
+        private static Message serverProxy;
+        private static MessageImpl clientM1;
+        private static MessageImpl clientM2;
+
+        public MessageTest(String type) throws Exception {
+                Properties env = new Properties();
+                env.setProperty(ParameterQueue.USER_NAME, "guest");
+                env.setProperty(ParameterQueue.USER_PASS, "guest");
+
+                // Set host info of rabbimq (where it is)
+                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
+                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
+                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+                env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
+                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
+
+                // Set info about where the message will be sent
+                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
+
+                // Set info about the queue & the exchange where the ResponseListener
+                // will listen to.
+                env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue");
+                env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");
+
+                broker = new Broker(env);
+                serverProxy = broker.lookupMulti(NAME, Message.class);
+        }
+
+        @Parameters
+        public static Collection<Object[]> data() {
+                Object[][] data = new Object[][] { { Serializer.JAVA }, { Serializer.GSON }, { Serializer.KRYO } };
+                return Arrays.asList(data);
+        }
 
         @BeforeClass
-        public static void server() throws Exception {
+        public static void client() throws Exception {
                 Properties env = new Properties();
                 env.setProperty(ParameterQueue.USER_NAME, "guest");
@@ -31 +73 @@
                 env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
 
-                trigger = new EventTriggerImpl();
                 Broker broker = new Broker(env);
+                clientM1 = new MessageImpl();
+                broker.bind(NAME, clientM1);
 
-                broker.startTriggerEvent("trigger", trigger);
+                Broker broker2 = new Broker(env);
+                clientM2 = new MessageImpl();
+                broker2.bind(NAME, clientM2);
+        }
 
-                System.out.println("Server started");
+        @After
+        public void stop() throws Exception {
+                broker.stopBroker();
         }
 
         @Test
-        public void eventTest() throws Exception {
-                String expected = "This is an event";
-                String actual = null;
+        public void test() throws Exception {
+                String expected = "Hello";
 
-                Properties env = new Properties();
-                env.setProperty(ParameterQueue.USER_NAME, "guest");
-                env.setProperty(ParameterQueue.USER_PASS, "guest");
+                serverProxy.setMessage(expected);
+                Thread.sleep(200);
+                assertEquals(expected, clientM1.getMessage());
+                assertEquals(expected, clientM2.getMessage());
+                serverProxy.setMessage("");
+                Thread.sleep(200);
+        }
 
-                // Set host info of rabbimq (where it is)
-                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
-                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
-                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
-                env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
-                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
-
-                // Set info about where the message will be sent
-                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
-                // env.setProperty(ParameterQueue.DEBUGFILE, "c:\\middlewareDebug");
-
-                // Set info about the queue & the exchange where the ResponseListener
-                // will listen to.
-                env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue");
-                env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");
-
-                Broker broker = new Broker(env);
-                EventTrigger et = broker.lookup("trigger", EventTrigger.class);
-
-                MessageListener ms = new MessageListener();
-                et.addListener(ms);
-                trigger.triggerEvent(expected);
-                Thread.sleep(500);
-                actual = ms.getMessage();
-
-                assertEquals(expected, actual);
-        }
 }