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

Class DBOption

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

All Implemented Interfaces:

Runnable, Action

Direct Known Subclasses:

PrintData, RecoverMessages, XmlDataExporter

public class DBOption
extends OptionalLocking

Field Summary

Fields

Modifier and Type	Field	Description
protected Configuration	config
protected ExecutorService	executor
protected ExecutorFactory	executorFactory
protected org.apache.activemq.artemis.core.paging.PagingManager	pagingmanager
protected ScheduledExecutorService	scheduledExecutorService
protected org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager	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.ActionAbstract

DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
DBOption()

Method Summary

Modifier and Type	Method	Description
protected void	cleanup()
void	done()
Object	execute(ActionContext context)
String	getJdbcBindings()
String	getJdbcClassName()
String	getJdbcLargeMessages()
String	getJdbcMessages()
String	getJdbcNodeManager()
String	getJdbcPageStore()
String	getJdbcPassword()
String	getJdbcURL()
String	getJdbcUser()
File	getOutput()
Configuration	getParameterConfiguration()
protected void	initializeJournal(Configuration configuration)
boolean	isJDBC()
DBOption	setJdbcBindings(String jdbcBindings)
DBOption	setJdbcClassName(String jdbcClassName)
DBOption	setJdbcLargeMessages(String jdbcLargeMessages)
DBOption	setJdbcMessages(String jdbcMessages)
DBOption	setJdbcNodeManager(String jdbcNodeManager)
DBOption	setJdbcPageStore(String jdbcPageStore)
DBOption	setJdbcPassword(String jdbcPassword)
DBOption	setJdbcURL(String jdbcURL)
DBOption	setJdbcUser(String jdbcUser)
DBOption	setOutput(File output)

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

isIgnoreLock, lockCLI, setIgnoreLock

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, readConfiguration, treatError

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

getActionContext, getBrokerConfiguration, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, getBrokerURLInstance, isVerbose, run, setHomeValues

Methods inherited from class java.lang.Object

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

Field Detail

storageManager

protected org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager storageManager

config

protected Configuration config

executor

protected ExecutorService executor

executorFactory

protected ExecutorFactory executorFactory

scheduledExecutorService

protected ScheduledExecutorService scheduledExecutorService

pagingmanager

protected org.apache.activemq.artemis.core.paging.PagingManager pagingmanager

Constructor Detail

DBOption

public DBOption()

Method Detail

isJDBC

public boolean isJDBC()
               throws Exception

Throws:

Exception

getOutput

public File getOutput()

setOutput

public DBOption setOutput(File output)

getJdbcBindings

public String getJdbcBindings()
                       throws Exception

Throws:

Exception

setJdbcBindings

public DBOption setJdbcBindings(String jdbcBindings)

getJdbcMessages

public String getJdbcMessages()
                       throws Exception

Throws:

Exception

setJdbcMessages

public DBOption setJdbcMessages(String jdbcMessages)

getJdbcLargeMessages

public String getJdbcLargeMessages()
                            throws Exception

Throws:

Exception

setJdbcLargeMessages

public DBOption setJdbcLargeMessages(String jdbcLargeMessages)

getJdbcPageStore

public String getJdbcPageStore()
                        throws Exception

Throws:

Exception

setJdbcPageStore

public DBOption setJdbcPageStore(String jdbcPageStore)

getJdbcNodeManager

public String getJdbcNodeManager()
                          throws Exception

Throws:

Exception

setJdbcNodeManager

public DBOption setJdbcNodeManager(String jdbcNodeManager)

getJdbcURL

public String getJdbcURL()
                  throws Exception

Throws:

Exception

setJdbcURL

public DBOption setJdbcURL(String jdbcURL)

getJdbcClassName

public String getJdbcClassName()
                        throws Exception

Throws:

Exception

setJdbcClassName

public DBOption setJdbcClassName(String jdbcClassName)

getJdbcUser

public String getJdbcUser()

setJdbcUser

public DBOption setJdbcUser(String jdbcUser)

getJdbcPassword

public String getJdbcPassword()

setJdbcPassword

public DBOption setJdbcPassword(String jdbcPassword)

execute

public Object execute(ActionContext context)
               throws Exception

Specified by:

execute in interface Action

Overrides:

execute in class LockAbstract

Throws:

Exception

done

public void done()

Specified by:

done in interface Action

Overrides:

done in class LockAbstract

getParameterConfiguration

public Configuration getParameterConfiguration()
                                        throws Exception

Throws:

Exception

initializeJournal

protected void initializeJournal(Configuration configuration)
                          throws Exception

Throws:

Exception

cleanup

protected void cleanup()
                throws Exception

Throws:

Exception