axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Davanum Srinivas <d...@yahoo.com>
Subject Re: cvs commit: xml-axis/java/src/org/apache/axis/ime MessageExchangeEvent.java MessageExchangeEventListener.java MessageExchange.java MessageExchangeFaultListener.java MessageExchangeStatusListener.java MessageContextListener.java
Date Wed, 13 Nov 2002 14:39:12 GMT
James,

Is there a summary list of items for this changes?

Thanks,
dims


--- jmsnell@apache.org wrote:
> jmsnell     2002/11/12 21:24:20
> 
>   Modified:    java/src/org/apache/axis/ime/internal
>                         MessageExchangeSendContext.java
>                         FirstComeFirstServeDispatchPolicy.java
>                         MessageExchangeProvider.java
>                         MessageExchangeImpl.java
>                         MessageExchangeReceiveContext.java
>                java/src/org/apache/axis/ime/internal/util/handler
>                         HandlerMessageExchange.java
>                java/src/org/apache/axis/ime MessageExchange.java
>   Added:       java/src/org/apache/axis/ime/event MessageSendEvent.java
>                         MessageCorrelatedEvent.java MessageFaultEvent.java
>                         MessageReceiveEvent.java MessageStatusEvent.java
>                java/src/org/apache/axis/ime MessageExchangeEvent.java
>                         MessageExchangeEventListener.java
>   Removed:     java/src/org/apache/axis/ime/internal
>                         MessageExchangeSendListener.java
>                java/src/org/apache/axis/ime
>                         MessageExchangeFaultListener.java
>                         MessageExchangeStatusListener.java
>                         MessageContextListener.java
>   Log:
>   Commiting some changes made by the Sonic folks
>   
>   Revision  Changes    Path
>   1.2       +7 -14    
> xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeSendContext.java
>   
>   Index: MessageExchangeSendContext.java
>   ===================================================================
>   RCS file:
> /home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeSendContext.java,v
>   retrieving revision 1.1
>   retrieving revision 1.2
>   diff -u -r1.1 -r1.2
>   --- MessageExchangeSendContext.java	29 Oct 2002 05:15:29 -0000	1.1
>   +++ MessageExchangeSendContext.java	13 Nov 2002 05:24:19 -0000	1.2
>   @@ -56,8 +56,7 @@
>    
>    import org.apache.axis.MessageContext;
>    import org.apache.axis.ime.MessageExchangeCorrelator;
>   -import org.apache.axis.ime.MessageExchangeFaultListener;
>   -import org.apache.axis.ime.MessageExchangeStatusListener;
>   +import org.apache.axis.ime.MessageExchangeEventListener;
>    
>    import java.io.Serializable;
>    
>   @@ -70,6 +69,7 @@
>     * For thread safety, instances of this class are immutable
>     * 
>     * @author James M Snell (jasnell@us.ibm.com)
>   + * @author Ray Chun (rchun@sonicsoftware.com)
>     */
>    public final class MessageExchangeSendContext
>            implements Serializable {
>   @@ -77,20 +77,17 @@
>        public static MessageExchangeSendContext newInstance(
>                MessageExchangeCorrelator correlator,
>                MessageContext context,
>   -            MessageExchangeFaultListener faultListener,
>   -            MessageExchangeStatusListener statusListener) {
>   +            MessageExchangeEventListener eventListener) {
>            MessageExchangeSendContext mectx =
>                    new MessageExchangeSendContext();
>            mectx.correlator = correlator;
>            mectx.context = context;
>   -        mectx.faultListener = faultListener;
>   -        mectx.statusListener = statusListener;
>   +        mectx.eventListener = eventListener;
>            return mectx;
>        }
>    
>        protected MessageExchangeCorrelator correlator;
>   -    protected MessageExchangeFaultListener faultListener;
>   -    protected MessageExchangeStatusListener statusListener;
>   +    protected MessageExchangeEventListener eventListener;
>        protected MessageContext context;
>    
>        protected MessageExchangeSendContext() {
>   @@ -104,11 +101,7 @@
>            return this.context;
>        }
>    
>   -    public MessageExchangeFaultListener getMessageExchangeFaultListener() {
>   -        return this.faultListener;
>   -    }
>   -
>   -    public MessageExchangeStatusListener getMessageExchangeStatusListener() {
>   -        return this.statusListener;
>   +    public MessageExchangeEventListener getMessageExchangeEventListener() {
>   +        return this.eventListener;
>        }    
>    }
>   
>   
>   
>   1.3       +18 -11   
> xml-axis/java/src/org/apache/axis/ime/internal/FirstComeFirstServeDispatchPolicy.java
>   
>   Index: FirstComeFirstServeDispatchPolicy.java
>   ===================================================================
>   RCS file:
>
/home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/FirstComeFirstServeDispatchPolicy.java,v
>   retrieving revision 1.2
>   retrieving revision 1.3
>   diff -u -r1.2 -r1.3
>   --- FirstComeFirstServeDispatchPolicy.java	29 Oct 2002 23:33:40 -0000	1.2
>   +++ FirstComeFirstServeDispatchPolicy.java	13 Nov 2002 05:24:20 -0000	1.3
>   @@ -56,14 +56,16 @@
>    
>    import org.apache.axis.MessageContext;
>    import org.apache.axis.ime.MessageExchangeCorrelator;
>   -import org.apache.axis.ime.MessageContextListener;
>   -import org.apache.axis.ime.MessageExchangeFaultListener;
>   +import org.apache.axis.ime.MessageExchangeEventListener;
>   +import org.apache.axis.ime.event.MessageFaultEvent;
>   +import org.apache.axis.ime.event.MessageReceiveEvent;
>    import org.apache.axis.ime.internal.util.KeyedBuffer;
>    import org.apache.axis.components.logger.LogFactory;
>    import org.apache.commons.logging.Log;
>    
>    /**
>     * @author James M Snell (jasnell@us.ibm.com)
>   + * @author Ray Chun (rchun@sonicsoftware.com)
>     */
>    public class FirstComeFirstServeDispatchPolicy
>            implements ReceivedMessageDispatchPolicy {
>   @@ -104,19 +106,24 @@
>            if (receiveContext == null) 
>                RECEIVE.put(correlator,context);
>            else {
>   -            MessageExchangeFaultListener faultListener = 
>   -              receiveContext.getMessageExchangeFaultListener();
>   -            MessageContextListener contextListener = 
>   -              receiveContext.getMessageContextListener();
>   +            MessageExchangeEventListener eventListener = 
>   +              receiveContext.getMessageExchangeEventListener();
>                MessageContext msgContext = 
>                  context.getMessageContext();
>                try {
>   -                contextListener.onReceive(
>   -                    correlator, msgContext);       
>   +                MessageReceiveEvent receiveEvent = 
>   +                    new org.apache.axis.ime.event.MessageReceiveEvent(
>   +                            correlator, 
>   +                            receiveContext, 
>   +                            context.getMessageContext());
>   +                eventListener.onEvent(receiveEvent);
>                } catch (Exception exception) {
>   -              if (faultListener != null)
>   -                  faultListener.onFault(
>   -                      correlator, exception);
>   +              if (eventListener != null) {
>   +                  MessageFaultEvent faultEvent = new MessageFaultEvent(
>   +                        correlator,
>   +                        exception);
>   +                  eventListener.onEvent(faultEvent);
>   +              }
>                }
>            }
>            if (log.isDebugEnabled()) {
>   
>   
>   
>   1.9       +13 -7    
> 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.8
>   retrieving revision 1.9
>   diff -u -r1.8 -r1.9
>   --- MessageExchangeProvider.java	29 Oct 2002 23:33:40 -0000	1.8
>   +++ MessageExchangeProvider.java	13 Nov 2002 05:24:20 -0000	1.9
>   @@ -60,10 +60,10 @@
>    import org.apache.axis.Handler;
>    import org.apache.axis.MessageContext;
>    import org.apache.axis.ime.MessageExchange;
>   -import org.apache.axis.ime.MessageContextListener;
>   +import org.apache.axis.ime.MessageExchangeEventListener;
>    import org.apache.axis.ime.MessageExchangeCorrelator;
>    import org.apache.axis.ime.MessageExchangeFactory;
>   -import org.apache.axis.ime.MessageExchangeFaultListener;
>   +import org.apache.axis.ime.event.MessageSendEvent;
>    import org.apache.axis.ime.internal.util.WorkerPool;
>    import org.apache.axis.ime.internal.util.KeyedBuffer;
>    import org.apache.axis.ime.internal.util.NonPersistentKeyedBuffer;
>   @@ -74,6 +74,7 @@
>    
>    /**
>     * @author James M Snell (jasnell@us.ibm.com)
>   + * @author Ray Chun (rchun@sonicsoftware.com)
>     */
>    public abstract class MessageExchangeProvider
>            implements MessageExchangeFactory {
>   @@ -99,7 +100,7 @@
>          return null;
>        }
> 
=== message truncated ===


=====
Davanum Srinivas - http://xml.apache.org/~dims/

__________________________________________________
Do you Yahoo!?
U2 on LAUNCH - Exclusive greatest hits videos
http://launch.yahoo.com/u2

Mime
View raw message