org.apache.axis2.transport.nhttp
Class HttpCoreRequestResponseTransport

java.lang.Object
  org.apache.axis2.transport.nhttp.HttpCoreRequestResponseTransport

All Implemented Interfaces:

RequestResponseTransport

public class HttpCoreRequestResponseTransport
extends java.lang.Object
implements RequestResponseTransport

This interface is a point of control for Axis2 (and Sandesha2 in particular) to control the behaviour of a Request-Response transport such as HTTP/s For nhttp, this does not make much of a difference, as we are capable of keeping a socket open and writing to it from a different thread, while letting the initial thread that read the request go free. However, it seems like Sandesha2 is looking for this interface, and it is not going to create much of an issue anyway

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.axis2.transport.RequestResponseTransport

RequestResponseTransport.RequestResponseTransportStatus

Field Summary

Fields inherited from interface org.apache.axis2.transport.RequestResponseTransport

HOLD_RESPONSE, TRANSPORT_CONTROL

Method Summary

void	acknowledgeMessage(MessageContext msgContext) Notify the transport that a message should be acknowledged at this time.
void	awaitResponse() Pause execution and wait for a response message to be ready.
RequestResponseTransport.RequestResponseTransportStatus	getStatus() This gives the current status of an RequestResponseTransport object.
boolean	isResponseWritten() This will indicate whether or not the response has already been written
void	setResponseWritten(boolean responseWritten) This is used to set the response written flag on the RequestResponseTransport instance
void	signalFaultReady(AxisFault fault) This will tell the transport to end a current wait by raising the given fault.
void	signalResponseReady() Signal that a response has be created and is ready for transmission.

Methods inherited from class java.lang.Object

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

Method Detail

acknowledgeMessage

public void acknowledgeMessage(MessageContext msgContext)
                        throws AxisFault

Description copied from interface: RequestResponseTransport

Notify the transport that a message should be acknowledged at this time.

Specified by:

acknowledgeMessage in interface RequestResponseTransport

Throws:

AxisFault

awaitResponse

public void awaitResponse()
                   throws java.lang.InterruptedException,
                          AxisFault

Description copied from interface: RequestResponseTransport

Pause execution and wait for a response message to be ready. This will typically be called by the transport after a message has been paused and will cause the transport to block until a response message is ready to be returned. This is required to enable RM for in-out MEPs over a request/response transport; without it the message would be paused and the transport would simply ack the request.

Specified by:

awaitResponse in interface RequestResponseTransport

Throws:

java.lang.InterruptedException

AxisFault

signalResponseReady

public void signalResponseReady()

Description copied from interface: RequestResponseTransport

Signal that a response has be created and is ready for transmission. This should release anyone who is blocked on a awaitResponse().

Specified by:

signalResponseReady in interface RequestResponseTransport

getStatus

public RequestResponseTransport.RequestResponseTransportStatus getStatus()

Description copied from interface: RequestResponseTransport

This gives the current status of an RequestResponseTransport object.

Specified by:

getStatus in interface RequestResponseTransport

Returns:

signalFaultReady

public void signalFaultReady(AxisFault fault)

Description copied from interface: RequestResponseTransport

This will tell the transport to end a current wait by raising the given fault.

Specified by:

signalFaultReady in interface RequestResponseTransport

Parameters:

fault - The fault to be raised.

isResponseWritten

public boolean isResponseWritten()

Description copied from interface: RequestResponseTransport

This will indicate whether or not the response has already been written

Specified by:

isResponseWritten in interface RequestResponseTransport

setResponseWritten

public void setResponseWritten(boolean responseWritten)

Description copied from interface: RequestResponseTransport

This is used to set the response written flag on the RequestResponseTransport instance

Specified by:

setResponseWritten in interface RequestResponseTransport