TcpMessageMapper - нулевая полезная нагрузка от соединения xxxx: xxxx: 0e07144 c -456e-4e31-a93 c -66926b8f7018 при использовании FailoverClientConnectionFactory - PullRequest
Новая
       30

TcpMessageMapper - нулевая полезная нагрузка от соединения xxxx: xxxx: 0e07144 c -456e-4e31-a93 c -66926b8f7018 при использовании FailoverClientConnectionFactory

0 голосов
/ 25 февраля 2020

У меня проблема, если сервер переключается с A на B. Если A не работает, а B работает. Используя FailoverClientConnectionFactory, я могу видеть ниже предупреждение при отправке любого запроса на сервер.

WARN osiit c .TcpMessageMapper - нулевая полезная нагрузка от соединения cisco-xxxx: 42017: 58773: 0e07144 c -456e-4e31- a93 c -66926b8f7018

Я использую FailoverClientConnectionFactory с двумя серверами. работает, если первый сервер запущен и работает. Но не работает, если его переключают на сервер B.

Вот фрагмент кода: 

@Bean
    public FailoverClientConnectionFactory getFailoverClientConnectionFactory() throws CiscoConnectionFailureException 
    {
        FailoverClientConnectionFactory failoverCF = new FailoverClientConnectionFactory(underlyingCF());
        failoverCF.setSingleUse(false);
        failoverCF.afterPropertiesSet();

        return failoverCF;
    }

@Bean
    public List<AbstractClientConnectionFactory> underlyingCF() throws CiscoConnectionFailureException 
    {

            List<ServerInfo> processServers = mConfigurationService.getProcesservers();
            List<AbstractClientConnectionFactory> factories = new ArrayList<>();
            boolean connectionSuccessful = false;
            for (ServerInfo serverInfo : processServers) 
            {
                AbstractClientConnectionFactory clientFactory = new TcpNetClientConnectionFactory(
                        serverInfo.getServerAddress(), serverInfo.getServerPort());
                clientFactory.setSingleUse(false);
                clientFactory.setDeserializer(mMessageSerializerDeserializer);
                clientFactory.setSerializer(mMessageSerializerDeserializer);                
                factories.add(clientFactory);

            }
            return factories;

    }

@Bean(name = "outAdapter.client")
    @ServiceActivator(inputChannel = "input", requiresReply = "true")
    public TcpSendingMessageHandler getOutboundChannelAdapter(
            FailoverClientConnectionFactory failoverClientConnectionFactory)
    {
        TcpSendingMessageHandler outboundChannelAdapter = new TcpSendingMessageHandler();
        outboundChannelAdapter.setOrder(OUTBOUND_ADAPTOR_ORDER);
        outboundChannelAdapter.setConnectionFactory(failoverClientConnectionFactory);
        outboundChannelAdapter.setClientMode(true);

        return outboundChannelAdapter;
    }

Может кто-нибудь иметь представление, в чем проблема?

...