update

src/main/java/it/isislab/dmason/experimentals/systemmanagement/master/MasterServer.java

@@ -262,6 +262,7 @@ public void onMessage(Message msg) {
 
 										if(!infoWorkers.containsKey(ID))
 										{
+
 											processInfoForCopyLog(info,ID);
 											getConnection().createTopic(ID, 1);
 											try {

src/main/java/it/isislab/dmason/experimentals/systemmanagement/master/MasterServerMain.java

@@ -69,6 +69,7 @@ public static void main(String[] args){
 		server.setHandler(ctx);
 		//Launch activeMq server
 				ActiveMQStarter amqS = new ActiveMQStarter();
+
 			    amqS.startActivemq();
 		try {
 			server.start();

src/main/java/it/isislab/dmason/experimentals/systemmanagement/utils/ActiveMQStarter.java

@@ -26,6 +26,9 @@
 import org.apache.activemq.usage.TempUsage;
 import org.apache.activemq.usage.UsageCapacity;
 
+import it.isislab.dmason.util.connection.Address;
+import it.isislab.dmason.util.connection.jms.activemq.ConnectionNFieldsWithActiveMQAPI;
+
 /**
  * Start Activemq 
  * @author miccar
@@ -54,6 +57,9 @@ public ActiveMQStarter(){
 			IP_ACTIVEMQ=startProperties.getProperty("ipmaster");
 			PORT_ACTIVEMQ=startProperties.getProperty("portmaster");
 			System.out.println(IP_ACTIVEMQ +" "+PORT_ACTIVEMQ);
+
+
+
 		} catch (IOException e2) {
 			System.err.println(e2.getMessage());
 		}finally{
@@ -97,6 +103,12 @@ public void startActivemq(){
 			/*     end code for tempUsage setting    */
 			broker.addConnector(address);
 			broker.start();
+
+			ConnectionNFieldsWithActiveMQAPI conn=new ConnectionNFieldsWithActiveMQAPI();
+			conn.setupConnection(new Address(IP_ACTIVEMQ, PORT_ACTIVEMQ));
+			conn.createTopic("MANAGEMENT", 1);
+
+
 		} catch (Exception e1) {e1.printStackTrace();}
 	}
 

src/main/java/it/isislab/dmason/experimentals/systemmanagement/worker/Worker.java

@@ -251,17 +251,19 @@ class MasterChecker extends Thread{
 		Random r=new Random();
 		public MasterChecker() {
 			timeToCheck=0;
-
+			
 		}
 		@Override
 		public void run() {
 			do
 			{
+				System.out.println("Start Mater monitor...");
 				if(masterlost==null)
 				{
 
 					masterlost=new MasterLostChecker();
 					masterlost.start();
+					System.out.println("done.");
 
 					try {
 						lock.lock();
@@ -309,9 +311,9 @@ private void startMasterComunication() {
 		catch (Exception e1) {e1.printStackTrace();}
 
 
-		masterchecker=new MasterChecker();
-		masterchecker.start();
-
+		//masterchecker=new MasterChecker();
+	//	masterchecker.start();
+		new MasterLostChecker().start();
 		conn.asynchronousReceive(MANAGEMENT, new MyMessageListener() {
 			@Override
 			public void onMessage(Message msg) {