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

Class XmlDataImporter

java.lang.Object

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

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

All Implemented Interfaces:

Action

@Command(name="imp",
         description="Import all message-data using an XML that could be interpreted by any system.")
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	Description
String	host
String	input
boolean	legacyPrefixes
String	password
int	port
boolean	sort
boolean	transactional
String	user

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

context, DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
XmlDataImporter()

Method Summary

Modifier and Type	Method	Description
Object	execute(ActionContext context)
String	getPassword()
String	getUser()
void	process(InputStream inputStream, String host, int port, boolean transactional)
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(String inputFileName, String host, int port, boolean transactional)
void	setPassword(String password)
void	setUser(String user)
void	validate(InputStream inputStream)
void	validate(String fileName)

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

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

sort

public boolean sort

legacyPrefixes

public boolean legacyPrefixes

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 inputFileName,
                    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

validate

public void validate(String fileName)
              throws Exception

Throws:

Exception

validate

public void validate(InputStream inputStream)
              throws Exception

Throws:

Exception