У меня есть следующий компонент слушателя:
@Component
public class Receiver {
@RabbitListener(queues = "fmd-response")
public void receiveMessage(Response response, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {
channel.basicAck(tag, false);
}
@PreDestroy
public void preDestroy() {
}
}
Что следует поместить в preDestroy()
, чтобы закрыть канал, автоматически созданный при загрузке компонента?Это необходимо для перезагрузки компонента с помощью JRebel, потому что при каждой перезагрузке будет создаваться новый канал:
127.0.0.1:54916 (1)
guest idle 0 250 0
127.0.0.1:54916 (2)
guest idle 0 250 0
127.0.0.1:54916 (3)
guest idle 0 250 0
127.0.0.1:54916 (4)
guest idle 0 250 0
127.0.0.1:54916 (5)
guest idle 0 250 0
127.0.0.1:54916 (6)
guest idle 0 250 0