[Ubermq-commits] jms/src/com/ubermq/jms/server/routing IRouter.java,1.3,1.4 IRouterStatistics.java,1
Brought to you by:
jimmyp
From: <ji...@us...> - 2002-10-26 15:54:16
|
Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing In directory usw-pr-cvs1:/tmp/cvs-serv30900/src/com/ubermq/jms/server/routing Modified Files: IRouter.java IRouterStatistics.java Log Message: administrative application, bug fixes Index: IRouter.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/IRouter.java,v retrieving revision 1.3 retrieving revision 1.4 diff -C2 -d -r1.3 -r1.4 *** IRouter.java 21 Oct 2002 21:11:04 -0000 1.3 --- IRouter.java 26 Oct 2002 15:54:13 -0000 1.4 *************** *** 11,14 **** --- 11,15 ---- * Gets destination nodes given an implementation of a source specification. * @param source a specification + * @return a Collection of RouteDestNode objects */ public Collection getRoutes(SourceSpec source); *************** *** 18,28 **** * to an object representation in some implementation specific way. * @param source a textual source specification */ public Collection getRoutes(String source); /** ! * Returns statistics about the router's operation. ! * @return an IRouterStatistics object. */ ! public IRouterStatistics getStatistics(); } --- 19,36 ---- * to an object representation in some implementation specific way. * @param source a textual source specification + * @return a Collection of RouteDestNode objects */ public Collection getRoutes(String source); /** ! * Returns a set of source specifications that are currently ! * mapped to the specified destination node. This is considered a reverse ! * lookup and may potentially be costly, depending on implementation.<P> ! * ! * @param dest the destination ! * @return a Collection of SourceSpec objects ! * @throws UnsupportedOperationException if the router does not ! * choose to implement this reverse lookup function. */ ! public Collection getRoutesTo(RouteDestNode dest); } Index: IRouterStatistics.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/IRouterStatistics.java,v retrieving revision 1.3 retrieving revision 1.4 diff -C2 -d -r1.3 -r1.4 *** IRouterStatistics.java 21 Oct 2002 21:11:04 -0000 1.3 --- IRouterStatistics.java 26 Oct 2002 15:54:13 -0000 1.4 *************** *** 8,19 **** { /** * Returns the number of messages published to the router. */ ! public void getMessagesIn(); /** * Returns the number of messages delivered via this router. */ ! public void getMessagesOut(); /** --- 8,34 ---- { /** + * Indicates a message was received. + */ + public void messageIn(); + + /** + * Indicates that a message was sent. + */ + public void messageOut(); + + /** + * Indicates that a message was dropped. + */ + public void messageDropped(); + + /** * Returns the number of messages published to the router. */ ! public int getMessagesIn(); /** * Returns the number of messages delivered via this router. */ ! public int getMessagesOut(); /** *************** *** 21,25 **** * subscribers (i.e. dropped). */ ! public void getMessagesDropped(); /** --- 36,40 ---- * subscribers (i.e. dropped). */ ! public int getMessagesDropped(); /** *************** *** 30,34 **** /** * Indicates whether the router is active. */ ! public void isRunning(); } --- 45,56 ---- /** * Indicates whether the router is active. + * @return true if the router is active. */ ! public boolean isRunning(); ! ! /** ! * Returns a friendly description of our router statistics. ! * @return a formatted textual description of the stats. ! */ ! public String getStatisticsAsText(); } |