Package org.openwms.tms.impl.state

Class AmqpStateListener

java.lang.Object

org.openwms.tms.impl.state.AmqpStateListener

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

An AmqpStateListener listens on a start response from remote services as a reply to a former start request, validates the response and delegates to the Startable instance for final starting of the TransportOrder.

Author:

Heiko Scherrer

Field Summary

Fields

Modifier and Type	Field	Description
private final TransportationService<TransportOrder>	service
private final Startable	starter

Constructor Summary

Constructors

Constructor	Description
AmqpStateListener(Startable starter, TransportationService<TransportOrder> service)

Method Summary

Modifier and Type	Method	Description
void	onResponse(StateChangeResponse response)	Listen and validate StateChangeResponses.

Methods inherited from class java.lang.Object

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

Field Details

starter

private final Startable starter

service

private final TransportationService<TransportOrder> service

Constructor Details

AmqpStateListener

AmqpStateListener(Startable starter,
 TransportationService<TransportOrder> service)

Method Details

onResponse

@Measured
@RabbitListener(queues="${owms.requests.tms.to.queue-name}")
public void onResponse(StateChangeResponse response)

Listen and validate StateChangeResponses.

Parameters:

response - The response