cvs commit: xml-axis/java/src/org/apache/axis/ime/internal MessageExchangeProvider.java

[jmsnell]

jmsnell     2002/11/19 13:18:20

  Modified:    java/src/org/apache/axis/ime/internal
                        MessageExchangeProvider.java
  Log:
  Initial checkin of IME enabled HTTP, Java and Local transport senders.  This part 
simply wraps the existing HTTPSender, JavaSender and LocalSender handlers into a 
MessageExchangeProvider so we're able to use all of the existing code.
  
  Revision  Changes    Path
  1.10      +14 -4     
xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeProvider.java
  
  Index: MessageExchangeProvider.java
  ===================================================================
  RCS file: 
/home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeProvider.java,v
  retrieving revision 1.9
  retrieving revision 1.10
  diff -u -r1.9 -r1.10
  --- MessageExchangeProvider.java      13 Nov 2002 05:24:20 -0000      1.9
  +++ MessageExchangeProvider.java      19 Nov 2002 21:18:20 -0000      1.10
  @@ -89,15 +89,25 @@
       protected final KeyedBuffer SEND = new NonPersistentKeyedBuffer(WORKERS);
       protected final KeyedBuffer RECEIVE = new NonPersistentKeyedBuffer(WORKERS);
       protected final KeyedBuffer RECEIVE_REQUESTS = new 
NonPersistentKeyedBuffer(WORKERS);
  +    protected Handler sendHandler = null;
  +    protected Handler receiveHandler = null; 
   
       protected boolean initialized = false;
   
  -    protected Handler getSendHandler() {
  -      return null;
  +    public Handler getSendHandler() {
  +      return sendHandler;
       }
       
  -    protected Handler getReceiveHandler() {
  -      return null;
  +    public Handler getReceiveHandler() {
  +      return receiveHandler;
  +    }
  +
  +    public void setSendHandler(Handler handler) {
  +      this.sendHandler = handler;
  +    }
  +    
  +    public void setReceiveHandler(Handler handler) {
  +      this.receiveHandler = handler;
       }
   
       protected abstract MessageExchangeEventListener 
getMessageExchangeEventListener();