Существующее соединение было принудительно закрыто удаленным хостом в служебной шине - PullRequest
Новая
       126

Существующее соединение было принудительно закрыто удаленным хостом в служебной шине

0 голосов
/ 19 марта 2020

Мы постоянно отправляем и получаем сообщение в очереди, используя azure служебную шину qpid-jms-client (https://github.com/Azure/azure-service-bus/blob/master/samples/Java/qpid-jms-client/JmsQueueQuickstart/src/main/java/com/microsoft/azure/servicebus/samples/jmsqueuequickstart/JmsQueueQuickstart.java). После работы более 2-х дней он выходит из строя, за исключением следующего: 

2020-03-19 02:40:36.528 ERROR [Thread-49] 
Error occurred while receive message:
javax.jms.IllegalStateException: The MessageConsumer was closed due to an unrecoverable error.
    at org.apache.qpid.jms.JmsMessageConsumer.checkClosed(JmsMessageConsumer.java:367)
    at org.apache.qpid.jms.JmsMessageConsumer.receive(JmsMessageConsumer.java:190)
    at org.apache.qpid.jms.JmsMessageConsumer.receive(JmsMessageConsumer.java:185)

    at java.lang.Thread.run(Thread.java:748)
Caused by: java.io.IOException: An existing connection was forcibly closed by the remote host
    at sun.nio.ch.SocketDispatcher.read0(Native Method)
    at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
    at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
    at sun.nio.ch.IOUtil.read(IOUtil.java:192)
    at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
    at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)
    at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
    at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:347)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:148)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    ... 1 more

Пожалуйста, предложите, что может быть не так. Спасибо.

...