Index: trunk/src/main/java/omq/common/broker/Broker.java
===================================================================
--- trunk/src/main/java/omq/common/broker/Broker.java	(revision 53)
+++ trunk/src/main/java/omq/common/broker/Broker.java	(revision 54)
@@ -176,7 +176,9 @@
 		if (responseListener == null) {
 			responseListener = new ResponseListener(this);
+			responseListener.start();
 		}
 		if (eventDispatcher == null) {
 			eventDispatcher = new EventDispatcher(this);
+			eventDispatcher.start();
 		}
 	}
@@ -197,6 +199,4 @@
 		byte[] bytesResponse = serializer.serialize(wrapper);
 		channel.basicPublish(UID, "", null, bytesResponse);
-
-		// Log.saveLog("Server-Serialize", bytesResponse);
 	}
 
Index: trunk/src/main/java/omq/common/event/EventDispatcher.java
===================================================================
--- trunk/src/main/java/omq/common/event/EventDispatcher.java	(revision 53)
+++ trunk/src/main/java/omq/common/event/EventDispatcher.java	(revision 54)
@@ -56,4 +56,5 @@
 		boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
 		channel.queueDeclare(event_queue, durable, false, false, null);
+		logger.info("EventDispatcher creating queue: " + event_queue + ", durable: " + durable);
 
 		// Declare a new consumer
@@ -72,4 +73,5 @@
 	@Override
 	public void run() {
+		logger.info("EventDispatcher started");
 		Delivery delivery;
 		Event event;
@@ -84,9 +86,4 @@
 
 				logger.info("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
-				// Log.saveLog("Client-Deserialize", delivery.getBody());
-
-				// long timeEnd = (new Date()).getTime();
-				// Log.saveTimeSendRequestLog("Client-time-response",
-				// event.getCorrId(), "Event!", timeEnd);
 
 				// Dispatch it
Index: trunk/src/main/java/omq/common/message/Request.java
===================================================================
--- trunk/src/main/java/omq/common/message/Request.java	(revision 53)
+++ trunk/src/main/java/omq/common/message/Request.java	(revision 54)
@@ -15,4 +15,5 @@
 	private boolean async = false;
 
+	private transient boolean multi;
 	private transient long timeout;
 	private transient int retries;
@@ -34,4 +35,8 @@
 	}
 
+	public Request(String id2, String method2, boolean b, Object[] params2, boolean multi2) {
+		// TODO Auto-generated constructor stub
+	}
+
 	public static Request newSyncRequest(String id, String method, Object[] params) {
 		return new Request(id, method, false, params);
@@ -45,6 +50,6 @@
 	}
 
-	public static Request newAsyncRequest(String id, String method, Object[] params) {
-		return new Request(id, method, true, params);
+	public static Request newAsyncRequest(String id, String method, Object[] params, boolean multi) {
+		return new Request(id, method, true, params, multi);
 	}
 
@@ -97,3 +102,10 @@
 	}
 
+	public boolean isMulti() {
+		return multi;
+	}
+
+	public void setMulti(boolean multi) {
+		this.multi = multi;
+	}
 }