Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 67)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 72)
@@ -4,5 +4,4 @@
 import java.lang.reflect.Method;
 import java.util.ArrayList;
-import java.util.Collection;
 import java.util.HashMap;
 import java.util.List;
@@ -10,14 +9,10 @@
 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,5 +37,4 @@
 	private Properties env;
 	private transient Broker broker;
-	private transient Serializer serializer;
 	private transient RemoteWrapper remoteWrapper;
 	private transient Map<String, List<Class<?>>> params;
@@ -69,5 +63,4 @@
 		multiQueue = UID + System.currentTimeMillis();
 		env = broker.getEnvironment();
-		serializer = broker.getSerializer();
 
 		params = new HashMap<String, List<Class<?>>>();
@@ -93,5 +86,4 @@
 		this.broker = broker;
 		UID = reference;
-		serializer = broker.getSerializer();
 		if (channel == null || !channel.isOpen()) {
 			channel = broker.getChannel();
@@ -141,15 +133,4 @@
 	}
 
-	@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,16 +246,3 @@
 	}
 
-	@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;
-	}
-
 }