Package org.openwms.common.comm.osip.locu

Class AmqpLocationUpdateMessageHandler

java.lang.Object

org.openwms.common.comm.osip.locu.AmqpLocationUpdateMessageHandler

All Implemented Interfaces:

Function<org.springframework.messaging.support.GenericMessage<LocationUpdateMessage>,Void>

@Profile("ASYNCHRONOUS")
@OSIPComponent
@RefreshScope
class AmqpLocationUpdateMessageHandler
extends Object
implements Function<org.springframework.messaging.support.GenericMessage<LocationUpdateMessage>,Void>

An AmqpLocationUpdateMessageHandler is the handler function to accept LocationUpdateMessages and forward them for processing over AMQP.

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 String	routingKey

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Void	apply(org.springframework.messaging.support.GenericMessage<LocationUpdateMessage> msg)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Field Details

amqpTemplate

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

exchangeName

private final String exchangeName

routingKey

private final String routingKey

Constructor Details

AmqpLocationUpdateMessageHandler

AmqpLocationUpdateMessageHandler(org.springframework.amqp.core.AmqpTemplate amqpTemplate,
 @Value("${owms.driver.osip.locu.exchange-name}")
 String exchangeName,
 @Value("${owms.driver.osip.locu.routing-key-out}")
 String routingKey)

Method Details

apply

public Void apply(org.springframework.messaging.support.GenericMessage<LocationUpdateMessage> msg)

Specified by:

apply in interface Function<org.springframework.messaging.support.GenericMessage<LocationUpdateMessage>,Void>