Package org.openwms.wms.receiving.events

Class EventPropagator

java.lang.Object

org.openwms.wms.receiving.events.EventPropagator

@Profile("ASYNCHRONOUS")
@Component
public class EventPropagator
extends Object

A EventPropagator is a Spring managed bean, activated in profile ASYNCHRONOUS that propagates internal events to the outer world via AMQP.

Author:

Heiko Scherrer

Field Summary

Fields

Modifier and Type	Field	Description
private final org.springframework.amqp.core.AmqpTemplate	amqpTemplate
private static final org.slf4j.Logger	LOGGER
private final ReceivingMOMapper	mapper
private final String	receivingExchangeName

Constructor Summary

Constructors

Constructor	Description
EventPropagator(org.springframework.amqp.core.AmqpTemplate amqpTemplate, ReceivingMOMapper mapper, String receivingExchangeName)

Method Summary

Modifier and Type	Method	Description
<T extends AbstractReceivingOrderPosition> void	onEvent(ReceivingOrderPositionStateChangeEvent<T> event)
void	onEvent(ReceivingOrderStateChangeEvent 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

amqpTemplate

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

mapper

private final ReceivingMOMapper mapper

receivingExchangeName

private final String receivingExchangeName

Constructor Details

EventPropagator

public EventPropagator(org.springframework.amqp.core.AmqpTemplate amqpTemplate,
 ReceivingMOMapper mapper,
 @Value("${owms.events.receiving.exchange-name}")
 String receivingExchangeName)

Method Details

onEvent

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

onEvent

@Measured
@TransactionalEventListener
@Transactional(propagation=REQUIRES_NEW)
public <T extends AbstractReceivingOrderPosition>
void onEvent(ReceivingOrderPositionStateChangeEvent<T> event)