Package org.apache.axis2.transport.mail
Class MailRequestResponseTransport
- java.lang.Object
-
- org.apache.axis2.transport.mail.MailRequestResponseTransport
-
- All Implemented Interfaces:
RequestResponseTransport
public class MailRequestResponseTransport extends Object implements RequestResponseTransport
this class is not generally used with the SMTP transport. this is added to work this smtp transport with Sandesah2.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.axis2.kernel.RequestResponseTransport
RequestResponseTransport.RequestResponseTransportStatus
-
-
Field Summary
-
Fields inherited from interface org.apache.axis2.kernel.RequestResponseTransport
HOLD_RESPONSE, TRANSPORT_CONTROL
-
-
Constructor Summary
Constructors Constructor Description MailRequestResponseTransport()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
acknowledgeMessage(MessageContext messageContext)
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 writtenvoid
setResponseWritten(boolean b)
This is used to set the response written flag on the RequestResponseTransport instancevoid
signalFaultReady(AxisFault axisFault)
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.
-
-
-
Method Detail
-
acknowledgeMessage
public void acknowledgeMessage(MessageContext messageContext) throws AxisFault
Description copied from interface:RequestResponseTransport
Notify the transport that a message should be acknowledged at this time.- Specified by:
acknowledgeMessage
in interfaceRequestResponseTransport
- Throws:
AxisFault
-
awaitResponse
public void awaitResponse() throws 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 interfaceRequestResponseTransport
- Throws:
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 interfaceRequestResponseTransport
-
signalFaultReady
public void signalFaultReady(AxisFault axisFault)
Description copied from interface:RequestResponseTransport
This will tell the transport to end a current wait by raising the given fault.- Specified by:
signalFaultReady
in interfaceRequestResponseTransport
- Parameters:
axisFault
- The fault to be raised.
-
getStatus
public RequestResponseTransport.RequestResponseTransportStatus getStatus()
Description copied from interface:RequestResponseTransport
This gives the current status of an RequestResponseTransport object.- Specified by:
getStatus
in interfaceRequestResponseTransport
- Returns:
-
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 interfaceRequestResponseTransport
-
setResponseWritten
public void setResponseWritten(boolean b)
Description copied from interface:RequestResponseTransport
This is used to set the response written flag on the RequestResponseTransport instance- Specified by:
setResponseWritten
in interfaceRequestResponseTransport
-
-