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

java.lang.Object
  org.apache.axis2.transport.testkit.axis2.endpoint.AxisTestEndpoint
      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