[hornetq-commits] JBoss hornetq SVN: r11422 - in branches/HORNETQ-720_Replication: hornetq-journal/src/main/java/org/hornetq/core/journal/impl and 1 other directories.

Author: borges Date: 2011-09-26 06:38:04 -0400 (Mon, 26 Sep 2011) New Revision: 11422 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/impl/AIOSequentialFile.java branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/NIOSequentialFile.java branches/HORNETQ-720_Replication/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java Log: Throw IOException instead of 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-09-26 10:37:00 UTC (rev 11421) +++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/SequentialFile.java 2011-09-26 10:38:04 UTC (rev 11422) @@ -13,6 +13,7 @@ package org.hornetq.core.journal; +import java.io.IOException; import java.nio.ByteBuffer; import org.hornetq.api.core.HornetQBuffer; @@ -87,7 +88,7 @@ void waitForClose() throws Exception; - void sync() throws Exception; + void sync() throws IOException; long size() throws Exception; Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/AIOSequentialFile.java =================================================================== --- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/AIOSequentialFile.java 2011-09-26 10:37:00 UTC (rev 11421) +++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/AIOSequentialFile.java 2011-09-26 10:38:04 UTC (rev 11422) @@ -14,6 +14,7 @@ package org.hornetq.core.journal.impl; import java.io.File; +import java.io.IOException; import java.nio.ByteBuffer; import java.util.concurrent.Executor; @@ -230,7 +231,7 @@ return bytesRead; } - public void sync() throws Exception + public void sync() { throw new UnsupportedOperationException("This method is not supported on AIO"); } Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/NIOSequentialFile.java =================================================================== --- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/NIOSequentialFile.java 2011-09-26 10:37:00 UTC (rev 11421) +++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/NIOSequentialFile.java 2011-09-26 10:38:04 UTC (rev 11422) @@ -29,9 +29,9 @@ import org.hornetq.core.logging.Logger; /** - * + * * A NIOSequentialFile - * + * * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a> * @author <a href="mailto:clebert.suconic@jboss.com">Clebert Suconic</a> * @@ -205,7 +205,7 @@ } - public void sync() throws Exception + public void sync() throws IOException { if (channel != null) { Modified: branches/HORNETQ-720_Replication/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java =================================================================== --- branches/HORNETQ-720_Replication/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java 2011-09-26 10:37:00 UTC (rev 11421) +++ branches/HORNETQ-720_Replication/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java 2011-09-26 10:38:04 UTC (rev 11422) @@ -13,6 +13,7 @@ package org.hornetq.tests.unit.core.journal.impl.fakes; +import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.List; @@ -474,7 +475,7 @@ } - public void sync() throws Exception + public void sync() throws IOException { if (supportsCallback) {