org.apache.axis2.transport.testkit.axis2.endpoint
Class AxisAsyncEndpoint

java.lang.Object
  extended by org.apache.axis2.transport.testkit.axis2.endpoint.AxisTestEndpoint
      extended by org.apache.axis2.transport.testkit.axis2.endpoint.AxisAsyncEndpoint
All Implemented Interfaces:
AsyncEndpoint<AxisMessage>

public class AxisAsyncEndpoint
extends AxisTestEndpoint
implements AsyncEndpoint<AxisMessage>


Constructor Summary
AxisAsyncEndpoint()
           
 
Method Summary
 void clear()
          Discard any pending messages.
protected  org.apache.axis2.description.InOnlyAxisOperation createOperation()
          Create an operation appropriate for the message exchange pattern implemented by the test endpoint.
protected  void onTransportError(java.lang.Throwable ex)
          Process a transport error.
 IncomingMessage<AxisMessage> waitForMessage(int timeout)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AxisAsyncEndpoint

public AxisAsyncEndpoint()
Method Detail

createOperation

protected org.apache.axis2.description.InOnlyAxisOperation createOperation()
Description copied from class: AxisTestEndpoint
Create an operation appropriate for the message exchange pattern implemented by the test endpoint. The operation returned should have a MessageReceiver set.

Specified by:
createOperation in class AxisTestEndpoint
Returns:
the operation

onTransportError

protected void onTransportError(java.lang.Throwable ex)
Description copied from class: AxisTestEndpoint
Process a transport error. Note that this method will only be called if the underlying transport supports reporting of transport errors.

Specified by:
onTransportError in class AxisTestEndpoint
Parameters:
ex - the exception describing the transport error

clear

public void clear()
           throws java.lang.Exception
Description copied from interface: AsyncEndpoint
Discard any pending messages.

Specified by:
clear in interface AsyncEndpoint<AxisMessage>
Throws:
java.lang.Exception

waitForMessage

public IncomingMessage<AxisMessage> waitForMessage(int timeout)
                                            throws java.lang.Throwable
Specified by:
waitForMessage in interface AsyncEndpoint<AxisMessage>
Throws:
java.lang.Throwable


Copyright © 2004-2009 The Apache Software Foundation. All Rights Reserved.