[Ubermq-commits] jms/src/com/ubermq/jms/client/impl AbstractConnectionFactory.java,NONE,1.1 LocalQueue.java,NONE,1.1 LocalTopic.java,NONE,1.1

[<ji...@us...>]

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

Added Files:
	AbstractConnectionFactory.java LocalQueue.java LocalTopic.java 
Log Message:
missing files


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

/**
 * A convenience implementation for a connection factory
 * that does not need to distinguish between topic and queue
 * connections, and does not use username and password information.
 * <P>
 *
 * All method calls are delegated to the <code>createConnection</code> method.<P>
 */
public abstract class AbstractConnectionFactory
    implements javax.jms.ConnectionFactory,
    javax.jms.TopicConnectionFactory,
    javax.jms.QueueConnectionFactory
{
    public javax.jms.TopicConnection createTopicConnection(String p0, String p1) throws javax.jms.JMSException
    {
        return (javax.jms.TopicConnection)createConnection();
    }

    public javax.jms.TopicConnection createTopicConnection() throws javax.jms.JMSException
    {
        return (javax.jms.TopicConnection)createConnection();
    }

    public javax.jms.QueueConnection createQueueConnection(String p0, String p1) throws javax.jms.JMSException
    {
        return (javax.jms.QueueConnection)createConnection();
    }

    public javax.jms.QueueConnection createQueueConnection() throws javax.jms.JMSException
    {
        return (javax.jms.QueueConnection)createConnection();
    }

    public javax.jms.Connection createConnection(String p0, String p1) throws javax.jms.JMSException
    {
        return createConnection();
    }
}

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

import javax.jms.*;

public class LocalQueue
    implements java.io.Serializable, javax.jms.Queue
{
    public static final long serialVersionUID = 1L;

    /**
     * A prefix for queue names that yields the actual UberMQ
     * topic name for the queue.
     */
    public static final String QUEUE_TOPIC_PREFIX = ".queue.";

    private String name;

    LocalQueue(String name)
    {
        this.name = name;
    }

    public String getQueueName()
    {
        return name;
    }

    /**
     * Returns the UberMQ topic name that is used to implement
     * the named queue.
     *
     * @return   a topic name
     */
    Topic getTopic()
    {
        return LocalQueue.getTopicForQueueName(name);
    }

    /**
     * Returns the UberMQ topic name that is used to implement
     * the named queue.
     *
     * @return   a topic name
     */
    public static LocalTopic getTopicForQueueName(String name)
    {
        return new LocalTopic(QUEUE_TOPIC_PREFIX + name);
    }


}


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

/**
 * A simple Topic representation that encapsulates a String topic name.
 */
public final class LocalTopic
    implements javax.jms.TemporaryTopic,
    java.io.Serializable
{
    private String name;

    LocalTopic(String name)
    {
        if (name == null)
            throw new IllegalArgumentException();
        this.name = name;
    }

    public String getTopicName()
    {
        return name;
    }

    public void delete()
    {
        // nothing needs to happen to delete a temp. topic
    }

    public boolean equals(Object o)
    {
        if (o instanceof LocalTopic) {
            return (((LocalTopic)o).name.equals(name));
        } else {
            return false;
        }
    }
    public int hashCode() {return name.hashCode();}
    public String toString() {return name;}
}