svn commit: r713180 - /webservices/commons/trunk/modules/transport/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/endpoint/AxisAsyncEndpoint.java

[ve...@apache.org]

Author: veithen
Date: Tue Nov 11 13:41:11 2008
New Revision: 713180

URL: http://svn.apache.org/viewvc?rev=713180&view=rev
Log:
Transport test kit: Added some more assertions on the server side message context.

Modified:
    webservices/commons/trunk/modules/transport/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/endpoint/AxisAsyncEndpoint.java

Modified: webservices/commons/trunk/modules/transport/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/endpoint/AxisAsyncEndpoint.java
URL: http://svn.apache.org/viewvc/webservices/commons/trunk/modules/transport/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/endpoint/AxisAsyncEndpoint.java?rev=713180&r1=713179&r2=713180&view=diff
==============================================================================
--- webservices/commons/trunk/modules/transport/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/endpoint/AxisAsyncEndpoint.java (original)
+++ webservices/commons/trunk/modules/transport/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/endpoint/AxisAsyncEndpoint.java Tue Nov 11 13:41:11 2008
@@ -31,6 +31,7 @@
 import org.apache.axis2.context.MessageContext;
 import org.apache.axis2.description.AxisOperation;
 import org.apache.axis2.description.InOnlyAxisOperation;
+import org.apache.axis2.description.TransportInDescription;
 import org.apache.axis2.engine.MessageReceiver;
 import org.apache.axis2.transport.testkit.axis2.MessageContextValidator;
 import org.apache.axis2.transport.testkit.endpoint.AsyncEndpoint;
@@ -44,11 +45,13 @@
         IncomingMessage<AxisMessage> process() throws Throwable;
     }
     
+    private @Transient AxisTestEndpointContext context;
     private @Transient MessageContextValidator[] validators;
     private @Transient BlockingQueue<Event> queue;
     
     @Setup @SuppressWarnings("unused")
     private void setUp(AxisTestEndpointContext context, MessageContextValidator[] validators) {
+        this.context = context;
         this.validators = validators;
         queue = new LinkedBlockingQueue<Event>();
     }
@@ -64,6 +67,13 @@
         final AxisMessage messageData;
         try {
             Assert.assertTrue(messageCtx.isServerSide());
+            
+            TransportInDescription transportIn = messageCtx.getTransportIn();
+            Assert.assertNotNull("transportIn not set on message context", transportIn);
+            Assert.assertEquals(context.getTransportName(), transportIn.getName());
+            
+            Assert.assertEquals(context.getTransportName(), messageCtx.getIncomingTransportName());
+            
             for (MessageContextValidator validator : validators) {
                 validator.validate(messageCtx, false);
             }