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

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/client/proxy/Proxymq.java (modified) (8 diffs)

trunk/src/main/java/omq/client/proxy/Proxymq.java

@@ -1 +1 @@
 package omq.client.proxy;
 
-import java.io.IOException;
 import java.lang.reflect.Array;
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.Method;
-import java.util.Collection;
 import java.util.HashMap;
 import java.util.Map;
@@ -16 +14 @@
 import omq.client.listener.ResponseListener;
 import omq.common.broker.Broker;
-import omq.common.event.Event;
-import omq.common.event.EventDispatcher;
-import omq.common.event.EventListener;
 import omq.common.message.Request;
 import omq.common.message.Response;
@@ -25 +20 @@
 import omq.exception.OmqException;
 import omq.exception.RetryException;
-import omq.exception.SerializerException;
 import omq.exception.TimeoutException;
 
@@ -55 +49 @@
         private transient Broker broker;
         private transient ResponseListener rListener;
-        private transient EventDispatcher dispatcher;
         private transient Serializer serializer;
         private transient Properties env;
         private transient Map<String, byte[]> results;
-        private transient Map<String, EventListener<?>> listeners;
 
         private static final Map<String, Class<?>> primitiveClasses = new HashMap<String, Class<?>>();
@@ -92 +84 @@
                 this.broker = broker;
                 rListener = broker.getResponseListener();
-                dispatcher = broker.getEventDispatcher();
                 serializer = broker.getSerializer();
 
@@ -105 +96 @@
                 serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
 
-                listeners = new HashMap<String, EventListener<?>>();
-
                 // Create a new hashmap and registry it in rListener
                 results = new HashMap<String, byte[]>();
@@ -121 +110 @@
                         if (methodName.equals("getRef")) {
                                 return getRef();
-                        } else if (methodName.equals("addListener")) {
-                                addListener((EventListener<?>) arguments[0]);
-                                return null;
-                        } else if (methodName.equals("removeListener")) {
-                                removeListener((EventListener<?>) arguments[0]);
-                                return null;
-                        } else if (methodName.equals("getListeners")) {
-                                return getListeners();
                         }
                 }
@@ -306 +287 @@
         }
 
-        @Override
-        public void notifyEvent(Event event) throws IOException, SerializerException {
-        }
-
-        @Override
-        public void addListener(EventListener<?> eventListener) throws Exception {
-                if (eventListener.getTopic() == null) {
-                        eventListener.setTopic(uid);
-                }
-                listeners.put(eventListener.getTopic(), eventListener);
-                dispatcher.addListener(eventListener);
-        }
-
-        @Override
-        public void removeListener(EventListener<?> eventListener) throws Exception {
-                listeners.remove(eventListener.getTopic());
-                dispatcher.removeListener(eventListener);
-        }
-
-        @Override
-        public Collection<EventListener<?>> getListeners() throws Exception {
-                return listeners.values();
-        }
-
 }