[Ubermq-commits] RE: Ubermq-commits digest, Vol 1 #137 - 1 msg

[Sin Le R. <Sin@Cybersoft-VN.com>]

-----Original Message-----
From: ube...@li...
[mailto:ube...@li...]On Behalf Of
ube...@li...
Sent: Friday, December 13, 2002 9:05 AM
To: ube...@li...
Subject: Ubermq-commits digest, Vol 1 #137 - 1 msg


Send Ubermq-commits mailing list submissions to
	ube...@li...

To subscribe or unsubscribe via the World Wide Web, visit
	https://lists.sourceforge.net/lists/listinfo/ubermq-commits
or, via email, send a message with subject or body 'help' to
	ube...@li...

You can reach the person managing the list at
	ube...@li...

When replying, please edit your Subject line so it is more specific
than "Re: Contents of Ubermq-commits digest..."


Today's Topics:

   1. RE: Ubermq-commits digest, Vol 1 #133 - 7 msgs (Sin Le Roop)

--__--__--

Message: 1
Date: Fri, 13 Dec 2002 09:03:09 +0700
From: "Sin Le Roop" <Sin@Cybersoft-VN.com>
To: <ube...@li...>
Subject: [Ubermq-commits] RE: Ubermq-commits digest, Vol 1 #133 - 7 msgs




-----Original Message-----
From: ube...@li...
[mailto:ube...@li...]
Sent: Friday, December 13, 2002 1:03 AM
To: ube...@li...
Subject: Ubermq-commits digest, Vol 1 #133 - 7 msgs


Send Ubermq-commits mailing list submissions to
	ube...@li...

To subscribe or unsubscribe via the World Wide Web, visit
	https://lists.sourceforge.net/lists/listinfo/ubermq-commits
or, via email, send a message with subject or body 'help' to
	ube...@li...

You can reach the person managing the list at
	ube...@li...

When replying, please edit your Subject line so it is more specific
than "Re: Contents of Ubermq-commits digest..."


Today's Topics:

   1. jms/src/com/ubermq/jms/server/routing/impl =3D
SimpleSelector.java,1.3,1.4 (ji...@us...)
   2. jms/lib jms.jar,1.1,1.2 (ji...@us...)
   3. jms server.properties,1.5,1.6 (ji...@us...)
   4. jms/src/com/ubermq/jms/client PipeConnectionFactory.java,NONE,1.1 =
=3D
UnicastConnectionFactory.java,NONE,1.1 IClientProcessor.java,1.8,1.9 =3D
MulticastTopicConnectionFactory.java,1.5,1.6 =3D
PipeTopicConnectionFactory.java,1.2,1.3 =3D
URLTopicConnectionFactory.java,1.3,1.4 =3D
UnicastTopicConnectionFactory.java,1.6,1.7 =3D
(ji...@us...)
   5. jms/src/com/ubermq/jms/client/msg LocalBytesMessage.java,1.4,1.5 =
=3D
(ji...@us...)
   6. jms/src/com/ubermq/jms/client/multicast =3D
MulticastTopicConnection.java,1.7,1.8 (ji...@us...)
   7. jms/src/com/ubermq/jms/client/proc ClientProc.java,1.21,1.22 =3D
(ji...@us...)

-- __--__--=20

Message: 1
From: ji...@us...
To: ube...@li...
Date: Thu, 12 Dec 2002 10:01:53 -0800
Subject: [Ubermq-commits] jms/src/com/ubermq/jms/server/routing/impl =3D
SimpleSelector.java,1.3,1.4

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/impl
In directory =3D
sc8-pr-cvs1:/tmp/cvs-serv797/src/com/ubermq/jms/server/routing/impl

Modified Files:
	SimpleSelector.java=3D20
Log Message:
JMS 1.1 support (full backwards compatibility)
queue support (incomplete - functional, but w/o administrative =3D
capabilities)


Index: SimpleSelector.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/impl/SimpleSelector=
=3D
.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** SimpleSelector.java	12 Sep 2002 22:23:10 -0000	1.3
--- SimpleSelector.java	12 Dec 2002 18:01:51 -0000	1.4
***************
*** 13,90 ****
   */
  public class SimpleSelector
