Changeset 73
- Timestamp:
- 07/01/13 11:38:39 (11 years ago)
- Location:
- trunk/src/test/java/omq/test
- Files:
-
- 9 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/test/java/omq/test/calculator/CalculatorTest.java
r72 r73 39 39 // Set info about where the message will be sent 40 40 env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange"); 41 // env.setProperty(ParameterQueue.DEBUGFILE, "c:\\middlewareDebug");42 41 43 42 // Set info about the queue & the exchange where the ResponseListener 44 43 // will listen to. 45 44 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 46 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");47 45 48 46 broker = new Broker(env); -
trunk/src/test/java/omq/test/event/MessageTest.java
r70 r73 45 45 // will listen to. 46 46 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 47 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");48 47 49 48 broker = new Broker(env); -
trunk/src/test/java/omq/test/exception/ExceptionTest.java
r62 r73 42 42 // will listen to. 43 43 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 44 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");45 44 46 45 broker = new Broker(env); -
trunk/src/test/java/omq/test/faultTolerance/FaultToleranceTest.java
r62 r73 44 44 // will listen to. 45 45 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 46 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");47 46 env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "5000"); 48 47 -
trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java
r62 r73 41 41 // will listen to. 42 42 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 43 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");44 43 45 44 broker = new Broker(env); -
trunk/src/test/java/omq/test/observer/ObserverTest.java
r72 r73 44 44 // will listen to. 45 45 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 46 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");47 46 48 47 broker = new Broker(env); … … 75 74 // will listen to. 76 75 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "server_reply_queue"); 77 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "server_event_queue");78 76 79 77 Broker broker = new Broker(env); -
trunk/src/test/java/omq/test/serializer/CalculatorTest.java
r63 r73 36 36 // will listen to. 37 37 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 38 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");39 38 40 39 broker = new Broker(env); -
trunk/src/test/java/omq/test/stopBroker/StopBrokerTest.java
r62 r73 41 41 // will listen to. 42 42 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 43 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");44 43 env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "5000"); 45 44 -
trunk/src/test/java/omq/test/temporal/ProvaTest.java
r62 r73 69 69 // will listen to. 70 70 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue"); 71 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");72 71 73 72 broker = new Broker(env);
Note: See TracChangeset
for help on using the changeset viewer.