User: hiram
Date: 00/11/27 15:03:52
Modified: src/java/org/spydermq/distributed/server
ConnectionReceiverUIL.java
DistributedJMSServerUIL.java
Log:
Revision Changes Path
1.3 +3 -2
spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverUIL.java
Index: ConnectionReceiverUIL.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverUIL.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- ConnectionReceiverUIL.java 2000/11/19 20:00:01 1.2
+++ ConnectionReceiverUIL.java 2000/11/27 23:03:51 1.3
@@ -35,13 +35,14 @@
import java.io.ObjectOutputStream;
import java.io.IOException;
-import org.spydermq.SpyMessageConsumer;/**
+import org.spydermq.SpyMessageConsumer;
+/**
* The OIL implementation of the ConnectionReceiver object
*
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class ConnectionReceiverUIL
implements Runnable, ConnectionReceiverSetup
1.3 +1 -5
spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerUIL.java
Index: DistributedJMSServerUIL.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerUIL.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- DistributedJMSServerUIL.java 2000/11/19 20:00:02 1.2
+++ DistributedJMSServerUIL.java 2000/11/27 23:03:52 1.3
@@ -36,7 +36,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
import org.spydermq.multiplexor.SocketMultiplexor;import
org.spydermq.SpyAcknowledgementItem;public class DistributedJMSServerUIL
implements Runnable, DistributedJMSServerSetup, DistributedJMSServerUILMBean
@@ -98,16 +98,12 @@
socket = serverSocket.accept();
new Thread(this).start();
- Log.log("SeverUIL initializing");
-
mSocket = new SocketMultiplexor(socket);
out = new ObjectOutputStream(new
BufferedOutputStream(mSocket.getOutputStream(1)));
out.flush();
in = new ObjectInputStream(new
BufferedInputStream(mSocket.getInputStream(1)));
-
- Log.log("SeverUIL initialized");
} catch (IOException e) {
failure("Initialisation",e);