! 	implements Selector
  {
! 	private String property, scalar;
! 	private int operator;
! 	private boolean valid;
! =3D09
! 	private static final int EQUALS =3D3D 0, GREATER =3D3D 1, LESS =3D3D =
2, =3D
NOTEQUAL =3D3D 3;
! 	private static final String WHERE_REGEX =3D3D =3D
"where\\s*(\\w*)\\s*(=3D3D|>|<|!=3D3D|<>)\\s*(\\w*)";
! =3D09
! 	public SimpleSelector(String sz)
! 	{
! 		// parse the string.
! 		Pattern p =3D3D Pattern.compile(WHERE_REGEX, =3D
Pattern.CASE_INSENSITIVE);
! 		Matcher m =3D3D p.matcher(sz);
! 	=3D09
! 		if (m.matches()) {
! 			property =3D3D m.group(1);
! 			scalar =3D3D m.group(3);
! 		=3D09
! 			String op =3D3D m.group(2);
! 			if (op.equals("=3D3D")) operator =3D3D EQUALS;
! 			else if (op.equals("<>") || op.equals("!=3D3D")) operator =3D3D =3D
NOTEQUAL;
! 			else if (op.equals(">")) operator =3D3D GREATER;
! 			else if (op.equals("<")) operator =3D3D LESS;
! 			else operator =3D3D EQUALS;
! 		=3D09
! 			if (scalar.equalsIgnoreCase("NULL"))
! 				scalar =3D3D null;
! 		=3D09
! 			valid =3D3D true;
! 		}
! 		else valid =3D3D false;
! 	}
! =3D09
! 	public boolean accept(IMessageDatagram msg)
! 	{
! 		Object value =3D3D null;
! 	=3D09
! 		// if we are not valid, return false for everything.
! 		if (!valid) return false;
! 	=3D09
! 		if (property.equals("JMSDeliveryMode")) {
! 			value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_DELIVERYMODE);
! 		} else if (property.equals("JMSPriority")) {
! 			value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_PRIORITY);
! 		} else if (property.equals("JMSMessageID")) {
! 			value =3D3D msg.getMessageId();
! 		} else if (property.equals("JMSTimestamp")) {
! 			value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_TIMESTAMP);
! 		} else if (property.equals("JMSCorrelationID")) {
! 			value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_CORRELATIONID);
! 		} else {
! 			value =3D3D msg.getCustomProperty(property);
! 		}
! 	=3D09
! 		com.ubermq.Utility.getLogger().fine("selector comparing " + property =
=3D
+ " containing " + value + " with " + scalar);
! 	=3D09
! 		if (value =3D3D=3D3D null || scalar =3D3D=3D3D null) {
! 			return (value =3D3D=3D3D null && scalar =3D3D=3D3D null && operator =
=3D3D=3D3D =3D
EQUALS);
! 		} else {
! 			switch(operator) {
! 				case EQUALS:
! 					return (value.toString().equals(scalar));
! 				case NOTEQUAL:
! 					return !(value.toString().equals(scalar));
! 				default:
! 					return false;
! 			}
! 		}
! 	}
! =3D09
! 	public String toString()
! 	{
! 		return "Property: " + property + " operator: " + operator + " =3D
scalar: " + scalar;
! 	}
  }
--- 13,90 ----
   */
  public class SimpleSelector
!     implements Selector
  {
!     private String property, scalar;
!     private int operator;
!     private boolean valid;
!=3D20
!     private static final int EQUALS =3D3D 0, GREATER =3D3D 1, LESS =
=3D3D 2, =3D
NOTEQUAL =3D3D 3;
!     public static final String WHERE_REGEX =3D3D =3D
"where\\s*(\\S*)\\s*(=3D3D|>|<|!=3D3D|<>)\\s*'??([^']*)'??";
!=3D20
!     public SimpleSelector(String sz)
!     {
!         // parse the string.
!         Pattern p =3D3D Pattern.compile(WHERE_REGEX, =3D
Pattern.CASE_INSENSITIVE);
!         Matcher m =3D3D p.matcher(sz);
!=3D20
!         if (m.matches()) {
!             property =3D3D m.group(1);
!             scalar =3D3D m.group(3);
!=3D20
!             String op =3D3D m.group(2);
!             if (op.equals("=3D3D")) operator =3D3D EQUALS;
!             else if (op.equals("<>") || op.equals("!=3D3D")) operator =
=3D
=3D3D NOTEQUAL;
!             else if (op.equals(">")) operator =3D3D GREATER;
!             else if (op.equals("<")) operator =3D3D LESS;
!             else operator =3D3D EQUALS;
!=3D20
!             if (scalar.equalsIgnoreCase("NULL"))
!                 scalar =3D3D null;
!=3D20
!             valid =3D3D true;
!         }
!         else valid =3D3D false;
!     }
!=3D20
!     public boolean accept(IMessageDatagram msg)
!     {
!         Object value =3D3D null;
!=3D20
!         // if we are not valid, return false for everything.
!         if (!valid) return false;
!=3D20
!         if (property.equals("JMSDeliveryMode")) {
!             value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_DELIVERYMODE);
!         } else if (property.equals("JMSPriority")) {
!             value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_PRIORITY);
!         } else if (property.equals("JMSMessageID")) {
!             value =3D3D msg.getMessageId();
!         } else if (property.equals("JMSTimestamp")) {
!             value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_TIMESTAMP);
!         } else if (property.equals("JMSCorrelationID")) {
!             value =3D3D =3D
msg.getStandardProperty(IMessageDatagram.STDPROP_CORRELATIONID);
!         } else {
!             value =3D3D msg.getCustomProperty(property);
!         }
!=3D20
!         com.ubermq.Utility.getLogger().fine("selector comparing " + =
=3D
property + " containing " + value + " with " + scalar);
!=3D20
!         if (value =3D3D=3D3D null || scalar =3D3D=3D3D null) {
!             return (value =3D3D=3D3D null && scalar =3D3D=3D3D null && =
=3D
operator =3D3D=3D3D EQUALS);
!         } else {
!             switch(operator) {
!                 case EQUALS:
!                     return (value.toString().equals(scalar));
!                 case NOTEQUAL:
!                     return !(value.toString().equals(scalar));
!                 default:
!                     return false;
!             }
!         }
!     }
!=3D20
!     public String toString()
!     {
!         return "Property: " + property + " operator: " + operator + " =
=3D
scalar: " + scalar;
!     }
  }




-- __--__--=20

Message: 2
From: ji...@us...
To: ube...@li...
Date: Thu, 12 Dec 2002 10:02:19 -0800
Subject: [Ubermq-commits] jms/lib jms.jar,1.1,1.2

Update of /cvsroot/ubermq/jms/lib
In directory sc8-pr-cvs1:/tmp/cvs-serv797/lib

Modified Files:
	jms.jar=3D20
Log Message:
JMS 1.1 support (full backwards compatibility)
queue support (incomplete - functional, but w/o administrative =3D
capabilities)


Index: jms.jar
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: /cvsroot/ubermq/jms/lib/jms.jar,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
Binary files /tmp/cvs3gkgXF and /tmp/cvscck6Vd differ




-- __--__--=20

Message: 3
From: ji...@us...
To: ube...@li...
Date: Thu, 12 Dec 2002 10:02:19 -0800
Subject: [Ubermq-commits] jms server.properties,1.5,1.6

Update of /cvsroot/ubermq/jms
In directory sc8-pr-cvs1:/tmp/cvs-serv797

Modified Files:
	server.properties=3D20
Log Message:
JMS 1.1 support (full backwards compatibility)
queue support (incomplete - functional, but w/o administrative =3D
capabilities)


Index: server.properties
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: /cvsroot/ubermq/jms/server.properties,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** server.properties	6 Dec 2002 15:22:15 -0000	1.5
--- server.properties	12 Dec 2002 18:01:46 -0000	1.6
***************
*** 4,8 ****
  server.durable.logsize=3D3D1000000
  server.durable.logprefix=3D3Ddurable-
! server.admin.enable=3D3Dtrue
  clustering.enable=3D3Dfalse
  clustering.address=3D3D224.1.2.3
