Издатель недоступен для publi sh TcpConnectionOpenEvent / TcpConnectionCloseEvent

Question

Я настроил TCP-клиент с Java DSL Spring Integration. Похоже, это

    @Bean
    public TcpSendingMessageHandler tcpClient()
    {
        return Tcp
            .outboundAdapter(
                Tcp.nioClient("localhost", 9060)
                   .deserializer(new ByteArrayLfSerializer())
                   .soKeepAlive(false)
                   .leaveOpen(false)
                   .taskExecutor(Executors.newSingleThreadExecutor())
                   .get()
            )
            .clientMode(false)
            .get();
    }

И я использую его в Службе для отправки сообщений в сокет TCP, к которому подключен клиент:

    @Slf4j
    @Service
    public class TcpClientConnectionService
    {
        private final TcpSendingMessageHandler messageHandler;

        @Autowired
        public TcpClientConnectionService(final TcpSendingMessageHandler messageHandler)
        {
            this.messageHandler = messageHandler;
            this.messageHandler.start();
        }

        public void sendMessage(final String message)
        {
            messageHandler.handleMessage(new GenericMessage<>(message));

            log.debug("Message: " + message + " send");
        }
    }

Но в процессе производства я получаю Следующее предупреждение является довольно регулярным, и я не знаю, в чем проблема и как ее исправить. издатель, доступный для publi sh TcpConnectionCloseEvent

Было бы здорово, если бы кто-нибудь мог мне помочь, так как я не смог ничего найти с помощью Google.

Answer 1

Вложенная фабрика не инициализирована должным образом, потому что вы неправильно вызываете .get() на spe c, что нарушает инициализацию Spring.

Я настроил TCP-клиент с Java DSL интеграции Spring . Это выглядит так

@Bean
public TcpSendingMessageHandler tcpClient()
{
    return Tcp
        .outboundAdapter(
            Tcp.nioClient("localhost", 9060)
               .deserializer(new ByteArrayLfSerializer())
               .soKeepAlive(false)
               .leaveOpen(false)
               .taskExecutor(Executors.newSingleThreadExecutor()))
        .clientMode(false)
        .get();
}

Или переместите определение factory на верхний уровень @Bean.