com/scalagent/joram/osgi/client/Activator.java

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;
  }

  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);
  }

  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);
    }

    public void createUser(String name, String password) throws Exception {
      User.create(name, password);
    }

    public Queue createQueue(String name) throws Exception {
      Queue queue = Queue.create(name);
      queue.setFreelyWriteable(true);
      queue.setFreelyReadable(true);

      return queue;
    }

    public Topic createTopic(String name) throws Exception {
      Topic topic = Topic.create(name);
      topic.setFreelyWriteable(true);
      topic.setFreelyReadable(true);

      return topic;
    }

    public List getDestinations() throws Exception {
      return AdminModule.getDestinations();
    }

    public List getUsers() throws Exception {
      return AdminModule.getUsers();
    }
  }
}

---