|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.apache.axis.ime.internal.MessageExchangeImpl
Nested Class Summary | |
class |
MessageExchangeImpl.Listener
|
Field Summary | |
static long |
DEFAULT_TIMEOUT
|
protected org.apache.axis.ime.internal.MessageExchangeImpl.Holder |
holder
|
protected static org.apache.commons.logging.Log |
log
|
static long |
NO_TIMEOUT
|
Constructor Summary | |
MessageExchangeImpl(MessageExchangeProvider provider)
|
Method Summary | |
void |
awaitShutdown()
Block indefinitely until shutdown is complete. |
void |
awaitShutdown(long timeout)
Block for the specified amount of time or until shutdown is complete |
void |
cleanup()
Cleanup |
void |
clearOptions()
Unsupported for now |
MessageExchangeEventListener |
getMessageExchangeEventListener()
see org.apache.axis.ime.MessageExchange#getMessageExchangeStatusListener() |
java.lang.Object |
getOption(java.lang.String OptionId)
Unsupported for now |
java.lang.Object |
getOption(java.lang.String OptionId,
java.lang.Object defaultValue)
Unsupported for now |
java.util.Hashtable |
getOptions()
Unsupported for now |
void |
init()
Initialize the lifecycle. |
MessageContext |
receive()
Waits indefinitely for a message to be received (blocking) |
MessageContext |
receive(long timeout)
Waits the specified amount of time for a message to be received (blocking) |
MessageContext |
receive(MessageExchangeCorrelator correlator)
Waits indefinitely for a message matching the specified correlator (blocking) |
MessageContext |
receive(MessageExchangeCorrelator correlator,
long timeout)
Waits the specified amount of time for a message matching the specified correlator (blocking) |
void |
receive(MessageExchangeCorrelator correlator,
MessageExchangeEventListener listener)
Registers a listener for receiving messages (nonblocking) |
void |
receive(MessageExchangeEventListener listener)
Registers a listener for receiving messages (nonblocking) |
MessageExchangeCorrelator |
send(MessageContext context)
Send an outbound message. |
MessageExchangeCorrelator |
send(MessageContext context,
MessageExchangeEventListener listener)
Send an outbound message. |
MessageContext |
sendAndReceive(MessageContext context)
Synchronized send and receive |
MessageContext |
sendAndReceive(MessageContext context,
long timeout)
Synchronized send and receive with timeout |
void |
setMessageExchangeEventListener(MessageExchangeEventListener listener)
see org.apache.axis.ime.MessageExchange#setMessageExchangeFaultListener(MessageExchangeFaultListener) |
void |
setOption(java.lang.String OptionId,
java.lang.Object OptionValue)
Unsupported for now |
void |
setOptions(java.util.Hashtable options)
Unsupported for now |
void |
shutdown()
Performs a "safe shutdown", allowing all current activities to complete. |
void |
shutdown(boolean force)
Performs an "unsafe shutdown", interrupting all current activities without letting them complete |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected static org.apache.commons.logging.Log log
public static final long NO_TIMEOUT
public static final long DEFAULT_TIMEOUT
protected org.apache.axis.ime.internal.MessageExchangeImpl.Holder holder
Constructor Detail |
public MessageExchangeImpl(MessageExchangeProvider provider)
Method Detail |
public MessageExchangeCorrelator send(MessageContext context) throws AxisFault
MessageExchange
send
in interface MessageExchange
AxisFault
MessageExchange.send(MessageContext)
public MessageExchangeCorrelator send(MessageContext context, MessageExchangeEventListener listener) throws AxisFault
MessageExchange
send
in interface MessageExchange
AxisFault
MessageExchange.send(MessageContext)
public MessageContext receive() throws AxisFault
MessageExchange
receive
in interface MessageExchange
AxisFault
MessageExchange.receive()
public MessageContext receive(long timeout) throws AxisFault
MessageExchange
receive
in interface MessageExchange
AxisFault
MessageExchange.receive(long)
public MessageContext receive(MessageExchangeCorrelator correlator) throws AxisFault
MessageExchange
receive
in interface MessageExchange
AxisFault
MessageExchange.receive(MessageExchangeCorrelator)
public MessageContext receive(MessageExchangeCorrelator correlator, long timeout) throws AxisFault
MessageExchange
receive
in interface MessageExchange
AxisFault
MessageExchange.receive(MessageExchangeCorrelator,long)
public void receive(MessageExchangeEventListener listener) throws AxisFault
MessageExchange
receive
in interface MessageExchange
AxisFault
org.apache.axis.ime.MessageExchange#receive(MessageContextListener)
public void receive(MessageExchangeCorrelator correlator, MessageExchangeEventListener listener) throws AxisFault
MessageExchange
receive
in interface MessageExchange
AxisFault
org.apache.axis.ime.MessageExchange#receive(MessageExchangeCorrelator,MessageContextListener)
public MessageContext sendAndReceive(MessageContext context) throws AxisFault
MessageExchange
sendAndReceive
in interface MessageExchange
AxisFault
MessageExchange.sendAndReceive(MessageContext)
public MessageContext sendAndReceive(MessageContext context, long timeout) throws AxisFault
MessageExchange
sendAndReceive
in interface MessageExchange
AxisFault
MessageExchange.sendAndReceive(MessageContext,long)
public void setMessageExchangeEventListener(MessageExchangeEventListener listener)
setMessageExchangeEventListener
in interface MessageExchange
public MessageExchangeEventListener getMessageExchangeEventListener()
getMessageExchangeEventListener
in interface MessageExchange
public void setOption(java.lang.String OptionId, java.lang.Object OptionValue)
setOption
in interface MessageExchange
public java.lang.Object getOption(java.lang.String OptionId)
getOption
in interface MessageExchange
public java.lang.Object getOption(java.lang.String OptionId, java.lang.Object defaultValue)
getOption
in interface MessageExchange
public java.util.Hashtable getOptions()
getOptions
in interface MessageExchange
public void setOptions(java.util.Hashtable options)
setOptions
in interface MessageExchange
public void clearOptions()
clearOptions
in interface MessageExchange
public void awaitShutdown() throws java.lang.InterruptedException
MessageExchangeLifecycle
awaitShutdown
in interface MessageExchangeLifecycle
java.lang.InterruptedException
MessageExchangeLifecycle.awaitShutdown()
public void cleanup() throws java.lang.InterruptedException
MessageExchangeLifecycle
cleanup
in interface MessageExchangeLifecycle
java.lang.InterruptedException
MessageExchangeLifecycle.cleanup()
public void awaitShutdown(long timeout) throws java.lang.InterruptedException
MessageExchangeLifecycle
awaitShutdown
in interface MessageExchangeLifecycle
java.lang.InterruptedException
MessageExchangeLifecycle.awaitShutdown(long)
public void init()
MessageExchangeLifecycle
init
in interface MessageExchangeLifecycle
MessageExchangeLifecycle.init()
public void shutdown()
MessageExchangeLifecycle
shutdown
in interface MessageExchangeLifecycle
MessageExchangeLifecycle.shutdown()
public void shutdown(boolean force)
MessageExchangeLifecycle
shutdown
in interface MessageExchangeLifecycle
MessageExchangeLifecycle.shutdown(boolean)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |