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@jboss.com">Tim Fox</a> * @author <a href="mailto:clebert.suconic@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) { }