--- 4,8 ----
  server.durable.logsize=3D3D1000000
  server.durable.logprefix=3D3Ddurable-
! server.admin.enable=3D3Dfalse
  clustering.enable=3D3Dfalse
  clustering.address=3D3D224.1.2.3




-- __--__--=20

Message: 4
From: ji...@us...
To: ube...@li...
Date: Thu, 12 Dec 2002 10:02:19 -0800
Subject: [Ubermq-commits] jms/src/com/ubermq/jms/client =3D
PipeConnectionFactory.java,NONE,1.1 =3D
UnicastConnectionFactory.java,NONE,1.1 IClientProcessor.java,1.8,1.9 =3D
MulticastTopicConnectionFactory.java,1.5,1.6 =3D
PipeTopicConnectionFactory.java,1.2,1.3 =3D
URLTopicConnectionFactory.java,1.3,1.4 =3D
UnicastTopicConnectionFactory.java,1.6,1.7

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client
In directory sc8-pr-cvs1:/tmp/cvs-serv797/src/com/ubermq/jms/client

Modified Files:
	IClientProcessor.java MulticastTopicConnectionFactory.java=3D20
	PipeTopicConnectionFactory.java URLTopicConnectionFactory.java=3D20
	UnicastTopicConnectionFactory.java=3D20
Added Files:
	PipeConnectionFactory.java UnicastConnectionFactory.java=3D20
Log Message:
JMS 1.1 support (full backwards compatibility)
queue support (incomplete - functional, but w/o administrative =3D
capabilities)


--- NEW FILE: PipeConnectionFactory.java ---
package com.ubermq.jms.client;

import com.ubermq.jms.client.impl.*;
import com.ubermq.jms.client.unicast.*;
import com.ubermq.jms.server.*;
import javax.jms.*;

/**
 * Creates a pipe-based topic connection, connected to a particular
 * in-process message server object.
 */
public class PipeConnectionFactory
    extends AbstractConnectionFactory
{
    private MessageServer s;

    public PipeConnectionFactory(MessageServer s)
    {
        this.s =3D3D s;
    }

    public javax.jms.Connection createConnection()
        throws JMSException
    {
        try {
            return new PipeConnection(s);
        } catch(Exception x) {throw new JMSException(x.toString());}
    }
}

--- NEW FILE: UnicastConnectionFactory.java ---
package com.ubermq.jms.client;

import com.ubermq.jms.client.impl.*;
import com.ubermq.jms.client.unicast.*;
import java.net.*;
import javax.jms.*;

/**
 * Creates a point to point topic connection, attached to a particular
 * message server instance.
 */
public class UnicastConnectionFactory
    extends AbstractConnectionFactory
    implements java.io.Serializable
{
    private final InternetConnectionDescriptor icd;
    public static final long serialVersionUID =3D3D 1L;

    /**
     * Connects to a named URL, if the string is of the form =3D
<code>method://host:port</code>
     * or a named host on the default port (3999) otherwise.<p>
     *
     * The URL may also be a comma separated list of URLs, indicating
     * that failover should occur if a host is unreachable. <p>
     *
     * The method specification is ignored.<P>
     *
     * @see com.ubermq.jms.server.MessageServer.DEFAULT_PORT
     * @see com.ubermq.jms.client.unicast.FailoverConnectionDescriptor
     * @param host a URL, or the name of the host to connect to.
     */
    public UnicastConnectionFactory(String url)
    {
        this.icd =3D3D =3D
FailoverConnectionDescriptor.parseFailoverSpec(url);
    }

    public UnicastConnectionFactory(URI uri)
    {
        String hosts =3D3D uri.getSchemeSpecificPart();
        int slash =3D3D hosts.indexOf('/', 2);  // we start at 2 to skip =
=3D
the leading //
        if (slash >=3D3D 0)
            hosts =3D3D hosts.substring(0, slash);

        this.icd =3D3D =3D
FailoverConnectionDescriptor.parseFailoverSpec(hosts);
    }

    /**
     * Connects to a named host and port.
     *
     * @param host the host to connect to.
     * @param port the port to connect on.
     */
    public UnicastConnectionFactory(String host, int port)
    {
        this.icd =3D3D new SimpleInternetConnectionDescriptor(host, =
port);
    }

    public javax.jms.Connection createConnection() throws JMSException
    {
        try {
            return new UnicastConnection(icd);
        } catch(Exception x) {throw new JMSException(x.toString());}
    }
}

