You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2011/03/08 08:17:37 UTC

svn commit: r1079281 - /camel/trunk/components/camel-sip/src/test/java/org/apache/camel/component/sip/PublishSubscribeTest.java

Author: davsclaus
Date: Tue Mar  8 07:17:36 2011
New Revision: 1079281

URL: http://svn.apache.org/viewvc?rev=1079281&view=rev
Log:
Fixed test on windows having port already in use

Modified:
    camel/trunk/components/camel-sip/src/test/java/org/apache/camel/component/sip/PublishSubscribeTest.java

Modified: camel/trunk/components/camel-sip/src/test/java/org/apache/camel/component/sip/PublishSubscribeTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-sip/src/test/java/org/apache/camel/component/sip/PublishSubscribeTest.java?rev=1079281&r1=1079280&r2=1079281&view=diff
==============================================================================
--- camel/trunk/components/camel-sip/src/test/java/org/apache/camel/component/sip/PublishSubscribeTest.java (original)
+++ camel/trunk/components/camel-sip/src/test/java/org/apache/camel/component/sip/PublishSubscribeTest.java Tue Mar  8 07:17:36 2011
@@ -42,23 +42,15 @@ public class PublishSubscribeTest extend
     
     @Test
     public void testPresenceAgentBasedPubSub() throws Exception {
-        if (LOG.isDebugEnabled()) {
-            LOG.debug("Beginning Test ---> testStatefulTransactionalTCPRequestReply()");
-        }
-
         unreachableEndpoint.expectedMessageCount(0);
         resultEndpoint.expectedMinimumMessageCount(1);
         
         producerTemplate.sendBodyAndHeader(
-            "sip://agent@localhost:5152?stackName=client&eventHeaderName=evtHdrName&eventId=evtid&fromUser=user2&fromHost=localhost&fromPort=3534", 
+            "sip://agent@localhost:5252?stackName=client&eventHeaderName=evtHdrName&eventId=evtid&fromUser=user2&fromHost=localhost&fromPort=3534", 
             "EVENT_A",
             "REQUEST_METHOD", Request.PUBLISH);         
 
         assertMockEndpointsSatisfied();
-            
-        if (LOG.isDebugEnabled()) {
-            LOG.debug("Completed Test ---> testStatefulTransactionalTCPRequestReply()");
-        }        
     }
     
     @Override
@@ -67,10 +59,10 @@ public class PublishSubscribeTest extend
             @Override
             public void configure() throws Exception {  
                 // Create PresenceAgent
-                from("sip://agent@localhost:5152?stackName=PresenceAgent&presenceAgent=true&eventHeaderName=evtHdrName&eventId=evtid")
+                from("sip://agent@localhost:5252?stackName=PresenceAgent&presenceAgent=true&eventHeaderName=evtHdrName&eventId=evtid")
                     .to("mock:neverland");
                 
-                from("sip://johndoe@localhost:5154?stackName=Subscriber&toUser=agent&toHost=localhost&toPort=5152&eventHeaderName=evtHdrName&eventId=evtid")
+                from("sip://johndoe@localhost:5254?stackName=Subscriber&toUser=agent&toHost=localhost&toPort=5252&eventHeaderName=evtHdrName&eventId=evtid")
                     .to("log:ReceivedEvent")
                     .to("mock:notification");
             }