Таким образом, согласно документам Spring, он будет публиковать метрики на конечной точке REST и канале сообщений.
Конечная точка REST работает нормально, так как я получаю ожидаемый результат. Однако я хотел бы обрабатывать каждое изменение в показателях. Таким образом, он говорит, что по умолчанию будет публиковать сообщения в канале под названием «metricsChannel».
Я попытался создать следующий класс, который будет слушать этот канал, но, похоже, он не срабатывает. Все остальное осталось по умолчанию для приложения Spring Boot.
package services.core;
import org.springframework.stereotype.Service;
import org.springframework.integration.annotation.ServiceActivator;
@Service
public class MetricService {
@ServiceActivator(inputChannel = "metricsChannel")
public void handleMessage(org.springframework.messaging.Message<?> message) {
System.out.println("Message [" + message.toString() + "] is received");
}
}
