Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA test output cleanup

This commit is contained in:
Clebert Suconic 2020-04-28 18:10:22 -04:00
parent ea437db530
commit 54c4611229
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
View File

@ -46,6 +46,7 @@ import javax.transaction.xa.Xid;
import io.netty.buffer.Unpooled; import io.netty.buffer.Unpooled;
import org.apache.activemq.artemis.api.core.ActiveMQBuffer; import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
import org.apache.activemq.artemis.api.core.ActiveMQBuffers; import org.apache.activemq.artemis.api.core.ActiveMQBuffers;
import org.apache.activemq.artemis.api.core.ActiveMQShutdownException;
import org.apache.activemq.artemis.api.core.Message; import org.apache.activemq.artemis.api.core.Message;
import org.apache.activemq.artemis.api.core.Pair; import org.apache.activemq.artemis.api.core.Pair;
import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.SimpleString;
@ -1720,7 +1721,11 @@ public abstract class AbstractJournalStorageManager extends CriticalComponentImp
try { try {
confirmPendingLargeMessage(largeServerMessage.getPendingRecordID()); confirmPendingLargeMessage(largeServerMessage.getPendingRecordID());
largeServerMessage.clearPendingRecordID(); largeServerMessage.clearPendingRecordID();
} catch (Exception e) { } catch (ActiveMQShutdownException e) {
// this may happen, this is asynchronous as all that would happen is we missed the update
// since the update was missed, next restart this operation will be retried
ActiveMQServerLogger.LOGGER.debug(e.getMessage(), e);
} catch (Throwable e) {
ActiveMQServerLogger.LOGGER.warn(e.getMessage(), e); ActiveMQServerLogger.LOGGER.warn(e.getMessage(), e);
} }
} }

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicOpenWireTest.java
View File

@ -116,11 +116,9 @@ public class BasicOpenWireTest extends OpenWireTestBase {
} }
testQueues.clear(); testQueues.clear();
} catch (Throwable e) { } catch (Throwable e) {
System.out.println("Exception !! " + e);
e.printStackTrace(); e.printStackTrace();
} finally { } finally {
super.tearDown(); super.tearDown();
System.out.println("Super done.");
} }
} }