Package org.openiam.config
Class IdmVHostConfig
- java.lang.Object
-
- org.openiam.config.BaseVHostConfig
-
- org.openiam.config.IdmVHostConfig
-
@Configuration public class IdmVHostConfig extends BaseVHostConfig
Created by alexander on 18/11/16.
-
-
Field Summary
-
Fields inherited from class org.openiam.config.BaseVHostConfig
concurrentConsumers, encoding, logger, syncReducingFactor
-
-
Constructor Summary
Constructors Constructor Description IdmVHostConfig()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BindQueue
bindQueue()
GroupProvisionQueue
groupProvisionQueue()
IdentityQueue
identityQueue()
org.springframework.amqp.core.AmqpAdmin
idmAmqpAdmin()
org.springframework.amqp.rabbit.connection.ConnectionFactory
idmCF()
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
idmRabbitListenerContainerFactory()
This is common container factory for all queues, except ProvisioningBulkQueueManagedSysQueue
managedSysQueue()
ProvisionBulkQueue
provisionBulkQueue()
ProvisionConnectorQueue
provisionConnectorQueue()
ProvisionDispatcherQueue
provisionDispatcherQueue()
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
provisionDispatcherRabbitListenerContainerFactory()
This is common container factory for ProvisionDispatcherQueue with separately configured number of consumers.ProvisionInfoQueue
provisionInfoQueue()
ProvisionQueue
provisionQueue()
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
provisionRabbitListenerContainerFactory()
This is common container factory for ProvisioningBulkQueue with separatelly configured number of consumers.ReconciliationConfigQueue
reconciliationConfigQueue()
ReconciliationIDMConfigQueue
reconciliationIDMConfigQueue()
SynchronizationQueue
synchronizationQueue()
-
Methods inherited from class org.openiam.config.BaseVHostConfig
commonBindQueue, createConnectionFactory, createRabbitListenerContainerFactory, createRabbitListenerContainerFactory
-
-
-
-
Method Detail
-
idmCF
@Bean public org.springframework.amqp.rabbit.connection.ConnectionFactory idmCF()
-
idmRabbitListenerContainerFactory
@Bean(name="idmRabbitListenerContainerFactory") public org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory idmRabbitListenerContainerFactory()
This is common container factory for all queues, except ProvisioningBulkQueue- Returns:
SimpleRabbitListenerContainerFactory
-
provisionRabbitListenerContainerFactory
@Bean(name="provisionRabbitListenerContainerFactory") public org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory provisionRabbitListenerContainerFactory()
This is common container factory for ProvisioningBulkQueue with separatelly configured number of consumers. we need this because provision operation is sent async and with big number of concurrent consumers it kills the system This Listener container configured with own number of consumers and normally it should be 4. in cluster more remember that each node with have 4 consumers (Keep in mind that is call user save that is ridiculously heavy take a lot of resources and miltiple concurrent saves may bring dead lock and fail of save.- Returns:
SimpleRabbitListenerContainerFactory
-
provisionDispatcherRabbitListenerContainerFactory
@Bean(name="provisionDispatcherRabbitListenerContainerFactory") public org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory provisionDispatcherRabbitListenerContainerFactory()
This is common container factory for ProvisionDispatcherQueue with separately configured number of consumers. we need this configurable, because there are use cases where we use heavy scripts for policy map for some managed systems. In this way we may limit parallel provisioning to target system operations and not overload system. Experiments show that with less number of the concurrent operation provisioning is faster and have less impact to entire system.- Returns:
SimpleRabbitListenerContainerFactory
-
idmAmqpAdmin
@Bean public org.springframework.amqp.core.AmqpAdmin idmAmqpAdmin()
-
provisionQueue
@Bean(name="ProvisionQueue") public ProvisionQueue provisionQueue()
-
provisionBulkQueue
@Bean(name="ProvisionBulkQueue") public ProvisionBulkQueue provisionBulkQueue()
-
provisionInfoQueue
@Bean(name="ProvisionInfoQueue") public ProvisionInfoQueue provisionInfoQueue()
-
provisionDispatcherQueue
@Bean(name="ProvisionDispatcherQueue") public ProvisionDispatcherQueue provisionDispatcherQueue()
-
managedSysQueue
@Bean(name="ManagedSysQueue") public ManagedSysQueue managedSysQueue()
-
provisionConnectorQueue
@Bean(name="ProvisionConnectorQueue") public ProvisionConnectorQueue provisionConnectorQueue()
-
identityQueue
@Bean(name="IdentityQueue") public IdentityQueue identityQueue()
-
groupProvisionQueue
@Bean(name="GroupProvisionQueue") public GroupProvisionQueue groupProvisionQueue()
-
bindQueue
@Bean(name="BindQueue") public BindQueue bindQueue()
-
synchronizationQueue
@Bean(name="SynchronizationQueue") public SynchronizationQueue synchronizationQueue()
-
reconciliationConfigQueue
@Bean(name="ReconciliationConfigQueue") public ReconciliationConfigQueue reconciliationConfigQueue()
-
reconciliationIDMConfigQueue
@Bean(name="ReconciliationIDMConfigQueue") public ReconciliationIDMConfigQueue reconciliationIDMConfigQueue()
-
-