User: norbert
Date: 00/06/19 19:19:11
Modified: src/java/org/spydermq JMSServer.java JMSServerQueue.java
SpyConnection.java SpyMessage.java
Log:
Some optimizations to the OIL
Revision Changes Path
1.7 +3 -3 spyderMQ/src/java/org/spydermq/JMSServer.java
Index: JMSServer.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/JMSServer.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- JMSServer.java 2000/06/19 04:23:11 1.6
+++ JMSServer.java 2000/06/20 02:19:10 1.7
@@ -22,7 +22,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.6 $
+ * @version $Revision: 1.7 $
*/
public class JMSServer
implements Runnable, JMSServerMBean
@@ -37,7 +37,7 @@
// Attributes ----------------------------------------------------
//messages pending for a Destination ( HashMap of JMSServerQueue objects )
- private HashMap messageQueue;
+ public HashMap messageQueue;
//list of tasks pending ( linked list of JMSServerQueue objects )
LinkedList taskQueue; //look when we unregister a temporaryTopic/Queue
//last id given to a client
@@ -186,7 +186,7 @@
//A connection has send a new message
public void newMessage(SpyMessage val[],String id) throws JMSException
- {
+ {//Warning, a part is in the OIL file
if (val.length!=1) Log.notice("INCOMING: "+val.length+" messages from
"+id);
for(int i=0;i<val.length;i++) {
1.12 +2 -2 spyderMQ/src/java/org/spydermq/JMSServerQueue.java
Index: JMSServerQueue.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/JMSServerQueue.java,v
retrieving revision 1.11
retrieving revision 1.12
diff -u -r1.11 -r1.12
--- JMSServerQueue.java 2000/06/19 04:23:12 1.11
+++ JMSServerQueue.java 2000/06/20 02:19:10 1.12
@@ -18,7 +18,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.11 $
+ * @version $Revision: 1.12 $
*/
public class JMSServerQueue
{
@@ -91,7 +91,7 @@
}
}
- void addMessage(SpyMessage mes) throws JMSException
+ public void addMessage(SpyMessage mes) throws JMSException
{
//Add a message to the message list...
synchronized (messages)
1.10 +3 -1 spyderMQ/src/java/org/spydermq/SpyConnection.java
Index: SpyConnection.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyConnection.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- SpyConnection.java 2000/06/19 21:51:57 1.9
+++ SpyConnection.java 2000/06/20 02:19:10 1.10
@@ -29,7 +29,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.9 $
+ * @version $Revision: 1.10 $
*/
public class SpyConnection
implements Connection, Serializable
@@ -242,6 +242,8 @@
try {
+ //Log.error("Send "+mes.length+" messages");
+
/*for(int i=0;i<mes.length;i++) {
SpyMessage message=mes[i];
1.3 +2 -2 spyderMQ/src/java/org/spydermq/SpyMessage.java
Index: SpyMessage.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyMessage.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- SpyMessage.java 2000/06/09 20:03:57 1.2
+++ SpyMessage.java 2000/06/20 02:19:10 1.3
@@ -21,7 +21,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class SpyMessage
implements Serializable, Cloneable, Message
@@ -39,7 +39,7 @@
//Header fields
//Set by send() method
- Destination jmsDestination=null;
+ public Destination jmsDestination=null;
private int jmsDeliveryMode=-1;
private long jmsExpiration=0;
private int jmsPriority=-1;
