Package org.openiam.config

Class SynchronizationVHostConfig

java.lang.Object

org.openiam.config.BaseVHostConfig

org.openiam.config.SynchronizationVHostConfig

@Configuration
public class SynchronizationVHostConfig
extends BaseVHostConfig

Created by alexander on 18/11/16.

Field Summary

Fields

Modifier and Type	Field	Description
protected Integer	syncLimitConcurrentConsumers
protected Integer	syncLimitConcurrentConsumersMax
protected Integer	syncLimitPrefetchCount

Fields inherited from class org.openiam.config.BaseVHostConfig

concurrentConsumers, encoding, logger, syncReducingFactor

Constructor Summary

Constructors

Constructor	Description
SynchronizationVHostConfig()

Method Summary

Modifier and Type	Method	Description
AsynchronPartProcessingQueue	asynchronPartProcessingQueue()
AsynchronSynchronizationQueue	asynchronSynchronizationQueue()
org.springframework.amqp.core.AmqpAdmin	synchronizationAmqpAdmin()
org.springframework.amqp.rabbit.connection.ConnectionFactory	synchronizationCF()
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory	synchronizationPartRabbitListenerContainerFactory()
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory	synchronizationRabbitListenerContainerFactory()

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

syncLimitConcurrentConsumers

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

syncLimitConcurrentConsumersMax

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

syncLimitPrefetchCount

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

Constructor Detail

SynchronizationVHostConfig

public SynchronizationVHostConfig()

Method Detail

synchronizationCF

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

synchronizationRabbitListenerContainerFactory

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

synchronizationPartRabbitListenerContainerFactory

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

synchronizationAmqpAdmin

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

asynchronSynchronizationQueue

@Bean(name="AsynchronSynchronizationQueue")
public AsynchronSynchronizationQueue asynchronSynchronizationQueue()

asynchronPartProcessingQueue

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