Package org.openwms.tms.impl.removal

Class TransportUnitRemovalListener

java.lang.Object

org.openwms.tms.impl.removal.TransportUnitRemovalListener

@Profile("ASYNCHRONOUS")
@TxService
class TransportUnitRemovalListener
extends Object

A TransportUnitRemovalListener is an AMQP listener that listens on commands when a TransportUnit is going to be deleted.

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 TransportUnitRemovalHandler	handler
private static final org.slf4j.Logger	LOGGER
private final jakarta.validation.Validator	validator

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	handle(org.openwms.common.transport.api.commands.TUCommand command)
void	onEvent(org.openwms.common.transport.api.commands.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

handler

private final TransportUnitRemovalHandler handler

validator

private final jakarta.validation.Validator validator

amqpTemplate

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

exchangeName

private final String exchangeName

Constructor Details

TransportUnitRemovalListener

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

Method Details

onEvent

@Measured
@TransactionalEventListener(fallbackExecution=true)
@Transactional(propagation=REQUIRES_NEW)
public void onEvent(org.openwms.common.transport.api.commands.TUCommand command)

handle

@Measured
@RabbitListener(queues="${owms.commands.common.tu.queue-name}")
public void handle(@Payload
 org.openwms.common.transport.api.commands.TUCommand command)