Package org.openwms.common.transport.commands

Class TransportUnitCommandPropagator

java.lang.Object

org.openwms.common.transport.commands.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 Summary

Fields

Modifier and Type	Field	Description
private final org.springframework.amqp.core.AmqpTemplate	amqpTemplate
private final String	exchangeName
private static final org.slf4j.Logger	LOGGER
private final jakarta.validation.Validator	validator

Constructor Summary

Constructors

Constructor	Description
TransportUnitCommandPropagator(org.springframework.amqp.core.AmqpTemplate amqpTemplate, jakarta.validation.Validator validator, String exchangeName)

Method Summary

Modifier and Type	Method	Description
void	onEvent(TUCommand command)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

amqpTemplate

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

validator

private final jakarta.validation.Validator validator

exchangeName

private final String exchangeName

Constructor Details

TransportUnitCommandPropagator

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

Method Details

onEvent

@Measured
@TransactionalEventListener(fallbackExecution=true)
@Transactional(propagation=REQUIRES_NEW)
public void onEvent(TUCommand command)