Package org.apache.activemq.artemis.cli.commands.tools

Class RecoverMessages

java.lang.Object

org.apache.activemq.artemis.cli.commands.ActionAbstract

org.apache.activemq.artemis.cli.commands.Configurable

org.apache.activemq.artemis.cli.commands.tools.DataAbstract

org.apache.activemq.artemis.cli.commands.tools.LockAbstract

org.apache.activemq.artemis.cli.commands.tools.OptionalLocking

org.apache.activemq.artemis.cli.commands.tools.DBOption

org.apache.activemq.artemis.cli.commands.tools.RecoverMessages

All Implemented Interfaces:

Action

@Command(name="recover",
         description="Recover (undelete) every message on the journal by creating a new output journal. Rolled backed and acked messages will be sent out to the output as much as possible.")
public class RecoverMessages
extends DBOption

Field Summary

Fields inherited from class org.apache.activemq.artemis.cli.commands.tools.DBOption

config, executor, executorFactory, pagingmanager, scheduledExecutorService, storageManager

Fields inherited from class org.apache.activemq.artemis.cli.commands.tools.DataAbstract

binding, journal, largeMessges, paging

Fields inherited from class org.apache.activemq.artemis.cli.commands.Configurable

global

Fields inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract

context, DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
RecoverMessages()

Method Summary

Modifier and Type	Method	Description
Object	execute(ActionContext context)
static void	recover(Configuration configuration, String journallocation, File journalOutput, File largeMessage, boolean reclaimed)

Methods inherited from class org.apache.activemq.artemis.cli.commands.tools.DBOption

cleanup, getJdbcBindings, getJdbcClassName, getJdbcLargeMessages, getJdbcMessages, getJdbcNodeManager, getJdbcPageStore, getJdbcURL, getParameterConfiguration, initializeJournal, isJDBC, setJdbcBindings, setJdbcClassName, setJdbcLargeMessages, setJdbcMessages, setJdbcNodeManager, setJdbcPageStore, setJdbcURL

Methods inherited from class org.apache.activemq.artemis.cli.commands.tools.OptionalLocking

lockCLI

Methods inherited from class org.apache.activemq.artemis.cli.commands.tools.LockAbstract

unlock

Methods inherited from class org.apache.activemq.artemis.cli.commands.tools.DataAbstract

getBinding, getJournal, getLargeMessages, getPaging

Methods inherited from class org.apache.activemq.artemis.cli.commands.Configurable

getBrokerDTO, getConfiguration, getFileConfiguration, getManagementConfiguration, getManagementDTO, helpGroup, readConfiguration, treatError

Methods inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract

checkOptions, getBrokerConfiguration, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, getBrokerURLInstance, isVerbose, setHomeValues

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecoverMessages

public RecoverMessages()

Method Detail

execute

public Object execute(ActionContext context)
               throws Exception

Specified by:

execute in interface Action

Overrides:

execute in class DBOption

Throws:

Exception

recover

public static void recover(Configuration configuration,
                           String journallocation,
                           File journalOutput,
                           File largeMessage,
                           boolean reclaimed)
                    throws Exception

Throws:

Exception