Package org.openwms.common.location.impl

Class LocationGroupEventPropagator

java.lang.Object

org.openwms.common.location.impl.LocationGroupEventPropagator

@Profile("ASYNCHRONOUS")
@RefreshScope
@Component
class LocationGroupEventPropagator
extends Object

A LocationGroupEventPropagator.

Author:

Heiko Scherrer

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
LocationGroupEventPropagator(org.springframework.amqp.core.AmqpTemplate amqpTemplate, jakarta.validation.Validator validator, String exchangeName, LocationMapper locationMapper, LocationGroupMapper locationGroupMapper)

Method Summary

Modifier and Type	Method	Description
void	onEvent(LocationGroupEvent event)
void	onLocationEvent(LocationEvent event)
(package private) void	onStartup()

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

locationMapper

private final LocationMapper locationMapper

locationGroupMapper

private final LocationGroupMapper locationGroupMapper

Constructor Details

LocationGroupEventPropagator

LocationGroupEventPropagator(org.springframework.amqp.core.AmqpTemplate amqpTemplate,
 jakarta.validation.Validator validator,
 @Value("${owms.events.common.lg.exchange-name}")
 String exchangeName,
 LocationMapper locationMapper,
 LocationGroupMapper locationGroupMapper)

Method Details

onStartup

@PostConstruct
void onStartup()

onEvent

@Measured
@TransactionalEventListener
@Transactional(propagation=REQUIRES_NEW)
public void onEvent(LocationGroupEvent event)

onLocationEvent

@Measured
@TransactionalEventListener
@Transactional(propagation=REQUIRES_NEW)
public void onLocationEvent(LocationEvent event)