Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 66)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 67)
@@ -93,4 +93,5 @@
 		this.broker = broker;
 		UID = reference;
+		serializer = broker.getSerializer();
 		if (channel == null || !channel.isOpen()) {
 			channel = broker.getChannel();
@@ -142,8 +143,11 @@
 	@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);
 	}