[hornetq-commits] JBoss hornetq SVN: r11121 - branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu Aug 4 11:28:56 EDT 2011
Author: borges
Date: 2011-08-04 11:28:56 -0400 (Thu, 04 Aug 2011)
New Revision: 11121
Modified:
branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java
Log:
HORNETQ-720 Only compare journals if up-to-date.
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java 2011-08-04 15:28:12 UTC (rev 11120)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java 2011-08-04 15:28:56 UTC (rev 11121)
@@ -325,6 +325,11 @@
public void compareJournalInformation(final JournalLoadInformation[] journalInformation) throws HornetQException
{
+ if (!server.isRemoteBackupUpToDate())
+ {
+ throw new HornetQException(HornetQException.ILLEGAL_STATE, "Cannot compare journals if not in sync!");
+ }
+
if (journalLoadInformation == null || journalLoadInformation.length != journalInformation.length)
{
throw new HornetQException(HornetQException.INTERNAL_ERROR,
More information about the hornetq-commits
mailing list