Changeset 72 for trunk/src/main/java/omq/server

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/server/RemoteObject.java (modified) (7 diffs)

trunk/src/main/java/omq/server/RemoteObject.java

@@ -4 +4 @@
 import java.lang.reflect.Method;
 import java.util.ArrayList;
-import java.util.Collection;
 import java.util.HashMap;
 import java.util.List;
@@ -10 +9 @@
 import java.util.Properties;
 
-import org.apache.log4j.Logger;
-
 import omq.Remote;
 import omq.common.broker.Broker;
-import omq.common.event.Event;
-import omq.common.event.EventListener;
-import omq.common.event.EventWrapper;
 import omq.common.util.ParameterQueue;
-import omq.common.util.Serializer;
 import omq.exception.SerializerException;
+
+import org.apache.log4j.Logger;
 
 import com.rabbitmq.client.Channel;
@@ -42 +37 @@
         private Properties env;
         private transient Broker broker;
-        private transient Serializer serializer;
         private transient RemoteWrapper remoteWrapper;
         private transient Map<String, List<Class<?>>> params;
@@ -69 +63 @@
                 multiQueue = UID + System.currentTimeMillis();
                 env = broker.getEnvironment();
-                serializer = broker.getSerializer();
 
                 params = new HashMap<String, List<Class<?>>>();
@@ -93 +86 @@
                 this.broker = broker;
                 UID = reference;
-                serializer = broker.getSerializer();
                 if (channel == null || !channel.isOpen()) {
                         channel = broker.getChannel();
@@ -141 +133 @@
         }
 
-        @Override
-        public void notifyEvent(Event event) throws IOException, SerializerException {
-                String corrID = java.util.UUID.randomUUID().toString();
-                event.setTopic(UID);
-                event.setCorrId(corrID);
-                EventWrapper wrapper = new EventWrapper(event);
-                channel.exchangeDeclare(UID, "fanout");
-                channel.basicPublish(UID, "", null, serializer.serialize(wrapper));
-                logger.debug("Sending event-> topic: " + UID + ", corrID: " + corrID);
-        }
-
         public void kill() throws IOException {
                 logger.warn("Killing objectmq: " + this.getRef());
@@ -265 +246 @@
         }
 
-        @Override
-        public void addListener(EventListener<?> eventListener) throws Exception {
-        }
-
-        @Override
-        public void removeListener(EventListener<?> eventListener) throws Exception {
-        }
-
-        @Override
-        public Collection<EventListener<?>> getListeners() throws Exception {
-                return null;
-        }
-
 }