Index: IClientProcessor.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/IClientProcessor.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -C2 -d -r1.8 -r1.9
*** IClientProcessor.java	18 Oct 2002 16:59:26 -0000	1.8
--- IClientProcessor.java	12 Dec 2002 18:01:47 -0000	1.9
***************
*** 56,59 ****
--- 56,73 ----
 =3D20
      /**
+      * Begins receiving messages from a queue, with the given =3D
selector,
+      * to the specified endpoint.
+      */
+     public void startQueue(String queue,
+                            String selector,
+                            IDatagramEndpoint e);
+=3D20
+     /**
+      * Stops a queue from sending messages to the endpoint.
+      */
+     public void stopQueue(String queue,
+                           IDatagramEndpoint e);
+=3D20
+     /**
       * Executes a control sequence on the remote. This is a
       * combination of an output datagram and a wait for a return ACK.

Index: MulticastTopicConnectionFactory.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/MulticastTopicConnectionFac=
=3D
tory.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** MulticastTopicConnectionFactory.java	18 Oct 2002 16:59:26 -0000	1.5
--- MulticastTopicConnectionFactory.java	12 Dec 2002 18:01:47 -0000	1.6
***************
*** 6,11 ****
  import javax.jms.*;
 =3D20
- import javax.jms.TopicConnection;
-=3D20
  /**
   * Instantiates a topic connection using the UberMQ LRMP multicast
--- 6,9 ----
***************
*** 44,52 ****
      }
 =3D20
!     public TopicConnection createTopicConnection(String p0, String p1)
          throws JMSException
      {
          return createTopicConnection();
      }
 =3D20
  }
--- 42,61 ----
      }
 =3D20
!     public javax.jms.TopicConnection createTopicConnection(String p0, =
=3D
String p1)
          throws JMSException
      {
          return createTopicConnection();
      }
+=3D20
+     public javax.jms.Connection createConnection(String p0, String p1) =
=3D
throws JMSException
+     {
+         return createTopicConnection(p0, p1);
+     }
+=3D20
+     public javax.jms.Connection createConnection() throws JMSException
+     {
+         return createTopicConnection();
+     }
+=3D20
 =3D20
  }

Index: PipeTopicConnectionFactory.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/PipeTopicConnectionFactory.=
=3D
java,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** PipeTopicConnectionFactory.java	18 Oct 2002 16:59:26 -0000	1.2
--- PipeTopicConnectionFactory.java	12 Dec 2002 18:01:47 -0000	1.3
***************
*** 7,35 ****
  /**
   * Creates a pipe-based topic connection, connected to a particular
!  * in-process message server object.
   */
! public class PipeTopicConnectionFactory
      implements javax.jms.TopicConnectionFactory, java.io.Serializable
  {
-     private MessageServer s;
      public static final long serialVersionUID =3D3D 1L;
 =3D20
      public PipeTopicConnectionFactory(MessageServer s)
      {
!         this.s =3D3D s;
!     }
!=3D20
!     public javax.jms.TopicConnection createTopicConnection()
!         throws JMSException
!     {
!         try {
!             return new PipeConnection(s);
!         } catch(Exception x) {throw new JMSException(x.toString());}
!     }
!=3D20
!     public javax.jms.TopicConnection createTopicConnection(String =3D
user, String cred)
!         throws JMSException
!     {
!         return createTopicConnection();
      }
  }
--- 7,30 ----
  /**
   * Creates a pipe-based topic connection, connected to a particular
!  * in-process message server object.<P>
!  *
!  * This connection factory is obsolete since JMS 1.1. Please use
!  * the <code>PipeConnectionFactory</code> for all future applications.
!  * This class will be removed in the future.<P>
!  *
!  * @deprecated
   */
! public final class PipeTopicConnectionFactory
!     extends PipeConnectionFactory
      implements javax.jms.TopicConnectionFactory, java.io.Serializable
  {
      public static final long serialVersionUID =3D3D 1L;
 =3D20
+     /**
+      * @deprecated
+      */
      public PipeTopicConnectionFactory(MessageServer s)
      {
!         super(s);
      }
  }

Index: URLTopicConnectionFactory.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/URLTopicConnectionFactory.j=
=3D
ava,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** URLTopicConnectionFactory.java	7 Dec 2002 20:21:09 -0000	1.3
--- URLTopicConnectionFactory.java	12 Dec 2002 18:01:47 -0000	1.4
***************
*** 93,97 ****
 =3D20
          // register the default factories
!         registerFactory(DEFAULT_UBERMQ_SCHEME, =3D
UnicastTopicConnectionFactory.class);
          registerFactory(DEFAULT_UBERMQ_MULTICAST_SCHEME, =3D
MulticastTopicConnectionFactory.class);
 =3D20
--- 93,97 ----
 =3D20
          // register the default factories
!         registerFactory(DEFAULT_UBERMQ_SCHEME, =3D
UnicastConnectionFactory.class);
          registerFactory(DEFAULT_UBERMQ_MULTICAST_SCHEME, =3D
MulticastTopicConnectionFactory.class);
 =3D20
***************
*** 216,219 ****
--- 216,228 ----
      }
 =3D20
+     public Connection createConnection() throws JMSException
+     {
+         return delegate.createConnection();
+     }
+=3D20
+     public Connection createConnection(String p0, String p1) throws =
=3D
JMSException
+     {
+         return delegate.createConnection(p0, p1);
+     }
 =3D20
  }

Index: UnicastTopicConnectionFactory.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/UnicastTopicConnectionFacto=
=3D
ry.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -C2 -d -r1.6 -r1.7
*** UnicastTopicConnectionFactory.java	5 Nov 2002 21:25:27 -0000	1.6
--- UnicastTopicConnectionFactory.java	12 Dec 2002 18:01:47 -0000	1.7
***************
*** 8,17 ****
  /**
   * Creates a point to point topic connection, attached to a particular
!  * message server instance.
   */
  public final class UnicastTopicConnectionFactory
      implements javax.jms.TopicConnectionFactory, java.io.Serializable
  {
-     private final InternetConnectionDescriptor icd;
      public static final long serialVersionUID =3D3D 1L;
 =3D20
--- 8,23 ----
  /**
   * Creates a point to point topic connection, attached to a particular
!  * message server instance.<P>
!  *
!  * This connection factory is obsolete since JMS 1.1. Please use
!  * the <code>PipeConnectionFactory</code> for all future applications.
!  * This class will be removed in the future.<P>
!  *
!  * @deprecated
   */
  public final class UnicastTopicConnectionFactory
+     extends UnicastConnectionFactory
      implements javax.jms.TopicConnectionFactory, java.io.Serializable
  {
      public static final long serialVersionUID =3D3D 1L;
 =3D20
***************
*** 28,45 ****
       * @see com.ubermq.jms.client.unicast.FailoverConnectionDescriptor
       * @param host a URL, or the name of the host to connect to.
       */
      public UnicastTopicConnectionFactory(String url)
      {
!         this.icd =3D3D =3D
FailoverConnectionDescriptor.parseFailoverSpec(url);
      }
 =3D20
      public UnicastTopicConnectionFactory(URI uri)
      {
!         String hosts =3D3D uri.getSchemeSpecificPart();
!         int slash =3D3D hosts.indexOf('/', 2);  // we start at 2 to =
skip =3D
the leading //
!         if (slash >=3D3D 0)
!             hosts =3D3D hosts.substring(0, slash);
!=3D20
!         this.icd =3D3D =3D
FailoverConnectionDescriptor.parseFailoverSpec(hosts);
      }
 =3D20
--- 34,50 ----
       * @see com.ubermq.jms.client.unicast.FailoverConnectionDescriptor
       * @param host a URL, or the name of the host to connect to.
+      * @deprecated
       */
      public UnicastTopicConnectionFactory(String url)
      {
!         super(url);
      }
 =3D20
+     /**
+      * @deprecated
+      */
      public UnicastTopicConnectionFactory(URI uri)
      {
!         super(uri);
      }
 =3D20
***************
*** 49,70 ****
       * @param host the host to connect to.
       * @param port the port to connect on.
       */
      public UnicastTopicConnectionFactory(String host, int port)
      {
!         this.icd =3D3D new SimpleInternetConnectionDescriptor(host, =
=3D
port);
!     }
!=3D20
!     public javax.jms.TopicConnection createTopicConnection()
!         throws JMSException
!     {
!         try {
!             return new UnicastTopicConnection(icd);
!         } catch(Exception x) {throw new JMSException(x.toString());}
!     }
!=3D20
!     public javax.jms.TopicConnection createTopicConnection(String =3D
user, String cred)
!         throws JMSException
!     {
!         return createTopicConnection();
      }
  }
--- 54,62 ----
       * @param host the host to connect to.
       * @param port the port to connect on.
+      * @deprecated
       */
      public UnicastTopicConnectionFactory(String host, int port)
      {
!         super(host, port);
      }
  }




