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

Class XmlDataImporter

java.lang.Object

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

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

All Implemented Interfaces:

Action

public final class XmlDataImporter
extends ActionAbstract

Read XML output from org.apache.activemq.artemis.core.persistence.impl.journal.XmlDataExporter, create a core session, and send the messages to a running instance of ActiveMQ Artemis. It uses the StAX javax.xml.stream.XMLStreamReader for speed and simplicity.

Field Summary

Fields

Modifier and Type	Field and Description
String	host
String	input
String	password
int	port
boolean	transactional
String	user

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

context, verbose

Constructor Summary

Constructors

Constructor and Description
XmlDataImporter()

Method Summary

Modifier and Type	Method and Description
Object	execute(ActionContext context)
String	getPassword()
String	getUser()
void	process(InputStream inputStream, ClientSession session) This is the normal constructor for programmatic access to the org.apache.activemq.artemis.core.persistence.impl.journal.XmlDataImporter if the session passed in uses auto-commit for sends.
void	process(InputStream inputStream, ClientSession session, ClientSession managementSession) This is the constructor to use if you wish to import all messages transactionally.
void	process(InputStream inputStream, String host, int port, boolean transactional)
void	process(String inputFile, String host, int port, boolean transactional)
void	setPassword(String password)
void	setUser(String user)

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

getBrokerHome, getBrokerInstance, getBrokerURIInstance, isVerbose, setHomeValues

Methods inherited from class java.lang.Object

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

Field Detail

host

public String host

port

public int port

transactional

public boolean transactional

user

public String user

password

public String password

input

public String input

Constructor Detail

XmlDataImporter

public XmlDataImporter()

Method Detail

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

getUser

public String getUser()

setUser

public void setUser(String user)

execute

public Object execute(ActionContext context)
               throws Exception

Specified by:

execute in interface Action

Overrides:

execute in class ActionAbstract

Throws:

Exception

process

public void process(String inputFile,
                    String host,
                    int port,
                    boolean transactional)
             throws Exception

Throws:

Exception

process

public void process(InputStream inputStream,
                    ClientSession session)
             throws Exception

This is the normal constructor for programmatic access to the org.apache.activemq.artemis.core.persistence.impl.journal.XmlDataImporter if the session passed in uses auto-commit for sends.
If the session needs to be transactional then use the constructor which takes 2 sessions.

Parameters:

inputStream - the stream from which to read the XML for import

session - used for sending messages, must use auto-commit for sends

Throws:

Exception

process

public void process(InputStream inputStream,
                    ClientSession session,
                    ClientSession managementSession)
             throws Exception

This is the constructor to use if you wish to import all messages transactionally.
Pass in a session which doesn't use auto-commit for sends, and one that does (for management operations necessary during import).

Parameters:

inputStream - the stream from which to read the XML for import

session - used for sending messages, doesn't need to auto-commit sends

managementSession - used for management queries, must use auto-commit for sends

Throws:

Exception

process

public void process(InputStream inputStream,
                    String host,
                    int port,
                    boolean transactional)
             throws Exception

Throws:

Exception