Package org.openwms.wms.movements.impl

Class MovementEventPropagator

java.lang.Object

org.openwms.wms.movements.impl.MovementEventPropagator

@Profile("ASYNCHRONOUS")
@Component
class MovementEventPropagator
extends Object

A MovementEventPropagator is active with the "ASYNCHRONOUS" profile and propagates internal events to the outer world over AMQP protocol.

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

Constructor Summary

Constructors

Constructor	Description
MovementEventPropagator(String exchangeName, org.springframework.amqp.core.AmqpTemplate amqpTemplate)

Method Summary

Modifier and Type	Method	Description
void	onEvent(MovementEvent event)

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

exchangeName

private final String exchangeName

amqpTemplate

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

Constructor Details

MovementEventPropagator

MovementEventPropagator(@Value("${owms.movements.exchange-name}")
 String exchangeName,
 org.springframework.amqp.core.AmqpTemplate amqpTemplate)

Method Details

onEvent

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