org.apache.axis2.transport.testkit.endpoint
Class AsyncEndpointAdapter<M,N>

java.lang.Object
  org.apache.axis2.transport.testkit.endpoint.AsyncEndpointAdapter<M,N>

All Implemented Interfaces:

Adapter, AsyncEndpoint<M>

public class AsyncEndpointAdapter<M,N>
extends java.lang.Object
implements AsyncEndpoint<M>, Adapter

Constructor Summary

AsyncEndpointAdapter(AsyncEndpoint<N> target, MessageDecoder<N,M> decoder)

Method Summary

void	clear() Discard any pending messages.
AsyncEndpoint<N>	getTarget()
IncomingMessage<M>	waitForMessage(int timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncEndpointAdapter

public AsyncEndpointAdapter(AsyncEndpoint<N> target,
                            MessageDecoder<N,M> decoder)

Method Detail

getTarget

public AsyncEndpoint<N> getTarget()

Specified by:

getTarget in interface Adapter

clear

public void clear()
           throws java.lang.Exception

Description copied from interface: AsyncEndpoint

Discard any pending messages.

Specified by:

clear in interface AsyncEndpoint<M>

Throws:

java.lang.Exception

waitForMessage

public IncomingMessage<M> waitForMessage(int timeout)
                                  throws java.lang.Throwable

Specified by:

waitForMessage in interface AsyncEndpoint<M>

Throws:

java.lang.Throwable