private static void appendKahaDbStore()

in activemq-kahadb-exporter/src/main/java/org/apache/activemq/cli/kahadb/exporter/Exporter.java [208:228]

• 18 lines of code
• 1 McCabe index (conditional complexity)

    private static void appendKahaDbStore(final ArtemisJournalMarshaller xmlMarshaller,
            final KahaDBPersistenceAdapter adapter, final ExportConfiguration config) throws Exception {

        try {
            adapter.start();

            final KahaDBExporter dbExporter = new KahaDBExporter(adapter,
                    new ArtemisXmlMetadataExporter(adapter.getStore(), xmlMarshaller, config),
                    new ArtemisXmlMessageRecoveryListener(adapter.getStore(), xmlMarshaller));

            xmlMarshaller.appendBindingsElement();
            dbExporter.exportMetadata();
            xmlMarshaller.appendEndElement();
            xmlMarshaller.appendMessagesElement();
            dbExporter.exportQueues(config.getQueuePattern());
            dbExporter.exportTopics(config.getTopicPattern());
            xmlMarshaller.appendEndElement();
        } finally {
            adapter.stop();
        }
    }