Package org.openiam.config

Class ReconciliationVHostConfig

java.lang.Object

org.openiam.config.BaseVHostConfig

org.openiam.config.ReconciliationVHostConfig

@Configuration
public class ReconciliationVHostConfig
extends BaseVHostConfig

Field Summary

Fields

Modifier and Type	Field	Description
protected Integer	reconLimitConcurrentConsumers
protected Integer	reconLimitConcurrentConsumersMax
protected Integer	reconLimitPrefetchCount

Fields inherited from class org.openiam.config.BaseVHostConfig

concurrentConsumers, encoding, logger, syncReducingFactor

Constructor Summary

Constructors

Constructor	Description
ReconciliationVHostConfig()

Method Summary

Modifier and Type	Method	Description
ReconPartProcessingQueue	asynchronPartProcessingQueue()
AsynchronReconciliationQueue	asynchronReconciliationQueue()
org.springframework.amqp.core.AmqpAdmin	reconciliationAmqpAdmin()
org.springframework.amqp.rabbit.connection.ConnectionFactory	reconciliationCF()
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory	reconciliationRabbitListenerContainerFactory()
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory	reconPartRabbitListenerContainerFactory()

Methods inherited from class org.openiam.config.BaseVHostConfig

commonBindQueue, createConnectionFactory, createRabbitListenerContainerFactory, createRabbitListenerContainerFactory

Methods inherited from class java.lang.Object

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

Field Detail

reconLimitConcurrentConsumers

@Value("${org.openiam.rabbitmq.sync.thread.concurrent.consumers}")
protected Integer reconLimitConcurrentConsumers

reconLimitConcurrentConsumersMax

@Value("${org.openiam.rabbitmq.recon.thread.concurrent.consumers_max}")
protected Integer reconLimitConcurrentConsumersMax

reconLimitPrefetchCount

@Value("${org.openiam.rabbitmq.recon.thread.prefetch.count}")
protected Integer reconLimitPrefetchCount

Constructor Detail

ReconciliationVHostConfig

public ReconciliationVHostConfig()

Method Detail

reconciliationCF

@Bean
public org.springframework.amqp.rabbit.connection.ConnectionFactory reconciliationCF()

reconciliationRabbitListenerContainerFactory

@Bean(name="reconciliationRabbitListenerContainerFactory")
public org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory reconciliationRabbitListenerContainerFactory()

reconPartRabbitListenerContainerFactory

@Bean(name="reconPartRabbitListenerContainerFactory")
public org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory reconPartRabbitListenerContainerFactory()

reconciliationAmqpAdmin

@Bean
public org.springframework.amqp.core.AmqpAdmin reconciliationAmqpAdmin()

asynchronReconciliationQueue

@Bean(name="AsynchronReconciliationQueue")
public AsynchronReconciliationQueue asynchronReconciliationQueue()

asynchronPartProcessingQueue

@Bean(name="ReconPartProcessingQueue")
public ReconPartProcessingQueue asynchronPartProcessingQueue()