|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.apache.axis.ime.internal.MessageExchangeImpl
Inner 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 |
clearProperties()
Unsupported for now |
void |
disableFeature(java.lang.String featureId)
Unsupported for now |
void |
enableFeature(java.lang.String featureId)
Unsupported for now |
MessageExchangeEventListener |
getMessageExchangeEventListener()
see org.apache.axis.ime.MessageExchange#getMessageExchangeStatusListener() |
java.util.Map |
getProperties()
Unsupported for now |
java.lang.Object |
getProperty(java.lang.String propertyId)
Unsupported for now |
java.lang.Object |
getProperty(java.lang.String propertyId,
java.lang.Object defaultValue)
Unsupported for now |
java.lang.String[] |
getSupportedFeatures()
Unsupported for now |
void |
init()
Initialize the lifecycle. |
boolean |
isFeatureEnabled(java.lang.String featureId)
Unsupported for now |
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 |
setProperties(java.util.Map properties)
Unsupported for now |
void |
setProperty(java.lang.String propertyId,
java.lang.Object propertyValue)
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
MessageExchange.send(MessageContext)
public MessageExchangeCorrelator send(MessageContext context, MessageExchangeEventListener listener) throws AxisFault
MessageExchange
send
in interface MessageExchange
MessageExchange.send(MessageContext)
public MessageContext receive() throws AxisFault
MessageExchange
receive
in interface MessageExchange
MessageExchange.receive()
public MessageContext receive(long timeout) throws AxisFault
MessageExchange
receive
in interface MessageExchange
MessageExchange.receive(long)
public MessageContext receive(MessageExchangeCorrelator correlator) throws AxisFault
MessageExchange
receive
in interface MessageExchange
MessageExchange.receive(MessageExchangeCorrelator)
public MessageContext receive(MessageExchangeCorrelator correlator, long timeout) throws AxisFault
MessageExchange
receive
in interface MessageExchange
MessageExchange.receive(MessageExchangeCorrelator,long)
public void receive(MessageExchangeEventListener listener) throws AxisFault
MessageExchange
receive
in interface MessageExchange
org.apache.axis.ime.MessageExchange#receive(MessageContextListener)
public void receive(MessageExchangeCorrelator correlator, MessageExchangeEventListener listener) throws AxisFault
MessageExchange
receive
in interface MessageExchange
org.apache.axis.ime.MessageExchange#receive(MessageExchangeCorrelator,MessageContextListener)
public MessageContext sendAndReceive(MessageContext context) throws AxisFault
MessageExchange
sendAndReceive
in interface MessageExchange
MessageExchange.sendAndReceive(MessageContext)
public MessageContext sendAndReceive(MessageContext context, long timeout) throws AxisFault
MessageExchange
sendAndReceive
in interface MessageExchange
MessageExchange.sendAndReceive(MessageContext,long)
public void setMessageExchangeEventListener(MessageExchangeEventListener listener)
setMessageExchangeEventListener
in interface MessageExchange
public MessageExchangeEventListener getMessageExchangeEventListener()
getMessageExchangeEventListener
in interface MessageExchange
public void enableFeature(java.lang.String featureId) throws AxisFault
enableFeature
in interface FeatureEnabled
public void disableFeature(java.lang.String featureId) throws AxisFault
disableFeature
in interface FeatureEnabled
public boolean isFeatureEnabled(java.lang.String featureId) throws AxisFault
isFeatureEnabled
in interface FeatureEnabled
public java.lang.String[] getSupportedFeatures() throws AxisFault
getSupportedFeatures
in interface FeatureEnabled
public void setProperty(java.lang.String propertyId, java.lang.Object propertyValue)
setProperty
in interface MessageExchange
public java.lang.Object getProperty(java.lang.String propertyId)
getProperty
in interface MessageExchange
public java.lang.Object getProperty(java.lang.String propertyId, java.lang.Object defaultValue)
getProperty
in interface MessageExchange
public java.util.Map getProperties()
getProperties
in interface MessageExchange
public void setProperties(java.util.Map properties)
setProperties
in interface MessageExchange
public void clearProperties()
clearProperties
in interface MessageExchange
public void awaitShutdown() throws java.lang.InterruptedException
MessageExchangeLifecycle
awaitShutdown
in interface MessageExchangeLifecycle
MessageExchangeLifecycle.awaitShutdown()
public void cleanup() throws java.lang.InterruptedException
MessageExchangeLifecycle
cleanup
in interface MessageExchangeLifecycle
MessageExchangeLifecycle.cleanup()
public void awaitShutdown(long timeout) throws java.lang.InterruptedException
MessageExchangeLifecycle
awaitShutdown
in interface MessageExchangeLifecycle
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: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |