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)

Inner Class Summary
static class MessageExchangeProvider.MessageReceiver
           
static class MessageExchangeProvider.MessageSender
           
 
Field Summary
static long DEFAULT_THREAD_COUNT
           
protected  boolean initialized
           
protected static org.apache.commons.logging.Log log
           
protected  KeyedBuffer RECEIVE
           
protected  KeyedBuffer RECEIVE_REQUESTS
           
protected  Handler receiveHandler
           
static long SELECT_TIMEOUT
           
protected  KeyedBuffer SEND
           
protected  Handler sendHandler
           
protected  WorkerPool WORKERS
           
 
Constructor Summary
MessageExchangeProvider()
           
 
Method Summary
 void awaitShutdown()
           
 void awaitShutdown(long shutdown)
           
 void cleanup()
           
 MessageExchange createMessageExchange()
           
 MessageExchange createMessageExchange(java.util.Map properties, java.lang.String[] enabledFeatures)
          Unsupported for now
protected abstract  MessageExchangeEventListener getMessageExchangeEventListener()
           
protected abstract  ReceivedMessageDispatchPolicy getReceivedMessageDispatchPolicy()
           
 Handler getReceiveHandler()
           
 Handler getSendHandler()
           
 void init()
           
 void init(long THREAD_COUNT)
           
 void processReceive(MessageExchangeReceiveContext context)
           
 void processSend(MessageExchangeSendContext context)
           
 void setReceiveHandler(Handler handler)
           
 void setSendHandler(Handler handler)
           
 void shutdown()
           
 void shutdown(boolean force)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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 WorkerPool 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
Constructor Detail

MessageExchangeProvider

public MessageExchangeProvider()
Method Detail

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.Map properties,
                                             java.lang.String[] enabledFeatures)
                                      throws AxisFault
Unsupported for now
Specified by:
createMessageExchange in interface MessageExchangeFactory
Following copied from interface: org.apache.axis.ime.MessageExchangeFactory
Parameters:
java.lang.Map - Collection of properties
String - 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


Copyright © 2002 Apache XML Project. All Rights Reserved.