org.hornetq.core.persistence.impl.journal

Class XmlDataImporter

java.lang.Object

org.hornetq.core.persistence.impl.journal.XmlDataImporter

public class XmlDataImporter
extends Object

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

Author:

Justin Bertram

Constructor Summary

Constructors

Constructor and Description
XmlDataImporter(InputStream inputStream, ClientSession session) This is the normal constructor for programmatic access to the org.hornetq.core.persistence.impl.journal.XmlDataImporter if the session passed in uses auto-commit for sends.
XmlDataImporter(InputStream inputStream, ClientSession session, ClientSession managementSession) This is the constructor to use if you wish to import all messages transactionally.
XmlDataImporter(InputStream inputStream, String host, String port, boolean transactional)
XmlDataImporter(String inputFile, String host, String port, boolean transactional)

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(String[] arg)
void	processXml()

Methods inherited from class java.lang.Object

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

Constructor Detail

XmlDataImporter

public XmlDataImporter(InputStream inputStream,
               ClientSession session)

This is the normal constructor for programmatic access to the org.hornetq.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

XmlDataImporter

public XmlDataImporter(InputStream inputStream,
               ClientSession session,
               ClientSession managementSession)

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

XmlDataImporter

public XmlDataImporter(InputStream inputStream,
               String host,
               String port,
               boolean transactional)

XmlDataImporter

public XmlDataImporter(String inputFile,
               String host,
               String port,
               boolean transactional)
                throws FileNotFoundException

Throws:

FileNotFoundException

Method Detail

main

public static void main(String[] arg)

processXml

public void processXml()
                throws Exception

Throws:

Exception