public class AxisAsyncEndpoint extends AxisTestEndpoint implements AsyncEndpoint<AxisMessage>
Constructor and Description |
---|
AxisAsyncEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Discard any pending messages.
|
protected InOnlyAxisOperation |
createOperation()
Create an operation appropriate for the message exchange pattern implemented
by the test endpoint.
|
protected void |
onTransportError(Throwable ex)
Process a transport error.
|
IncomingMessage<AxisMessage> |
waitForMessage(int timeout) |
protected InOnlyAxisOperation createOperation()
AxisTestEndpoint
MessageReceiver
set.createOperation
in class AxisTestEndpoint
protected void onTransportError(Throwable ex)
AxisTestEndpoint
onTransportError
in class AxisTestEndpoint
ex
- the exception describing the transport errorpublic void clear() throws Exception
AsyncEndpoint
clear
in interface AsyncEndpoint<AxisMessage>
Exception
public IncomingMessage<AxisMessage> waitForMessage(int timeout) throws Throwable
waitForMessage
in interface AsyncEndpoint<AxisMessage>
Throwable
Copyright © 2004-2015 The Apache Software Foundation. All Rights Reserved.