ome.smuggler.config.wiring.imports

Class ImportGcQBeans

java.lang.Object

ome.smuggler.config.wiring.imports.ImportGcQBeans

@Configuration
public class ImportGcQBeans
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
ImportGcQBeans()

Method Summary

Modifier and Type	Method and Description
DequeueTask<ProcessedImport>	dequeueImportFinaliserTask(QChannelFactory<ProcessedImport> factory, ImportConfigSource importConfig, ImportFinaliser finaliser, FailedFinalisationHandler failureHandler)
QChannelFactory<ProcessedImport>	importGcChannelFactory(ServerConnector connector, ImportGcQConfig qConfig)
SchedulingSource<ProcessedImport>	importGcSourceChannel(QChannelFactory<ProcessedImport> factory)

Methods inherited from class java.lang.Object

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

Constructor Detail

ImportGcQBeans

public ImportGcQBeans()

Method Detail

importGcChannelFactory

@Bean
public QChannelFactory<ProcessedImport> importGcChannelFactory(ServerConnector connector,
                                                                     ImportGcQConfig qConfig)

importGcSourceChannel

@Bean
public SchedulingSource<ProcessedImport> importGcSourceChannel(QChannelFactory<ProcessedImport> factory)
                                                              throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

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

dequeueImportFinaliserTask

@Bean
public DequeueTask<ProcessedImport> dequeueImportFinaliserTask(QChannelFactory<ProcessedImport> factory,
                                                                     ImportConfigSource importConfig,
                                                                     ImportFinaliser finaliser,
                                                                     FailedFinalisationHandler failureHandler)
                                                              throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

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