Package org.acemq.spring.boot

Class AceMqTopologyInitializer

java.lang.Object

org.acemq.spring.boot.AceMqTopologyInitializer

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

public class AceMqTopologyInitializer
extends Object
implements org.springframework.beans.factory.InitializingBean

Applies the declared topology once, at startup.

The plan is logged whatever the mode, because "the queue was already there" and "the queue was created just now" are different facts about a deployment and both are worth having in the log when a message goes missing an hour later.

Drift is reported and, with acemq.topology.fail-on-drift, fatal. It is not corrected. A starter that repaired drift would be a starter that changed a queue's arguments during a rolling deployment, and the broker's answer to that is to refuse the declaration on every instance that has not been restarted yet.

Constructor Summary

Constructors

Constructor	Description
AceMqTopologyInitializer(org.acemq.amqp.core.AceMq aceMq, org.acemq.amqp.api.Topology topology, org.acemq.amqp.api.ApplyMode mode, boolean failOnDrift)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()

Methods inherited from class java.lang.Object

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

Constructor Details

AceMqTopologyInitializer

public AceMqTopologyInitializer(org.acemq.amqp.core.AceMq aceMq,
 org.acemq.amqp.api.Topology topology,
 org.acemq.amqp.api.ApplyMode mode,
 boolean failOnDrift)

Method Details

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean