Index: trunk/src/main/java/omq/client/proxy/MultiProxymq.java
===================================================================
--- trunk/src/main/java/omq/client/proxy/MultiProxymq.java	(revision 64)
+++ 	(revision )
@@ -1,16 +1,0 @@
-package omq.client.proxy;
-
-import java.lang.reflect.InvocationHandler;
-import java.lang.reflect.Method;
-
-public class MultiProxymq implements InvocationHandler {
-
-	@Override
-	public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
-		
-		
-		
-		return null;
-	}
-
-}
Index: trunk/src/main/java/omq/common/broker/Broker.java
===================================================================
--- trunk/src/main/java/omq/common/broker/Broker.java	(revision 64)
+++ trunk/src/main/java/omq/common/broker/Broker.java	(revision 66)
@@ -150,4 +150,13 @@
 		try {
 			remote.startRemoteObject(reference, this);
+			remoteObjs.put(reference, remote);
+		} catch (Exception e) {
+			throw new RemoteException(e);
+		}
+	}
+	
+	public void startTriggerEvent(String reference, RemoteObject remote) throws RemoteException {
+		try {
+			remote.startTriggerEvent(reference, this);
 			remoteObjs.put(reference, remote);
 		} catch (Exception e) {
Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 64)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 66)
@@ -90,4 +90,12 @@
 	}
 
+	public void startTriggerEvent(String reference, Broker broker) throws Exception {
+		this.broker = broker;
+		UID = reference;
+		if (channel == null || !channel.isOpen()) {
+			channel = broker.getChannel();
+		}
+	}
+
 	@Override
 	public void run() {