activator.java

一个类似于openJMS分布在ObjectWeb之下的JMS消息中间件。

package com.scalagent.joram.osgi.client;

import java.io.*;
import java.util.*;

import org.osgi.framework.*;

import javax.naming.*;

import org.objectweb.joram.client.jms.ConnectionFactory;
import org.objectweb.joram.client.jms.tcp.TcpConnectionFactory;
import org.objectweb.joram.client.jms.local.LocalConnectionFactory;
import org.objectweb.joram.client.jms.Queue;
import org.objectweb.joram.client.jms.Topic;
import org.objectweb.joram.client.jms.admin.User;
import org.objectweb.joram.client.jms.admin.AdminModule;

public class Activator implements BundleActivator {

  private static BundleContext bcontext;

  public static BundleContext getBundleContext() {
    return bcontext;
  }

  /**
   * Implements BundleActivator.start().
   *
   * @param context the framework context for the bundle.
   */
  public void start(BundleContext context) throws Exception {
    bcontext = context;

    Properties props = new Properties();
    context.registerService(
      com.scalagent.joram.osgi.client.service.JoramClient.class.getName(), 
      new JoramClientImpl(), props);
  }

  /**
   * Implements BundleActivator.stop().
   *
   * @param context the framework context for the bundle.
   */
  public void stop(BundleContext context) {
  }

  public static class JoramClientImpl 
    implements com.scalagent.joram.osgi.client.service.JoramClient {
    /**
     *
     */
    public void connect(String host, int port,
                        String name, String password,
                        int cnxTimer) throws Exception {
      AdminModule.connect(host, port, name, password, cnxTimer);
    }
    /**
     *
     */
    public void disconnect() {
      AdminModule.disconnect();
    }

    /**
     *
     */
    public ConnectionFactory
        getTcpConnectionFactory(String hostname, int port) throws Exception {
      return new TcpConnectionFactory(hostname, port);
    }

    /**
     *
     */
    public Context getInitialContext() throws Exception {
      Properties prop = new Properties();
      prop.setProperty("java.naming.factory.initial", "fr.dyade.aaa.jndi2.client.NamingContextFactory");
      prop.setProperty("java.naming.factory.host", "localhost");
      prop.setProperty("java.naming.factory.port", "16400");
      return getInitialContext(prop);
    }

    /**
     *
     */
    public Context getInitialContext(Hashtable prop) throws Exception {
      Thread ct = Thread.currentThread();
      ClassLoader cl = ct.getContextClassLoader();
      ct.setContextClassLoader(JoramClientImpl.class.getClassLoader());
      Context ctx = new InitialContext(prop);
      ct.setContextClassLoader(cl);
      return ctx;
    }

    /**
     *
     */
    public boolean executeAdminXML(Reader reader) throws Exception {
      return AdminModule.executeAdmin(reader);
    }

    /**
     * Creates or retrieves a user on the underlying JORAM server.
     *
     * @exception Exception   If the creation fails.
     */
    public void createUser(String name, String password) throws Exception {
      User.create(name, password);
    }

    /**
     * Creates or retrieves a queue destination on the underlying JORAM server,
     * (re)binds the corresponding <code>Queue</code> instance.
     *
     * @param name       The name of the queue.
     *
     * @exception Exception   If the creation fails.
     */
    public Queue createQueue(String name) throws Exception {
      Queue queue = Queue.create(name);
      queue.setFreelyWriteable(true);
      queue.setFreelyReadable(true);

      return queue;
    }

    /**
     * Creates or retrieves a topic destination on the underlying JORAM server,
     * (re)binds the corresponding <code>Topic</code> instance.
     *
     * @exception Exception   If the creation fails.
     */
    public Topic createTopic(String name) throws Exception {
      Topic topic = Topic.create(name);
      topic.setFreelyWriteable(true);
      topic.setFreelyReadable(true);

      return topic;
    }

    /**
     * Returns the list of all destinations that exist on the server.
     */
    public List getDestinations() throws Exception {
      return AdminModule.getDestinations();
    }

    /**
     * Returns the list of all users that exist on a given server.
     */
    public List getUsers() throws Exception {
      return AdminModule.getUsers();
    }
  }
}