source: objectmq/src/omq/common/event/EventTrigger.java @ 3

package omq.common.event;

import java.io.IOException;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.util.Properties;

import omq.common.remote.RevoConnectionFactory;
import omq.common.util.RevoEnvironment;
import omq.common.util.Serializer;
import omq.exception.EnvironmentException;
import omq.exception.SerializerException;


import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

/**
 * This class is used to publish events into a topic
 * 
 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
 * 
 */
public class EventTrigger {
        private static EventTrigger trigger;
        private static Connection connection;
        private static Channel channel;

        private EventTrigger(Properties env) throws IOException, KeyManagementException, NoSuchAlgorithmException {
                connection = RevoConnectionFactory.getConnection(env);
                channel = connection.createChannel();
        }

        public static void initEventTrigger(Properties env) throws EnvironmentException, Exception {
                if (trigger == null) {
                        trigger = new EventTrigger(env);
                }
        }

        public static void initEventTrigger() throws EnvironmentException, Exception {
                if (trigger == null) {
                        trigger = new EventTrigger(RevoEnvironment.getEnvironment());
                }
        }

        public static synchronized void publish(String topic, Object obj) throws IOException, SerializerException {
                Event event = new Event(topic, obj);
                channel.exchangeDeclare(topic, "fanout");
                channel.basicPublish(topic, "", null, Serializer.serialize(event));
        }

        public static synchronized void publish(String topic, Event event) throws IOException, SerializerException {
                channel.exchangeDeclare(topic, "fanout");
                channel.basicPublish(topic, "", null, Serializer.serialize(event));
        }

        public static void close() throws Exception {
                trigger = null;
                channel.close();
                connection.close();
        }
}