Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 72)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 74)
@@ -58,11 +58,11 @@
 	}
 
-	public void startRemoteObject(String reference, Broker broker) throws Exception {
+	public void startRemoteObject(String reference, Broker broker, Properties env) throws Exception {
 		this.broker = broker;
-		UID = reference;
-		multiQueue = UID + System.currentTimeMillis();
-		env = broker.getEnvironment();
-
-		params = new HashMap<String, List<Class<?>>>();
+		this.UID = reference;
+		this.multiQueue = UID + System.currentTimeMillis();
+		this.env = env;
+
+		this.params = new HashMap<String, List<Class<?>>>();
 		for (Method m : this.getClass().getMethods()) {
 			List<Class<?>> list = new ArrayList<Class<?>>();
@@ -70,10 +70,10 @@
 				list.add(clazz);
 			}
-			params.put(m.getName(), list);
+			this.params.put(m.getName(), list);
 		}
 
 		// Get num threads to use
 		int numThreads = Integer.parseInt(env.getProperty(ParameterQueue.NUM_THREADS, "1"));
-		remoteWrapper = new RemoteWrapper(this, numThreads, broker.getSerializer());
+		this.remoteWrapper = new RemoteWrapper(this, numThreads, broker.getSerializer());
 
 		startQueues();
@@ -227,16 +227,13 @@
 
 		// Declares and bindings
-		logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
+		logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue + ", Durable: " + durable);
 		channel.exchangeDeclare(exchange, "direct");
 		channel.queueDeclare(queue, durable, false, false, null);
 		channel.queueBind(queue, exchange, routingKey);
 
+		logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + multiExchange + ", Queue: " + multiQueue + ", Durable: " + durable);
 		channel.exchangeDeclare(multiExchange, "fanout");
 		channel.queueDeclare(multiQueue, durable, false, false, null);
 		channel.queueBind(multiQueue, multiExchange, "");
-
-		// Declare the event topic fanout
-		logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + UID);
-		channel.exchangeDeclare(UID, "fanout");
 
 		// Declare a new consumer