Class TransportUnitCommandPropagator


  • @Profile("ASYNCHRONOUS")
    @RefreshScope
    @Component
    class TransportUnitCommandPropagator
    extends Object
    A TransportUnitCommandPropagator propagates TUCommands send by this service out to other services over an AMQP exchange.
    Author:
    Heiko Scherrer
    • Field Detail

      • LOGGER

        private static final org.slf4j.Logger LOGGER
      • amqpTemplate

        private final org.springframework.amqp.core.AmqpTemplate amqpTemplate
      • validator

        private final javax.validation.Validator validator
      • exchangeName

        private final String exchangeName
    • Constructor Detail

      • TransportUnitCommandPropagator

        TransportUnitCommandPropagator​(org.springframework.amqp.core.AmqpTemplate amqpTemplate,
                                       javax.validation.Validator validator,
                                       @Value("${owms.commands.common.tu.exchange-name}")
                                       String exchangeName)
    • Method Detail

      • onEvent

        @TransactionalEventListener(fallbackExecution=true)
        public void onEvent​(TUCommand command)