ExternalStartListener.java
/*
* Copyright 2005-2025 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.openwms.tms.routing.routes;
import org.ameba.annotation.Measured;
import org.openwms.core.SpringProfiles;
import org.openwms.tms.api.MessageVO;
import org.openwms.tms.api.TransportOrderApi;
import org.openwms.tms.api.requests.state.StateChangeRequest;
import org.openwms.tms.api.requests.state.StateChangeResponse;
import org.openwms.tms.routing.RouteSearchAlgorithm;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Component;
import static java.lang.String.format;
/**
* A ExternalStartListener.
*
* @author Heiko Scherrer
*/
@Profile({SpringProfiles.ASYNCHRONOUS_PROFILE})
@Component
class ExternalStartListener {
private static final Logger LOGGER = LoggerFactory.getLogger(ExternalStartListener.class);
public static final String RESPONSE_STATE_CHANGE = "response.state.change";
private final TransportOrderApi transportOrderApi;
private final RouteSearchAlgorithm routeSearch;
private final AmqpTemplate amqpTemplate;
private final String exchangeName;
ExternalStartListener(TransportOrderApi transportOrderApi, RouteSearchAlgorithm routeSearch, AmqpTemplate amqpTemplate,
@Value("${owms.requests.routing.to.exchange-name}") String exchangeName) {
this.transportOrderApi = transportOrderApi;
this.routeSearch = routeSearch;
this.amqpTemplate = amqpTemplate;
this.exchangeName = exchangeName;
}
@Measured
@RabbitListener(queues = "${owms.requests.routing.to.queue-name}")
public void onRequest(StateChangeRequest request) {
if ("STARTED".equals(request.getRequestedState())) {
try {
var vo = transportOrderApi.findByPKey(request.getTransportOrderPkey());
var route = routeSearch.findBy(vo.getSourceLocation(), vo.getTargetLocation(), vo.getTargetLocationGroup());
LOGGER.debug("TransportOrder to start has a Route [{}] ", route.getRouteId());
amqpTemplate.convertAndSend(exchangeName, RESPONSE_STATE_CHANGE, new StateChangeResponse(request, "STARTED", null));
} catch (NoRouteException ex) {
// not that bad we know no Route exists...
var msg = format("A TransportOrder was requested to start that has no Route. PKey: [%s]", request.getTransportOrderPkey());
LOGGER.warn(msg, msg);
amqpTemplate.convertAndSend(exchangeName, RESPONSE_STATE_CHANGE, new StateChangeResponse(request, "XX",
MessageVO.newBuilder()
.messageText(msg)
.build()
));
} catch (Exception ex) {
var msg = format("Generic exception. Route for TransportOrder [%s] could not be determined", request.getTransportOrderPkey());
LOGGER.warn(msg, msg);
amqpTemplate.convertAndSend(exchangeName, RESPONSE_STATE_CHANGE, new StateChangeResponse(request, "XX",
MessageVO.newBuilder()
.messageText(msg)
.build()
));
}
}
}
}