From 10302dd92e1820d794ad9a364739c815f3127637 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Sun, 11 Jun 2006 19:34:38 +0000 Subject: [PATCH] https://issues.apache.org/activemq/browse/AMQ-732 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/branches/activemq-4.0@413522 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activeio/journal/active/LogFileManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activeio/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java b/activeio/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java index d224324a88..ec52c16418 100644 --- a/activeio/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java +++ b/activeio/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java @@ -415,7 +415,7 @@ final public class LogFileManager { // Are we overflowing into next logFile? if (offset >= ri.getLogFileState().getAppendOffset()) { LogFileNode nextActive = ri.getLogFileState().getNextActive(); - if (nextActive == null) { + if (nextActive == null || nextActive.getId() <= ri.getLogFileState().getId() ) { return null; } logFileId = nextActive.getId();