Changeset 72 for trunk/src/main/java/omq/common/broker/Broker.java

Timestamp:

06/29/13 20:44:27 (11 years ago)

Author:

stoda

Message:

Events deleted instead of them there's a new example of how to use the observer pattern

File:

• trunk/src/main/java/omq/common/broker/Broker.java (modified) (6 diffs)

trunk/src/main/java/omq/common/broker/Broker.java

@@ -13 +13 @@
 import omq.client.proxy.MultiProxymq;
 import omq.client.proxy.Proxymq;
-import omq.common.event.Event;
-import omq.common.event.EventDispatcher;
-import omq.common.event.EventWrapper;
 import omq.common.util.OmqConnectionFactory;
 import omq.common.util.ParameterQueue;
@@ -21 +18 @@
 import omq.exception.InitBrokerException;
 import omq.exception.RemoteException;
-import omq.exception.SerializerException;
 import omq.server.RemoteObject;
 
@@ -41 +37 @@
         private Channel channel;
         private ResponseListener responseListener;
-        private EventDispatcher eventDispatcher;
         private Serializer serializer;
         private boolean clientStarted = false;
@@ -75 +70 @@
                 if (clientStarted) {
                         responseListener.kill();
-                        eventDispatcher.kill();
                         // TODO proxies = null; ??
                 }
@@ -211 +205 @@
                         responseListener.start();
                 }
-                if (eventDispatcher == null) {
-                        eventDispatcher = new EventDispatcher(this);
-                        eventDispatcher.start();
-                }
-        }
-
-        /**
-         * This method sends an event with its information
-         * 
-         * @param event
-         * @throws IOException
-         * @throws SerializerException
-         */
-        public void trigger(Event event) throws IOException, SerializerException {
-                String UID = event.getTopic();
-                EventWrapper wrapper = new EventWrapper(event);
-                logger.debug("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
-                channel.exchangeDeclare(UID, "fanout");
-
-                byte[] bytesResponse = serializer.serialize(wrapper);
-                channel.basicPublish(UID, "", null, bytesResponse);
         }
 
@@ -318 +291 @@
         }
 
-        public EventDispatcher getEventDispatcher() {
-                return eventDispatcher;
-        }
-
         public Serializer getSerializer() {
                 return serializer;