-- __--__--=20

Message: 5
From: ji...@us...
To: ube...@li...
Date: Thu, 12 Dec 2002 10:02:20 -0800
Subject: [Ubermq-commits] jms/src/com/ubermq/jms/client/msg =3D
LocalBytesMessage.java,1.4,1.5

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg
In directory sc8-pr-cvs1:/tmp/cvs-serv797/src/com/ubermq/jms/client/msg

Modified Files:
	LocalBytesMessage.java=3D20
Log Message:
JMS 1.1 support (full backwards compatibility)
queue support (incomplete - functional, but w/o administrative =3D
capabilities)


Index: LocalBytesMessage.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg/LocalBytesMessage.java,=
=3D
v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** LocalBytesMessage.java	19 Sep 2002 17:30:31 -0000	1.4
--- LocalBytesMessage.java	12 Dec 2002 18:01:48 -0000	1.5
***************
*** 1,8 ****
  package com.ubermq.jms.client.msg;
 =3D20
  import com.ubermq.jms.server.datagram.*;
 =3D20
- import com.ubermq.jms.client.IAcknowledgeHandler;
-=3D20
  /**
   * A BytesMessage implementation that simply inherits stream =3D
functionality
--- 1,7 ----
  package com.ubermq.jms.client.msg;
 =3D20
+ import com.ubermq.jms.client.*;
  import com.ubermq.jms.server.datagram.*;
 =3D20
  /**
   * A BytesMessage implementation that simply inherits stream =3D
functionality
***************
*** 10,21 ****
   */
  public class LocalBytesMessage
! 	extends AbstractStreamMessage
! 	implements javax.jms.BytesMessage
  {
      public LocalBytesMessage(IMessageDatagram md, IAcknowledgeHandler =
=3D
a) {
! 		super(md, a);
      }
      public LocalBytesMessage(IMessageDatagramFactory f) {super(f);}
!    =3D20
      public int getMessageType() {return =3D
com.ubermq.jms.client.impl.LocalMessage.MSGTYPE_BYTES;}
  }
--- 9,31 ----
   */
  public class LocalBytesMessage
!     extends AbstractStreamMessage
!     implements javax.jms.BytesMessage
  {
      public LocalBytesMessage(IMessageDatagram md, IAcknowledgeHandler =
=3D
a) {
!         super(md, a);
      }
      public LocalBytesMessage(IMessageDatagramFactory f) {super(f);}
!=3D20
!     public long getBodyLength() throws javax.jms.JMSException
!     {
!         try
!         {
!             return super.in.available();
!         }
!         catch (java.io.IOException e) {
!             throw new JMSIOException(e);
!         }
!     }
!=3D20
      public int getMessageType() {return =3D
com.ubermq.jms.client.impl.LocalMessage.MSGTYPE_BYTES;}
  }




-- __--__--=20

Message: 6
From: ji...@us...
To: ube...@li...
Date: Thu, 12 Dec 2002 10:02:20 -0800
Subject: [Ubermq-commits] jms/src/com/ubermq/jms/client/multicast =3D
MulticastTopicConnection.java,1.7,1.8

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/multicast
In directory =3D
sc8-pr-cvs1:/tmp/cvs-serv797/src/com/ubermq/jms/client/multicast

