[hornetq-commits] JBoss hornetq SVN: r11452 - in branches/HORNETQ-720_Replication: tests/integration-tests/src/test/java/org/hornetq/tests/integration/replication and 1 other directory.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-09-30 08:51:08 -0400 (Fri, 30 Sep 2011)
New Revision: 11452

Modified:
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java
   branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/replication/ReplicationTest.java
Log:
HORNETQ-720 Add Journal methods missing from previous commit.

Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java	2011-09-30 11:49:44 UTC (rev 11451)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java	2011-09-30 12:51:08 UTC (rev 11452)
@@ -634,6 +634,12 @@
       throw new UnsupportedOperationException();
    }
 
+   @Override
+   public int getFileSize()
+   {
+      return localJournal.getFileSize();
+   }
+
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------

Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/replication/ReplicationTest.java
===================================================================
--- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/replication/ReplicationTest.java	2011-09-30 11:49:44 UTC (rev 11451)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/replication/ReplicationTest.java	2011-09-30 12:51:08 UTC (rev 11452)
@@ -908,5 +908,11 @@
          return null;
       }
 
+      @Override
+      public int getFileSize()
+      {
+         return 0;
+      }
+
    }
 }