ome.smuggler.config.wiring.imports

Class ImportQBeans

java.lang.Object

ome.smuggler.config.wiring.imports.ImportQBeans

@Configuration
public class ImportQBeans
extends java.lang.Object

Singleton beans for HornetQ client resources that have to be shared and reused.

Constructor Summary

Constructors

Constructor and Description
ImportQBeans()

Method Summary

Modifier and Type	Method and Description
DequeueTask<QueuedImport>	dequeueImportTask(QChannelFactory<QueuedImport> factory, ImportConfigSource importConfig, ImportProcessor processor, FailedImportHandler failureHandler)
QChannelFactory<QueuedImport>	importChannelFactory(ServerConnector connector, ImportQConfig qConfig)
ChannelSource<QueuedImport>	importSourceChannel(QChannelFactory<QueuedImport> factory)

Methods inherited from class java.lang.Object

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

Constructor Detail

ImportQBeans

public ImportQBeans()

Method Detail

importChannelFactory

@Bean
public QChannelFactory<QueuedImport> importChannelFactory(ServerConnector connector,
                                                                ImportQConfig qConfig)

importSourceChannel

@Bean
public ChannelSource<QueuedImport> importSourceChannel(QChannelFactory<QueuedImport> factory)
                                                      throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

dequeueImportTask

@Bean
public DequeueTask<QueuedImport> dequeueImportTask(QChannelFactory<QueuedImport> factory,
                                                         ImportConfigSource importConfig,
                                                         ImportProcessor processor,
                                                         FailedImportHandler failureHandler)
                                                  throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException