Package org.openwms.tms.routing.app

Class Registrator

java.lang.Object

org.openwms.tms.routing.app.Registrator

@Profile("ASYNCHRONOUS")
@RefreshScope
@Component
class Registrator
extends Object

A Registrator.

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 org.openwms.common.location.api.commands.LocationReplicaRegistration	locationReplicaRegistration
private static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
Registrator(String exchangeName, String applicationName, String locationRequestRemovalPath, String locationRemovalPath, org.springframework.amqp.core.AmqpTemplate amqpTemplate)

Method Summary

Modifier and Type	Method	Description
void	onContextStarted(org.springframework.context.event.ContextStartedEvent cse)
void	onContextStopped(org.springframework.context.event.ContextClosedEvent cse)
void	onTimer()

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

locationReplicaRegistration

private final org.openwms.common.location.api.commands.LocationReplicaRegistration locationReplicaRegistration

amqpTemplate

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

Constructor Details

Registrator

Registrator(@Value("${owms.commands.common.registration.exchange-name}")
 String exchangeName,
 @Value("${spring.application.name}")
 String applicationName,
 @Value("${owms.routing.registration.location-request-removal-path}")
 String locationRequestRemovalPath,
 @Value("${owms.routing.registration.location-removal-path}")
 String locationRemovalPath,
 org.springframework.amqp.core.AmqpTemplate amqpTemplate)

Method Details

onContextStarted

@EventListener
public void onContextStarted(org.springframework.context.event.ContextStartedEvent cse)

onContextStopped

@EventListener
public void onContextStopped(org.springframework.context.event.ContextClosedEvent cse)

onTimer

@Scheduled(fixedDelay=30000L)
public void onTimer()