org.apache.axis.ime.internal
Class MessageExchangeProvider
java.lang.Object
|
+--org.apache.axis.ime.internal.MessageExchangeProvider
- All Implemented Interfaces:
- MessageExchangeFactory
- Direct Known Subclasses:
- HandlerMessageExchange
- public abstract class MessageExchangeProvider
- extends java.lang.Object
- implements MessageExchangeFactory
- Author:
- James M Snell (jasnell@us.ibm.com), Ray Chun (rchun@sonicsoftware.com)
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
protected static org.apache.commons.logging.Log log
SELECT_TIMEOUT
public static final long SELECT_TIMEOUT
DEFAULT_THREAD_COUNT
public static final long DEFAULT_THREAD_COUNT
WORKERS
protected final ThreadPool WORKERS
SEND
protected final KeyedBuffer SEND
RECEIVE
protected final KeyedBuffer RECEIVE
RECEIVE_REQUESTS
protected final KeyedBuffer RECEIVE_REQUESTS
sendHandler
protected Handler sendHandler
receiveHandler
protected Handler receiveHandler
initialized
protected boolean initialized
MessageExchangeProvider
public MessageExchangeProvider()
getSendHandler
public Handler getSendHandler()
getReceiveHandler
public Handler getReceiveHandler()
setSendHandler
public void setSendHandler(Handler handler)
setReceiveHandler
public void setReceiveHandler(Handler handler)
getMessageExchangeEventListener
protected abstract MessageExchangeEventListener getMessageExchangeEventListener()
getReceivedMessageDispatchPolicy
protected abstract ReceivedMessageDispatchPolicy getReceivedMessageDispatchPolicy()
createMessageExchange
public MessageExchange createMessageExchange()
throws AxisFault
- Specified by:
createMessageExchange
in interface MessageExchangeFactory
- Following copied from interface:
org.apache.axis.ime.MessageExchangeFactory
- Returns:
- MessageExchange
- Throws:
AxisFault
-
createMessageExchange
public MessageExchange createMessageExchange(java.util.Hashtable options)
throws AxisFault
- Specified by:
createMessageExchange
in interface MessageExchangeFactory
- Following copied from interface:
org.apache.axis.ime.MessageExchangeFactory
- Parameters:
java.lang.Map
- Collection of propertiesString
- Array of feature id's to enable- Returns:
- ConfigurableMessageExchange
cleanup
public void cleanup()
throws java.lang.InterruptedException
init
public void init()
init
public void init(long THREAD_COUNT)
processReceive
public void processReceive(MessageExchangeReceiveContext context)
processSend
public void processSend(MessageExchangeSendContext context)
shutdown
public void shutdown()
shutdown
public void shutdown(boolean force)
awaitShutdown
public void awaitShutdown()
throws java.lang.InterruptedException
awaitShutdown
public void awaitShutdown(long shutdown)
throws java.lang.InterruptedException
setOption
public void setOption(java.lang.String propertyId,
java.lang.Object propertyValue)
- Unsupported for now
- See Also:
getOption
public java.lang.Object getOption(java.lang.String propertyId)
- Unsupported for now
- See Also:
getOption
public java.lang.Object getOption(java.lang.String propertyId,
java.lang.Object defaultValue)
- Unsupported for now
- See Also:
getOptions
public java.util.Hashtable getOptions()
- Unsupported for now
- See Also:
setOptions
public void setOptions(java.util.Hashtable properties)
- Unsupported for now
- See Also:
clearOptions
public void clearOptions()
- Unsupported for now
- See Also:
Copyright © 2003 Apache Web Services Project. All Rights Reserved.