[hornetq-commits] JBoss hornetq SVN: r11056 - in branches/HORNETQ-720_Replication: hornetq-journal/src/main/java/org/hornetq/core/journal and 3 other directories.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Jul 27 13:28:44 EDT 2011
Author: borges
Date: 2011-07-27 13:28:44 -0400 (Wed, 27 Jul 2011)
New Revision: 11056
Modified:
branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java
branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/Journal.java
branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/SequentialFile.java
branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java
branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java
branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java
branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/replication/ReplicationTest.java
Log:
Remove unnecessary "throws Exception" declaration.
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-07-27 17:27:23 UTC (rev 11055)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java 2011-07-27 17:28:44 UTC (rev 11056)
@@ -493,7 +493,7 @@
* @throws Exception
* @see org.hornetq.core.journal.Journal#perfBlast(int)
*/
- public void perfBlast(final int pages) throws Exception
+ public void perfBlast(final int pages)
{
localJournal.perfBlast(pages);
}
Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/Journal.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/Journal.java 2011-07-27 17:27:23 UTC (rev 11055)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/Journal.java 2011-07-27 17:28:44 UTC (rev 11056)
@@ -125,10 +125,10 @@
int getAlignment() throws Exception;
int getNumberOfRecords();
-
+
int getUserVersion();
- void perfBlast(int pages) throws Exception;
+ void perfBlast(int pages);
void runDirectJournalBlast() throws Exception;
Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/SequentialFile.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/SequentialFile.java 2011-07-27 17:27:23 UTC (rev 11055)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/SequentialFile.java 2011-07-27 17:28:44 UTC (rev 11056)
@@ -19,12 +19,12 @@
import org.hornetq.core.journal.impl.TimedBuffer;
/**
- *
+ *
* A SequentialFile
- *
+ *
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
* @author <a href="mailto:clebert.suconic at jboss.com">Clebert Suconic</a>
- *
+ *
*/
public interface SequentialFile
{
@@ -69,7 +69,7 @@
/** Write directly to the file without using any buffer */
void writeDirect(ByteBuffer bytes, boolean sync) throws Exception;
-
+
/** Write directly to the file.
* This is used by compacting and other places where we write a big buffer in a single shot.
* writeInternal should always block until the entire write is sync on disk */
@@ -94,7 +94,7 @@
void renameTo(String newFileName) throws Exception;
SequentialFile copy();
-
+
void copyTo(SequentialFile newFileName) throws Exception;
void setTimedBuffer(TimedBuffer buffer);
Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java 2011-07-27 17:27:23 UTC (rev 11055)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java 2011-07-27 17:28:44 UTC (rev 11056)
@@ -2395,7 +2395,7 @@
/** Method for use on testcases.
* It will call waitComplete on every transaction, so any assertions on the file system will be correct after this */
- public void debugWait() throws Exception
+ public void debugWait() throws InterruptedException
{
fileFactory.flush();
@@ -2501,7 +2501,7 @@
}
}
- public void perfBlast(final int pages) throws Exception
+ public void perfBlast(final int pages)
{
new PerfBlast(pages).start();
}
Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java 2011-07-27 17:27:23 UTC (rev 11055)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java 2011-07-27 17:28:44 UTC (rev 11056)
@@ -149,7 +149,7 @@
}
/**
- *
+ *
*/
public void clear()
{
@@ -246,7 +246,7 @@
neg.add(new JournalUpdate(file, id, 0));
}
- /**
+ /**
* The caller of this method needs to guarantee appendLock.lock at the journal. (unless this is being called from load what is a single thread process).
* */
public void commit(final JournalFile file)
@@ -316,7 +316,7 @@
}
}
- public void waitCallbacks() throws Exception
+ public void waitCallbacks() throws InterruptedException
{
if (callbackList != null)
{
@@ -336,7 +336,7 @@
}
}
- /**
+ /**
* The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
* or else potFilesMap could be affected
* */
@@ -367,7 +367,7 @@
}
}
- /**
+ /**
* The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
* or else potFilesMap could be affected
* */
Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java
===================================================================
--- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java 2011-07-27 17:27:23 UTC (rev 11055)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/BackupJournalSyncTest.java 2011-07-27 17:28:44 UTC (rev 11056)
@@ -51,7 +51,6 @@
assertFalse("backup is not started!", backupServer.isStarted());
// BLOCK ON journals
- // SYNC, (UNSET reclaim, lock, use next file, get file list, sync) iterate
backupServer.start();
waitForBackup(sessionFactory, 5);
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-07-27 17:27:23 UTC (rev 11055)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/replication/ReplicationTest.java 2011-07-27 17:28:44 UTC (rev 11056)
@@ -726,7 +726,7 @@
return new JournalLoadInformation();
}
- public void perfBlast(final int pages) throws Exception
+ public void perfBlast(final int pages)
{
}
More information about the hornetq-commits
mailing list