public class AsyncEndpointAdapter<M,N> extends Object implements AsyncEndpoint<M>, Adapter
Constructor and Description |
---|
AsyncEndpointAdapter(AsyncEndpoint<N> target,
MessageDecoder<N,M> decoder) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Discard any pending messages.
|
AsyncEndpoint<N> |
getTarget() |
IncomingMessage<M> |
waitForMessage(int timeout) |
public AsyncEndpointAdapter(AsyncEndpoint<N> target, MessageDecoder<N,M> decoder)
public AsyncEndpoint<N> getTarget()
public void clear() throws Exception
AsyncEndpoint
clear
in interface AsyncEndpoint<M>
Exception
public IncomingMessage<M> waitForMessage(int timeout) throws Throwable
waitForMessage
in interface AsyncEndpoint<M>
Throwable
Copyright © 2004-2015 The Apache Software Foundation. All Rights Reserved.