svn commit: r695292 - /synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/AsyncMessageTestCase.java

[veithen]

Author: veithen
Date: Sun Sep 14 14:29:23 2008
New Revision: 695292

URL: http://svn.apache.org/viewvc?rev=695292&view=rev
Log:
Transport test kit: corrected a bug in AsyncMessageTestCase where a NPE is 
thrown when it doesn't receive the message

Modified:
    
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/AsyncMessageTestCase.java

Modified: 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/AsyncMessageTestCase.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/AsyncMessageTestCase.java?rev=695292&r1=695291&r2=695292&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/AsyncMessageTestCase.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/AsyncMessageTestCase.java
 Sun Sep 14 14:29:23 2008
@@ -23,6 +23,7 @@
 
 import org.apache.synapse.transport.testkit.client.AsyncTestClient;
 import org.apache.synapse.transport.testkit.listener.AsyncChannel;
+import org.apache.synapse.transport.testkit.message.IncomingMessage;
 import org.apache.synapse.transport.testkit.server.AsyncEndpoint;
 import org.apache.synapse.transport.testkit.tests.MessageTestCase;
 
@@ -47,12 +48,12 @@
         // Run the test.
 //                    contentTypeMode == ContentTypeMode.TRANSPORT ? 
contentType : null);
         client.sendMessage(options, options.getBaseContentType(), expected);
-        M actual = endpoint.waitForMessage(8000).getData();
+        IncomingMessage<M> actual = endpoint.waitForMessage(8000);
         if (actual == null) {
             fail("Failed to get message");
         }
         
-        checkMessageData(expected, actual);
+        checkMessageData(expected, actual.getData());
     }
     
     protected abstract M prepareMessage() throws Exception;