Package org.openiam.config

Class BaseVHostConfig

java.lang.Object

org.openiam.config.BaseVHostConfig

Direct Known Subclasses:

ActivitiVHostConfig, AmVHostConfig, AuditVHostConfig, BulkReconciliationVHostConfig, BulkSynchronizationVHostConfig, BusinessRuleVHostConfig, CommonVHostConfig, ConnectorBroadCastVHostConfig, ConnectorVHostConfig, ExtLogVHostConfig, GroovyManagerVHostConfig, IdmVHostConfig, ReconciliationVHostConfig, SASVHostConfig, SynchronizationVHostConfig, UserVHostConfig

public class BaseVHostConfig
extends Object

Created by alexander on 18/11/16.

Field Summary

Fields

Modifier and Type	Field	Description
protected Integer	concurrentConsumers
protected String	encoding
protected org.apache.commons.logging.Log	logger
protected float	syncReducingFactor

Constructor Summary

Constructors

Constructor	Description
BaseVHostConfig()

Method Summary

Modifier and Type	Method	Description
protected void	commonBindQueue(org.springframework.amqp.core.AmqpAdmin amqpAdmin, MqQueue queue)
protected org.springframework.amqp.rabbit.connection.ConnectionFactory	createConnectionFactory(String vhost)
protected org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory	createRabbitListenerContainerFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
protected org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory	createRabbitListenerContainerFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, Integer concurrentConsumers, Integer maxConcurrentConsumers, Integer prefetchCount)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.apache.commons.logging.Log logger

concurrentConsumers

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

encoding

@Value("${org.openiam.mq.broker.encoding}")
protected String encoding

syncReducingFactor

@Value("${org.openiam.rabbitmq.sync.reducing.factor}")
protected float syncReducingFactor

Constructor Detail

BaseVHostConfig

public BaseVHostConfig()

Method Detail

createConnectionFactory

protected org.springframework.amqp.rabbit.connection.ConnectionFactory createConnectionFactory(String vhost)

createRabbitListenerContainerFactory

protected org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory createRabbitListenerContainerFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                                                                                           Integer concurrentConsumers,
                                                                                                                           Integer maxConcurrentConsumers,
                                                                                                                           Integer prefetchCount)

createRabbitListenerContainerFactory

protected org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory createRabbitListenerContainerFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)

commonBindQueue

protected void commonBindQueue(org.springframework.amqp.core.AmqpAdmin amqpAdmin,
                               MqQueue queue)