Modified Files:
	MulticastTopicConnection.java=3D20
Log Message:
JMS 1.1 support (full backwards compatibility)
queue support (incomplete - functional, but w/o administrative =3D
capabilities)


Index: MulticastTopicConnection.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/multicast/MulticastTopicCon=
=3D
nection.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -C2 -d -r1.7 -r1.8
*** MulticastTopicConnection.java	18 Oct 2002 16:59:27 -0000	1.7
--- MulticastTopicConnection.java	12 Dec 2002 18:01:48 -0000	1.8
***************
*** 15,19 ****
   */
  public class MulticastTopicConnection
!     extends TopicConnection
  {
      private static IClientSession theSession =3D3D new =3D
LrmpClientSession();
--- 15,19 ----
   */
  public class MulticastTopicConnection
!     extends Connection
  {
      private static IClientSession theSession =3D3D new =3D
LrmpClientSession();




-- __--__--=20

Message: 7
From: ji...@us...
To: ube...@li...
Date: Thu, 12 Dec 2002 10:02:21 -0800
Subject: [Ubermq-commits] jms/src/com/ubermq/jms/client/proc =3D
ClientProc.java,1.21,1.22

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/proc
In directory sc8-pr-cvs1:/tmp/cvs-serv797/src/com/ubermq/jms/client/proc

Modified Files:
	ClientProc.java=3D20
Log Message:
JMS 1.1 support (full backwards compatibility)
queue support (incomplete - functional, but w/o administrative =3D
capabilities)


Index: ClientProc.java
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D
=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D3D=3D=
3D=3D3D=3D3D
RCS file: =3D
/cvsroot/ubermq/jms/src/com/ubermq/jms/client/proc/ClientProc.java,v
retrieving revision 1.21
retrieving revision 1.22
diff -C2 -d -r1.21 -r1.22
*** ClientProc.java	14 Nov 2002 22:25:29 -0000	1.21
--- ClientProc.java	12 Dec 2002 18:01:48 -0000	1.22
***************
*** 3,6 ****
--- 3,7 ----
  import EDU.oswego.cs.dl.util.concurrent.*;
  import com.ubermq.jms.client.*;
+ import com.ubermq.jms.client.impl.*;
  import com.ubermq.jms.server.datagram.*;
  import com.ubermq.jms.server.routing.*;
***************
*** 246,249 ****
--- 247,275 ----
      {
          controlSequence(controlFactory.durableGoingAway(name), =3D
controlHandler);
+     }
+=3D20
+     /**
+      * Begins receiving messages from a queue, with the given =3D
selector,
+      * to the specified endpoint.
+      */
+     public void startQueue(String queue, String selector, =3D
IDatagramEndpoint e)
+     {
+         SourceSpec ss =3D3D new =3D
TopicSourceSpec(LocalQueue.getTopicForQueueName(queue).getTopicName());
+=3D20
+         // check if there is an endpoint already registered here.
+         boolean alreadyRegistered =3D3D internalRegister(ss, e);
+         if (!alreadyRegistered)
+             controlSequence(controlFactory.queueStart(queue, =3D
selector), controlHandler);
+     }
+=3D20
+     /**
+      * Stops a queue from sending messages to the endpoint.
+      */
+     public void stopQueue(String queue, IDatagramEndpoint e)
+     {
+         SourceSpec ss =3D3D new =3D
TopicSourceSpec(LocalQueue.getTopicForQueueName(queue).getTopicName());
+=3D20
+         subRouter.remove(ss, new EndpointDestNode(e));
+         controlSequence(controlFactory.queueStop(queue), =3D
controlHandler);
      }
 =3D20





-- __--__--=20

_______________________________________________
Ubermq-commits mailing list
Ube...@li...
https://lists.sourceforge.net/lists/listinfo/ubermq-commits


End of Ubermq-commits Digest





--__--__--

_______________________________________________
Ubermq-commits mailing list
Ube...@li...
https://lists.sourceforge.net/lists/listinfo/ubermq-commits


End of Ubermq-commits Digest