Index: branches/supervisor/src/main/java/omq/client/proxy/Proxymq.java
===================================================================
--- branches/supervisor/src/main/java/omq/client/proxy/Proxymq.java	(revision 110)
+++ branches/supervisor/src/main/java/omq/client/proxy/Proxymq.java	(revision 111)
@@ -268,5 +268,5 @@
 
 		// Wait for the results.
-		long localTimeout = timeout;
+		long localTimeout = 0;
 		long start = System.currentTimeMillis();
 		synchronized (results) {
@@ -320,5 +320,5 @@
 
 		int i = 0;
-		long localTimeout = timeout;
+		long localTimeout = 0;
 		long start = System.currentTimeMillis();
 
@@ -380,5 +380,5 @@
 
 	@Override
-	public void setUID(String uID) {System.out.println("SET UID");
+	public void setUID(String uID) {
 		this.UID = uID;
 	}
Index: branches/supervisor/src/main/java/omq/common/broker/Broker.java
===================================================================
--- branches/supervisor/src/main/java/omq/common/broker/Broker.java	(revision 110)
+++ branches/supervisor/src/main/java/omq/common/broker/Broker.java	(revision 111)
@@ -3,5 +3,4 @@
 import java.io.IOException;
 import java.lang.reflect.Proxy;
-import java.net.URL;
 import java.util.HashMap;
 import java.util.Hashtable;
@@ -23,10 +22,9 @@
 
 import org.apache.log4j.Logger;
-import org.apache.log4j.xml.DOMConfigurator;
-
+
+import com.rabbitmq.client.AMQP.BasicProperties;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.QueueingConsumer;
-import com.rabbitmq.client.AMQP.BasicProperties;
 import com.rabbitmq.client.QueueingConsumer.Delivery;
 import com.rabbitmq.client.ShutdownListener;
@@ -60,6 +58,6 @@
 	public Broker(Properties env) throws Exception {
 		// Load log4j configuration
-		URL log4jResource = Broker.class.getResource("/log4j.xml");
-		DOMConfigurator.configure(log4jResource);
+		// URL log4jResource = Broker.class.getResource("/log4j.xml");
+		// DOMConfigurator.configure(log4jResource);
 
 		remoteObjs = new HashMap<String, RemoteObject>();
@@ -69,11 +67,18 @@
 		channel = connection.createChannel();
 		addFaultTolerance();
-		try {
-			tryConnection(env);
-		} catch (Exception e) {
-			channel.close();
-			connection.close();
+		if (!connection.isOpen() || !channel.isOpen()) {
+			if (connection.isOpen()) {
+				connection.close();
+			}
 			throw new InitBrokerException("The connection didn't work");
 		}
+
+		// try {
+		// tryConnection(env);
+		// } catch (Exception e) {
+		// channel.close();
+		// connection.close();
+		// throw new InitBrokerException("The connection didn't work");
+		// }
 	}
 
@@ -99,5 +104,5 @@
 
 		clientStarted = false;
-		connectionClosed = false;
+		// connectionClosed = false;
 		environment = null;
 		remoteObjs = null;
@@ -121,5 +126,5 @@
 		connectionClosed = true;
 		connection.close();
-		connectionClosed = false;
+		// connectionClosed = false;
 	}
 
@@ -154,5 +159,6 @@
 	 * @throws IOException
 	 */
-	public synchronized void publishMessge(String exchange, String routingKey, BasicProperties props, byte[] bytesRequest) throws IOException {
+	public synchronized void publishMessge(String exchange, String routingKey, BasicProperties props, byte[] bytesRequest)
+			throws IOException {
 		if (!channel.isOpen()) {
 			logger.error("Broker's channel is closed opening a new one", channel.getCloseReason());
Index: branches/supervisor/src/main/resources/log4j.xml
===================================================================
--- branches/supervisor/src/main/resources/log4j.xml	(revision 110)
+++ branches/supervisor/src/main/resources/log4j.xml	(revision 111)
@@ -4,5 +4,5 @@
 <log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">
     <appender name="consoleAppender" class="org.apache.log4j.ConsoleAppender">
-        <param name="Threshold" value="INFO" />
+        <param name="Threshold" value="OFF" />
         <layout class="org.apache.log4j.PatternLayout">
             <param name="ConversionPattern" value="%d{[yyyy-MM-dd HH:mm:ss]} %-5p %c:%L - %m%n" />
@@ -30,5 +30,5 @@
 
   <root> 
-    <priority value ="INFO" /> 
+    <priority value ="OFF" /> 
     <appender-ref ref="consoleAppender" />
     <appender-ref ref="A2" />