[hornetq-commits] JBoss hornetq SVN: r11597 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic
Date: 2011-10-25 22:53:10 -0400 (Tue, 25 Oct 2011)
New Revision: 11597

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java
Log:
Adding debug to print-data

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2011-10-25 21:50:31 UTC (rev 11596)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2011-10-26 02:53:10 UTC (rev 11597)
@@ -1985,7 +1985,7 @@
       }
    }
 
-   private OperationContext getContext(final boolean sync)
+   protected OperationContext getContext(final boolean sync)
    {
       if (sync)
       {

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java	2011-10-25 21:50:31 UTC (rev 11596)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java	2011-10-26 02:53:10 UTC (rev 11597)
@@ -13,6 +13,9 @@
 
 package org.hornetq.core.persistence.impl.journal;
 
+import java.io.File;
+
+import org.hornetq.core.server.impl.FileLockNodeManager;
 /**
  * A PrintData
  *
@@ -42,6 +45,25 @@
          System.exit(-1);
       }
       
+      File serverLockFile = new File(arg[1], "server.lock");
+      
+      if (serverLockFile.isFile())
+      {
+         try
+         {
+            FileLockNodeManager fileLock = new FileLockNodeManager(arg[1]);
+            fileLock.start();
+            System.out.println("********************************************");
+            System.out.println("Server's ID=" + fileLock.getNodeId().toString());
+            System.out.println("********************************************");
+            fileLock.stop();
+         }
+         catch (Exception e)
+         {
+            e.printStackTrace();
+         }
+      }
+      
       System.out.println("********************************************");
       System.out.println("B I N D I N G S  J O U R N A L");
       System.out.println("********************************************");