Dims, Basically the changes entail replacing the fine-grained event model that existed in the IME with a generic event/listener model. For example, in the previous versions there were MessageContextListener implementations that received MessageContext messages, StatusEventListeners that received StatusEvents and FaultListeners that received FaultEvents. The new model is that there is a single listener that receives MessageExchangeEvents. All of the previous events are extensions of the MessageExchangeEvents. This allows a single listener to receive all events that are applicable to a MessageExchange as opposed to requiring individual listeners for every event type.
Thanks, Jaime -----Original Message----- From: Davanum Srinivas [mailto:dims@;yahoo.com] Sent: Wednesday, November 13, 2002 9:39 AM To: [EMAIL PROTECTED] Cc: [EMAIL PROTECTED] Subject: Re: cvs commit: xml-axis/java/src/org/apache/axis/ime MessageExchangeEvent.java MessageExchangeEventListener.java MessageExchange.java MessageExchangeFaultListener.java MessageExchangeStatusListener.java MessageContextListener.java James, Is there a summary list of items for this changes? Thanks, dims --- [EMAIL PROTECTED] 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/MessageExchangeSendContex t.java > > Index: MessageExchangeSendContext.java > =================================================================== > RCS file: > /home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/MessageExchange SendContext.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 ([EMAIL PROTECTED]) > + * @author Ray Chun ([EMAIL PROTECTED]) > */ > 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/FirstComeFirstServeDispat chPolicy.java > > Index: FirstComeFirstServeDispatchPolicy.java > =================================================================== > RCS file: > /home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/FirstComeFirstS erveDispatchPolicy.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 ([EMAIL PROTECTED]) > + * @author Ray Chun ([EMAIL PROTECTED]) > */ > 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.j ava > > Index: MessageExchangeProvider.java > =================================================================== > RCS file: > /home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/MessageExchange Provider.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 ([EMAIL PROTECTED]) > + * @author Ray Chun ([EMAIL PROTECTED]) > */ > 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
