in activemq-kahadb-exporter/src/main/java/org/apache/activemq/cli/kahadb/exporter/Exporter.java [126:144]
public void run() {
LOG.info("Starting MultiKahaDB store export");
try {
Exporter.exportStore(ExportConfigurationBuilder.newBuilder()
.setMultiKaha(true)
.setSource(new File(source))
.setTarget(new File(target))
.setQueuePattern(queuePattern)
.setTopicPattern(topicPattern)
.setVirtualTopicConsumerWildcards(virtualTopicConsumerWildcards)
.setCompress(compress)
.setOverwrite(overwrite)
.build());
} catch (Exception e) {
LOG.error(e.getMessage(), e);
throw new IllegalStateException(e.getMessage(), e);
}
}