-
Notifications
You must be signed in to change notification settings - Fork 2.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Update to gRPC 1.65.0 and Netty 4.1.111 #41578
Conversation
This comment has been minimized.
This comment has been minimized.
gRPC is giving us trouble... |
Yeah, will have a look. They likely changed the mechanism |
e22d298
to
49b85f2
Compare
I've found the reason for the Stork failure when using the gRPC Java client: They do not call the load balancer every time anymore. grpc/grpc-java@8844cf7. |
:( |
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
🙈 The PR is closed and the preview is expired. |
49b85f2
to
f73aeea
Compare
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
These opentelemetry test failures might be related. |
The same tests have been failing in other PRs as well, so let's hold off until we find the cause |
Rebasing onto |
Hum, I've another PR totally unrelated with the same set of failures. |
Right. I think the problem has since been fixed in main which is why I propose a rebase |
This commit updates the gRPC version to 1.65.0 and enables the switch to Netty 4.1.111. Additionally, it updates several gRPC-related dependencies: - jprotoc to 1.2.2 - protoc to 3.25.3 - protobuf-java to 3.25.3 Disable Stork "least response time" IT when using the gRPC Java client. This is because in gRPC 1.65.0, the load balancer is only called once if the calls are queued. The Vert.x-based client is still behaving normally. When using gRPC Java client, it's a change in behavior, but the load balancer will still be called for non-concurrent calls.
f73aeea
to
2891ca4
Compare
This comment has been minimized.
This comment has been minimized.
Looks much better now. I am hoping that the windows failure is not related but we will probably have to rerun that job to be sure... 2024-07-03T12:01:21.3120304Z [INFO] Running io.quarkus.smallrye.reactivemessaging.amqp.AnonymousAmqpTest
2024-07-03T12:01:29.6857384Z 2024-07-03 12:01:22,500 INFO [org.apa.act.art.cor.server] (main) AMQ221000: Primary message broker is starting with configuration Broker Configuration (clustered=false,journalDirectory=target/data/journal,bindingsDirectory=target/data/bindings,largeMessagesDirectory=target/data/large-messages,pagingDirectory=target/data/paging)
2024-07-03T12:01:29.6860758Z 2024-07-03 12:01:22,537 INFO [org.apa.act.art.cor.server] (main) AMQ221013: Using NIO Journal
2024-07-03T12:01:29.6863354Z 2024-07-03 12:01:22,609 INFO [org.apa.act.art.cor.server] (main) AMQ221057: Global Max Size is being adjusted to 1/2 of the JVM max size (-Xmx). being defined as 786432000
2024-07-03T12:01:29.6866393Z 2024-07-03 12:01:22,640 INFO [org.apa.act.art.cor.server] (main) AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE
2024-07-03T12:01:29.6868932Z 2024-07-03 12:01:22,641 INFO [org.apa.act.art.cor.server] (main) AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP
2024-07-03T12:01:29.6871467Z 2024-07-03 12:01:22,690 INFO [org.apa.act.aud.base] (main) AMQ601138: User anonymous@unknown is getting notification info on target resource: null
2024-07-03T12:01:29.6874852Z 2024-07-03 12:01:22,691 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.ActiveMQServerControlImpl@7af1cd63
2024-07-03T12:01:29.6878502Z 2024-07-03 12:01:22,691 INFO [org.apa.act.aud.base] (main) AMQ601138: User anonymous@unknown is getting notification info on target resource: ActiveMQServerImpl::name=0.0.0.0
2024-07-03T12:01:29.6880935Z 2024-07-03 12:01:22,719 INFO [org.apa.act.art.cor.server] (main) AMQ221034: Waiting indefinitely to obtain primary lock
2024-07-03T12:01:29.6882952Z 2024-07-03 12:01:22,719 INFO [org.apa.act.art.cor.server] (main) AMQ221035: Primary Server Obtained primary lock
2024-07-03T12:01:29.6885111Z 2024-07-03 12:01:22,839 INFO [org.apa.act.art.cor.server] (main) AMQ221080: Deploying address DLQ supporting [ANYCAST]
2024-07-03T12:01:29.6887963Z 2024-07-03 12:01:22,849 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.AddressControlImpl@6ef81f31
2024-07-03T12:01:29.6890835Z 2024-07-03 12:01:22,853 INFO [org.apa.act.art.cor.server] (main) AMQ221003: Deploying ANYCAST queue DLQ on address DLQ
2024-07-03T12:01:29.6894383Z 2024-07-03 12:01:22,947 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.QueueControlImpl@2715644a
2024-07-03T12:01:29.6897257Z 2024-07-03 12:01:22,949 INFO [org.apa.act.art.cor.server] (main) AMQ221080: Deploying address ExpiryQueue supporting [ANYCAST]
2024-07-03T12:01:29.6900164Z 2024-07-03 12:01:22,950 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.AddressControlImpl@4c2869a9
2024-07-03T12:01:29.6903171Z 2024-07-03 12:01:22,950 INFO [org.apa.act.art.cor.server] (main) AMQ221003: Deploying ANYCAST queue ExpiryQueue on address ExpiryQueue
2024-07-03T12:01:29.6906309Z 2024-07-03 12:01:22,952 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.QueueControlImpl@6edcd0d8
2024-07-03T12:01:29.6909956Z 2024-07-03 12:01:22,955 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.AddressControlImpl@4a6c18ad
2024-07-03T12:01:29.6913932Z 2024-07-03 12:01:23,017 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.AcceptorControlImpl@50194e8d
2024-07-03T12:01:29.6917621Z 2024-07-03 12:01:23,019 INFO [org.apa.act.aud.base] (main) AMQ601019: User anonymous@unknown is getting mbean info on target resource: org.apache.activemq.artemis.core.management.impl.AcceptorControlImpl@290aeb20
2024-07-03T12:01:29.6921428Z 2024-07-03 12:01:23,176 ERROR [org.apa.act.art.cor.server] (main) AMQ224104: Error starting the Acceptor artemis {scheme=tcp, tcpReceiveBufferSize=1048576, port=61616, host=0.0.0.0, protocols=CORE,AMQP, tcpSendBufferSize=1048576}
2024-07-03T12:01:29.6925284Z 2024-07-03 12:01:23,176 ERROR [org.apa.act.art.cor.server] (main) AMQ224000: Failure in initialisation: java.lang.IllegalStateException: AMQ229230: Failed to bind acceptor artemis to 0.0.0.0:61616
2024-07-03T12:01:29.6928061Z at org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor.startServerChannels(NettyAcceptor.java:735)
2024-07-03T12:01:29.6930181Z at org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor.start(NettyAcceptor.java:531)
2024-07-03T12:01:29.6932788Z at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.startAcceptors(RemotingServiceImpl.java:316)
2024-07-03T12:01:29.6935423Z at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.completeActivation(ActiveMQServerImpl.java:3691)
2024-07-03T12:01:29.6937535Z at org.apache.activemq.artemis.core.server.impl.PrimaryOnlyActivation.run(PrimaryOnlyActivation.java:80)
2024-07-03T12:01:29.6939582Z at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.internalStart(ActiveMQServerImpl.java:742)
2024-07-03T12:01:29.6941635Z at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.start(ActiveMQServerImpl.java:632)
2024-07-03T12:01:29.6943787Z at org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ.start(EmbeddedActiveMQ.java:134)
2024-07-03T12:01:29.6945736Z at io.quarkus.smallrye.reactivemessaging.amqp.AnonymousAmqpBroker.start(AnonymousAmqpBroker.java:34)
2024-07-03T12:01:29.6947452Z at io.quarkus.test.QuarkusUnitTest.beforeAll(QuarkusUnitTest.java:515)
2024-07-03T12:01:29.6949176Z at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$invokeBeforeAllCallbacks$12(ClassBasedTestDescriptor.java:396)
2024-07-03T12:01:29.6951207Z at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2024-07-03T12:01:29.6953232Z at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeBeforeAllCallbacks(ClassBasedTestDescriptor.java:396)
2024-07-03T12:01:29.6955539Z at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.before(ClassBasedTestDescriptor.java:212)
2024-07-03T12:01:29.6957798Z at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.before(ClassBasedTestDescriptor.java:85)
2024-07-03T12:01:29.6959965Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:148)
2024-07-03T12:01:29.6962083Z at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2024-07-03T12:01:29.6964402Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2024-07-03T12:01:29.6966236Z at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2024-07-03T12:01:29.6968048Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2024-07-03T12:01:29.6970172Z at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2024-07-03T12:01:29.6972234Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2024-07-03T12:01:29.6974380Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2024-07-03T12:01:29.6976040Z at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
2024-07-03T12:01:29.6977900Z at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
2024-07-03T12:01:29.6979985Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2024-07-03T12:01:29.6981695Z at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2024-07-03T12:01:29.6983199Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2024-07-03T12:01:29.6984587Z at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2024-07-03T12:01:29.6985511Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2024-07-03T12:01:29.6986787Z at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2024-07-03T12:01:29.6988627Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2024-07-03T12:01:29.6990365Z at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2024-07-03T12:01:29.6992404Z at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
2024-07-03T12:01:29.6994813Z at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
2024-07-03T12:01:29.6996872Z at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
2024-07-03T12:01:29.6998736Z at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:198)
2024-07-03T12:01:29.7000634Z at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:169)
2024-07-03T12:01:29.7002463Z at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:93)
2024-07-03T12:01:29.7004420Z at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:58)
2024-07-03T12:01:29.7006510Z at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:141)
2024-07-03T12:01:29.7008514Z at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:57)
2024-07-03T12:01:29.7010213Z at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:103)
2024-07-03T12:01:29.7011708Z at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:85)
2024-07-03T12:01:29.7013254Z at org.junit.platform.launcher.core.DelegatingLauncher.execute(DelegatingLauncher.java:47)
2024-07-03T12:01:29.7014828Z at org.apache.maven.surefire.junitplatform.LazyLauncher.execute(LazyLauncher.java:56)
2024-07-03T12:01:29.7016559Z at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:184)
2024-07-03T12:01:29.7018457Z at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:148)
2024-07-03T12:01:29.7020429Z at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:122)
2024-07-03T12:01:29.7022153Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:385)
2024-07-03T12:01:29.7023543Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2024-07-03T12:01:29.7024813Z at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:507)
2024-07-03T12:01:29.7026025Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:495)
2024-07-03T12:01:29.7027256Z Caused by: java.net.BindException: Address already in use: bind
2024-07-03T12:01:29.7028054Z at java.base/sun.nio.ch.Net.bind0(Native Method)
2024-07-03T12:01:29.7028723Z at java.base/sun.nio.ch.Net.bind(Net.java:555)
2024-07-03T12:01:29.7029797Z at java.base/sun.nio.ch.ServerSocketChannelImpl.netBind(ServerSocketChannelImpl.java:337)
2024-07-03T12:01:29.7031310Z at java.base/sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:294)
2024-07-03T12:01:29.7032818Z at io.netty.channel.socket.nio.NioServerSocketChannel.doBind(NioServerSocketChannel.java:141)
2024-07-03T12:01:29.7034247Z at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:561)
2024-07-03T12:01:29.7035626Z at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1331)
2024-07-03T12:01:29.7037333Z at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:600)
2024-07-03T12:01:29.7039062Z at io.netty.channel.AbstractChannelHandlerContext.bind(AbstractChannelHandlerContext.java:579)
2024-07-03T12:01:29.7040518Z at io.netty.channel.DefaultChannelPipeline.bind(DefaultChannelPipeline.java:972)
2024-07-03T12:01:29.7041740Z at io.netty.channel.AbstractChannel.bind(AbstractChannel.java:259)
2024-07-03T12:01:29.7042890Z at io.netty.bootstrap.AbstractBootstrap$2.run(AbstractBootstrap.java:380)
2024-07-03T12:01:29.7044254Z at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
2024-07-03T12:01:29.7045831Z at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
2024-07-03T12:01:29.7047492Z at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
2024-07-03T12:01:29.7048877Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
2024-07-03T12:01:29.7050170Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:29.7051573Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:29.7052959Z at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
2024-07-03T12:01:29.7053871Z
2024-07-03T12:01:29.7055358Z 2024-07-03 12:01:23,177 INFO [org.apa.act.art.cor.server] (main) AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.35.0 [0.0.0.0, nodeID=f72ecedb-3933-11ef-b4f8-00155d9c869e]
2024-07-03T12:01:31.6189316Z 2024-07-03 12:01:31,581 INFO [io.sma.rea.mes.amqp] (main) SRMSG16201: AMQP broker configured to localhost:5672 for channel in
2024-07-03T12:01:31.7195718Z 2024-07-03 12:01:31,636 INFO [io.sma.rea.mes.amqp] (main) SRMSG16201: AMQP broker configured to localhost:5672 for channel source
2024-07-03T12:01:31.7198141Z 2024-07-03 12:01:31,707 INFO [io.sma.rea.mes.amqp] (main) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:31.8212079Z 2024-07-03 12:01:31,736 INFO [io.sma.rea.mes.amqp] (main) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:31.8708152Z 2024-07-03 12:01:31,842 INFO [io.quarkus] (main) quarkus-messaging-amqp-deployment 999-SNAPSHOT on JVM (powered by Quarkus 999-SNAPSHOT) started in 1.060s. Listening on: http://localhost:8081
2024-07-03T12:01:31.8710515Z 2024-07-03 12:01:31,842 INFO [io.quarkus] (main) Profile test activated.
2024-07-03T12:01:31.8723117Z 2024-07-03 12:01:31,842 INFO [io.quarkus] (main) Installed features: [cdi, messaging, messaging-amqp, resteasy, smallrye-context-propagation, vertx]
2024-07-03T12:01:33.1613742Z 2024-07-03 12:01:33,089 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:33.1616612Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:33.1617807Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:33.1619048Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:33.1620268Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:33.1621843Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:33.1624040Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:33.1625744Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:33.1627353Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:33.1628974Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:33.1630499Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:33.1631962Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:33.1633934Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:33.1635557Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:33.1636880Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:33.1637510Z
2024-07-03T12:01:33.1639932Z 2024-07-03 12:01:33,099 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:33.1642881Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:33.1644067Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:33.1645015Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:33.1646499Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:33.1648013Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:33.1649576Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:33.1651052Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:33.1652380Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:33.1654008Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:33.1655190Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:33.1656513Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:33.1657917Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:33.1659206Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:33.1660361Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:33.1660839Z
2024-07-03T12:01:34.2685511Z 2024-07-03 12:01:34,198 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:34.3689689Z 2024-07-03 12:01:34,337 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:35.3780191Z 2024-07-03 12:01:35,329 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:35.3781732Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:35.3782318Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:35.3782803Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:35.3784311Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:35.3785369Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:35.3786325Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:35.3787290Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:35.3788099Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:35.3788912Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:35.3789566Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:35.3790823Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:35.3791650Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:35.3792486Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:35.3793124Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:35.3793411Z
2024-07-03T12:01:35.4789989Z 2024-07-03 12:01:35,470 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:35.4791484Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:35.4792034Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:35.4792517Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:35.4793142Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:35.4793944Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:35.4794841Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:35.4795674Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:35.4796670Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:35.4797469Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:35.4798114Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:35.4798832Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:35.4799610Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:35.4800355Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:35.4800980Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:35.4801256Z
2024-07-03T12:01:36.7879269Z 2024-07-03 12:01:36,745 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:36.7880711Z 2024-07-03 12:01:36,785 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:38.0092618Z 2024-07-03 12:01:37,912 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:38.0094121Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:38.0094686Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:38.0095217Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:38.0095864Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:38.0096880Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:38.0097988Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:38.0098815Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:38.0099695Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:38.0100492Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:38.0101139Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:38.0101854Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:38.0102702Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:38.0103511Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:38.0104133Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:38.0104417Z
2024-07-03T12:01:38.0105622Z 2024-07-03 12:01:37,947 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:38.0107288Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:38.0107832Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:38.0108307Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:38.0109056Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:38.0109879Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:38.0110769Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:38.0111605Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:38.0112386Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:38.0113178Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:38.0113815Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:38.0114530Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:38.0115298Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:38.0116038Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:38.0116659Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:38.0116940Z
2024-07-03T12:01:41.7383918Z 2024-07-03 12:01:41,693 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:42.7446124Z 2024-07-03 12:01:42,665 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:42.8446560Z 2024-07-03 12:01:42,814 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:42.8448451Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:42.8449131Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:42.8449718Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:42.8450496Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:42.8451509Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:42.8452999Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:42.8454037Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:42.8455104Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:42.8456088Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:42.8456886Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:42.8457628Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:42.8458418Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:42.8459241Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:42.8459889Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:42.8460244Z
2024-07-03T12:01:43.8535412Z 2024-07-03 12:01:43,789 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:43.8537480Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:43.8538218Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:43.8539115Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:43.8539984Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:43.8541104Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:43.8542332Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:43.8543484Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:43.8544562Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:43.8545647Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:43.8546441Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:43.8547170Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:43.8547952Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:43.8548905Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:43.8549542Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:43.8549823Z
2024-07-03T12:01:50.9117999Z 2024-07-03 12:01:50,883 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:52.0201286Z 2024-07-03 12:01:52,005 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:52.0203036Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:52.0203666Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:52.0204219Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:52.0204932Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:52.0206096Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:52.0207138Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:52.0208085Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:52.0209159Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:52.0210065Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:52.0210750Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:52.0211554Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:52.0212338Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:52.0213082Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:52.0213707Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:52.0213991Z
2024-07-03T12:01:53.7325946Z 2024-07-03 12:01:53,731 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:01:54.9430262Z 2024-07-03 12:01:54,862 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:01:54.9432146Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:01:54.9432833Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:01:54.9433441Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:01:54.9434210Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:01:54.9435365Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:01:54.9436484Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:01:54.9437528Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:01:54.9438510Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:01:54.9439484Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:01:54.9440297Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:01:54.9441197Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:01:54.9442166Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:01:54.9443092Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:01:54.9443864Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:01:54.9444204Z
2024-07-03T12:02:01.1921464Z 2024-07-03 12:02:01,158 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:02.3040410Z 2024-07-03 12:02:02,287 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:02:02.3041920Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:02:02.3042486Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:02:02.3042994Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:02:02.3043606Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:02:02.3044550Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:02:02.3045511Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:02:02.3046370Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:02:02.3047155Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:02:02.3048114Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:02:02.3048766Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:02:02.3049467Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:02.3050318Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:02.3051070Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:02.3051679Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:02.3051962Z
2024-07-03T12:02:03.3112565Z 2024-07-03 12:02:03,260 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:04.4180696Z 2024-07-03 12:02:04,401 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:02:04.4182780Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:02:04.4183517Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:02:04.4184170Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:02:04.4185010Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:02:04.4186462Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:02:04.4187708Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:02:04.4188851Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:02:04.4189930Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:02:04.4191014Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:02:04.4191902Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:02:04.4192877Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:04.4193839Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:04.4194590Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:04.4195207Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:04.4195510Z
2024-07-03T12:02:07.9508597Z 2024-07-03 12:02:07,869 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:09.0654504Z 2024-07-03 12:02:08,992 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:02:09.0656816Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:02:09.0657642Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:02:09.0659668Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:02:09.0660989Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:02:09.0662439Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:02:09.0663682Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:02:09.0664835Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:02:09.0665908Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:02:09.0667194Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:02:09.0668078Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:02:09.0669068Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:09.0670220Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:09.0671274Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:09.0672142Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:09.0672444Z
2024-07-03T12:02:12.7966693Z 2024-07-03 12:02:12,741 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:13.9075366Z 2024-07-03 12:02:13,873 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:02:13.9077733Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:02:13.9078731Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:02:13.9079453Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:02:13.9080464Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:02:13.9081693Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:02:13.9082909Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:02:13.9083941Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:02:13.9084917Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:02:13.9085890Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:02:13.9086699Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:02:13.9087594Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:13.9088546Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:13.9089480Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:13.9090316Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:13.9090654Z
2024-07-03T12:02:16.1226248Z 2024-07-03 12:02:16,050 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:17.2310040Z 2024-07-03 12:02:17,178 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:02:17.2311924Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:02:17.2312601Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:02:17.2313208Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:02:17.2313975Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:02:17.2315217Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:02:17.2316351Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:02:17.2317379Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:02:17.2318362Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:02:17.2319348Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:02:17.2320326Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:02:17.2321216Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:17.2322198Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:17.2323221Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:17.2323994Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:17.2324528Z
2024-07-03T12:02:23.6959014Z 2024-07-03 12:02:23,641 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:24.8068466Z 2024-07-03 12:02:24,771 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:02:24.8070441Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:02:24.8071109Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:02:24.8071718Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:02:24.8072731Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:02:24.8073743Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:02:24.8074854Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:02:24.8075889Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:02:24.8076868Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:02:24.8077842Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:02:24.8078648Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:02:24.8079463Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:24.8080262Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:24.8081014Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:24.8081654Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:24.8081946Z
2024-07-03T12:02:25.3110862Z 2024-07-03 12:02:25,267 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:26.4197725Z 2024-07-03 12:02:26,395 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: getsockopt: localhost/127.0.0.1:5672
2024-07-03T12:02:26.4199471Z Caused by: java.net.ConnectException: Connection refused: getsockopt
2024-07-03T12:02:26.4200104Z at java.base/sun.nio.ch.Net.pollConnect(Native Method)
2024-07-03T12:02:26.4200666Z at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
2024-07-03T12:02:26.4201359Z at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
2024-07-03T12:02:26.4202398Z at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
2024-07-03T12:02:26.4203438Z at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
2024-07-03T12:02:26.4204404Z at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
2024-07-03T12:02:26.4205289Z at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
2024-07-03T12:02:26.4206193Z at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
2024-07-03T12:02:26.4206934Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
2024-07-03T12:02:26.4207920Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:26.4208756Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:26.4209505Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:26.4210194Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:26.4210476Z
2024-07-03T12:02:31.8683084Z 2024-07-03 12:02:31,803 INFO [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2024-07-03T12:02:32.4776631Z 2024-07-03 12:02:32,328 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted [Error Occurred After Shutdown]: java.lang.IllegalStateException: Client is closed
2024-07-03T12:02:32.4779335Z at io.vertx.core.net.impl.NetClientImpl.connectInternal(NetClientImpl.java:258)
2024-07-03T12:02:32.4780944Z at io.vertx.core.net.impl.NetClientImpl.lambda$null$4(NetClientImpl.java:320)
2024-07-03T12:02:32.4782540Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.handle(VertxImpl.java:1056)
2024-07-03T12:02:32.4783944Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.handle(VertxImpl.java:1027)
2024-07-03T12:02:32.4785198Z at io.vertx.core.impl.ContextImpl.emit(ContextImpl.java:328)
2024-07-03T12:02:32.4786240Z at io.vertx.core.impl.ContextImpl.emit(ContextImpl.java:321)
2024-07-03T12:02:32.4787344Z at io.vertx.core.impl.ContextInternal.emit(ContextInternal.java:209)
2024-07-03T12:02:32.4788566Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.run(VertxImpl.java:1045)
2024-07-03T12:02:32.4789858Z at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
2024-07-03T12:02:32.4791200Z at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153)
2024-07-03T12:02:32.4792901Z at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
2024-07-03T12:02:32.4794621Z at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
2024-07-03T12:02:32.4797686Z at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
2024-07-03T12:02:32.4799095Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
2024-07-03T12:02:32.4800430Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:32.4801826Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:32.4803495Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:32.4804608Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:32.4805102Z
2024-07-03T12:02:32.4807467Z 2024-07-03 12:02:32,330 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16216: Unable to recover from AMQP connection disruption [Error Occurred After Shutdown]: java.util.concurrent.RejectedExecutionException
2024-07-03T12:02:32.4809851Z at org.jboss.threads.RejectingExecutor.execute(RejectingExecutor.java:20)
2024-07-03T12:02:32.4811246Z at org.jboss.threads.EnhancedQueueExecutor.rejectShutdown(EnhancedQueueExecutor.java:2119)
2024-07-03T12:02:32.4812826Z at org.jboss.threads.EnhancedQueueExecutor$SchedulerTask.schedule(EnhancedQueueExecutor.java:3124)
2024-07-03T12:02:32.4814346Z at org.jboss.threads.EnhancedQueueExecutor.schedule(EnhancedQueueExecutor.java:919)
2024-07-03T12:02:32.4815921Z at io.smallrye.mutiny.operators.uni.UniDelayOnItem$UniDelayOnItemProcessor.onItem(UniDelayOnItem.java:54)
2024-07-03T12:02:32.4817894Z at io.smallrye.mutiny.operators.uni.builders.UniCreateFromKnownItem$KnownItemSubscription.forward(UniCreateFromKnownItem.java:38)
2024-07-03T12:02:32.4819979Z at io.smallrye.mutiny.operators.uni.builders.UniCreateFromKnownItem.subscribe(UniCreateFromKnownItem.java:23)
2024-07-03T12:02:32.4821561Z at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
2024-07-03T12:02:32.4823043Z at io.smallrye.mutiny.operators.uni.UniDelayOnItem.subscribe(UniDelayOnItem.java:28)
2024-07-03T12:02:32.4824488Z at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
2024-07-03T12:02:32.4826068Z at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.request(UniToMultiPublisher.java:74)
2024-07-03T12:02:32.4828683Z at io.smallrye.mutiny.operators.multi.MultiConcatMapOp$MainSubscriber.innerOnSubscribe(MultiConcatMapOp.java:109)
2024-07-03T12:02:32.4830647Z at io.smallrye.mutiny.operators.multi.MultiConcatMapOp$MainSubscriber$InnerSubscriber.onSubscribe(MultiConcatMapOp.java:297)
2024-07-03T12:02:32.4832488Z at io.smallrye.mutiny.converters.uni.UniToMultiPublisher.subscribe(UniToMultiPublisher.java:25)
2024-07-03T12:02:32.4834110Z at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:165)
2024-07-03T12:02:32.4836007Z at io.smallrye.mutiny.operators.multi.MultiConcatMapOp$MainSubscriber.onItem(MultiConcatMapOp.java:119)
2024-07-03T12:02:32.4837545Z at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
2024-07-03T12:02:32.4839238Z at io.smallrye.mutiny.operators.multi.processors.UnicastProcessor.drainWithDownstream(UnicastProcessor.java:108)
2024-07-03T12:02:32.4841094Z at io.smallrye.mutiny.operators.multi.processors.UnicastProcessor.drain(UnicastProcessor.java:139)
2024-07-03T12:02:32.4842818Z at io.smallrye.mutiny.operators.multi.processors.UnicastProcessor.onNext(UnicastProcessor.java:205)
2024-07-03T12:02:32.4844770Z at io.smallrye.mutiny.operators.multi.processors.SerializedProcessor.onNext(SerializedProcessor.java:104)
2024-07-03T12:02:32.4846476Z at io.smallrye.mutiny.subscription.SerializedSubscriber.onItem(SerializedSubscriber.java:74)
2024-07-03T12:02:32.4847939Z at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
2024-07-03T12:02:32.4849517Z at io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$RetryWhenOperator.onFailure(MultiRetryWhenOp.java:127)
2024-07-03T12:02:32.4851057Z at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73)
2024-07-03T12:02:32.4852722Z at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.onFailure(UniToMultiPublisher.java:104)
2024-07-03T12:02:32.4854742Z at io.smallrye.mutiny.operators.uni.UniOnItemConsume$UniOnItemComsumeProcessor.onFailure(UniOnItemConsume.java:55)
2024-07-03T12:02:32.4856467Z at io.smallrye.mutiny.operators.uni.UniOperatorProcessor.onFailure(UniOperatorProcessor.java:55)
2024-07-03T12:02:32.4858120Z at io.smallrye.mutiny.operators.uni.UniOperatorProcessor.onFailure(UniOperatorProcessor.java:55)
2024-07-03T12:02:32.4859604Z at io.smallrye.mutiny.vertx.AsyncResultUni.lambda$subscribe$1(AsyncResultUni.java:37)
2024-07-03T12:02:32.4861043Z at io.smallrye.mutiny.vertx.DelegatingHandler.handle(DelegatingHandler.java:25)
2024-07-03T12:02:32.4862289Z at io.vertx.core.impl.future.FutureImpl$4.onFailure(FutureImpl.java:188)
2024-07-03T12:02:32.4863548Z at io.vertx.core.impl.future.FutureImpl$ListenerArray.onFailure(FutureImpl.java:316)
2024-07-03T12:02:32.4864949Z at io.vertx.core.impl.future.FutureBase.emitFailure(FutureBase.java:81)
2024-07-03T12:02:32.4866101Z at io.vertx.core.impl.future.FutureImpl.tryFail(FutureImpl.java:278)
2024-07-03T12:02:32.4867025Z at io.vertx.core.Promise.fail(Promise.java:89)
2024-07-03T12:02:32.4868069Z at io.vertx.amqp.impl.AmqpConnectionImpl.lambda$connect$5(AmqpConnectionImpl.java:139)
2024-07-03T12:02:32.4869561Z at io.vertx.proton.impl.ProtonClientImpl$ConnectCompletionHandler.handle(ProtonClientImpl.java:123)
2024-07-03T12:02:32.4871133Z at io.vertx.proton.impl.ProtonClientImpl.lambda$connectNetClient$1(ProtonClientImpl.java:98)
2024-07-03T12:02:32.4872449Z at io.vertx.core.impl.future.FutureImpl$4.onFailure(FutureImpl.java:188)
2024-07-03T12:02:32.4873706Z at io.vertx.core.impl.future.FutureBase.emitFailure(FutureBase.java:81)
2024-07-03T12:02:32.4874960Z at io.vertx.core.impl.future.FutureImpl.tryFail(FutureImpl.java:278)
2024-07-03T12:02:32.4875860Z at io.vertx.core.Promise.fail(Promise.java:89)
2024-07-03T12:02:32.4876847Z at io.vertx.core.net.impl.NetClientImpl.connectInternal(NetClientImpl.java:258)
2024-07-03T12:02:32.4878179Z at io.vertx.core.net.impl.NetClientImpl.lambda$null$4(NetClientImpl.java:320)
2024-07-03T12:02:32.4879412Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.handle(VertxImpl.java:1056)
2024-07-03T12:02:32.4880660Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.handle(VertxImpl.java:1027)
2024-07-03T12:02:32.4881737Z at io.vertx.core.impl.ContextImpl.emit(ContextImpl.java:328)
2024-07-03T12:02:32.4882677Z at io.vertx.core.impl.ContextImpl.emit(ContextImpl.java:321)
2024-07-03T12:02:32.4883971Z at io.vertx.core.impl.ContextInternal.emit(ContextInternal.java:209)
2024-07-03T12:02:32.4885205Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.run(VertxImpl.java:1045)
2024-07-03T12:02:32.4886415Z at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
2024-07-03T12:02:32.4887628Z at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153)
2024-07-03T12:02:32.4889015Z at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
2024-07-03T12:02:32.4890534Z at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
2024-07-03T12:02:32.4892155Z at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
2024-07-03T12:02:32.4893525Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
2024-07-03T12:02:32.4894934Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:32.4896330Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:32.4897646Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:32.4898739Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:32.4899808Z Suppressed: java.util.concurrent.RejectedExecutionException: Executor is being shut down
2024-07-03T12:02:32.4901271Z at org.jboss.threads.EnhancedQueueExecutor.rejectShutdown(EnhancedQueueExecutor.java:2121)
2024-07-03T12:02:32.4902243Z ... 59 more
2024-07-03T12:02:32.4902445Z
2024-07-03T12:02:32.4904366Z 2024-07-03 12:02:32,331 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16225: Failure reported for channel `source`, closing client [Error Occurred After Shutdown]: java.util.concurrent.RejectedExecutionException
2024-07-03T12:02:32.4906670Z at org.jboss.threads.RejectingExecutor.execute(RejectingExecutor.java:20)
2024-07-03T12:02:32.4908000Z at org.jboss.threads.EnhancedQueueExecutor.rejectShutdown(EnhancedQueueExecutor.java:2119)
2024-07-03T12:02:32.4909549Z at org.jboss.threads.EnhancedQueueExecutor$SchedulerTask.schedule(EnhancedQueueExecutor.java:3124)
2024-07-03T12:02:32.4911022Z at org.jboss.threads.EnhancedQueueExecutor.schedule(EnhancedQueueExecutor.java:919)
2024-07-03T12:02:32.4912557Z at io.smallrye.mutiny.operators.uni.UniDelayOnItem$UniDelayOnItemProcessor.onItem(UniDelayOnItem.java:54)
2024-07-03T12:02:32.4914638Z at io.smallrye.mutiny.operators.uni.builders.UniCreateFromKnownItem$KnownItemSubscription.forward(UniCreateFromKnownItem.java:38)
2024-07-03T12:02:32.4916692Z at io.smallrye.mutiny.operators.uni.builders.UniCreateFromKnownItem.subscribe(UniCreateFromKnownItem.java:23)
2024-07-03T12:02:32.4918251Z at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
2024-07-03T12:02:32.4919542Z at io.smallrye.mutiny.operators.uni.UniDelayOnItem.subscribe(UniDelayOnItem.java:28)
2024-07-03T12:02:32.4920847Z at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
2024-07-03T12:02:32.4922399Z at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.request(UniToMultiPublisher.java:74)
2024-07-03T12:02:32.4924518Z at io.smallrye.mutiny.operators.multi.MultiConcatMapOp$MainSubscriber.innerOnSubscribe(MultiConcatMapOp.java:109)
2024-07-03T12:02:32.4926487Z at io.smallrye.mutiny.operators.multi.MultiConcatMapOp$MainSubscriber$InnerSubscriber.onSubscribe(MultiConcatMapOp.java:297)
2024-07-03T12:02:32.4928361Z at io.smallrye.mutiny.converters.uni.UniToMultiPublisher.subscribe(UniToMultiPublisher.java:25)
2024-07-03T12:02:32.4929740Z at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:165)
2024-07-03T12:02:32.4931142Z at io.smallrye.mutiny.operators.multi.MultiConcatMapOp$MainSubscriber.onItem(MultiConcatMapOp.java:119)
2024-07-03T12:02:32.4932644Z at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
2024-07-03T12:02:32.4934601Z at io.smallrye.mutiny.operators.multi.processors.UnicastProcessor.drainWithDownstream(UnicastProcessor.java:108)
2024-07-03T12:02:32.4936554Z at io.smallrye.mutiny.operators.multi.processors.UnicastProcessor.drain(UnicastProcessor.java:139)
2024-07-03T12:02:32.4938305Z at io.smallrye.mutiny.operators.multi.processors.UnicastProcessor.onNext(UnicastProcessor.java:205)
2024-07-03T12:02:32.4940076Z at io.smallrye.mutiny.operators.multi.processors.SerializedProcessor.onNext(SerializedProcessor.java:104)
2024-07-03T12:02:32.4941775Z at io.smallrye.mutiny.subscription.SerializedSubscriber.onItem(SerializedSubscriber.java:74)
2024-07-03T12:02:32.4943216Z at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
2024-07-03T12:02:32.4944793Z at io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$RetryWhenOperator.onFailure(MultiRetryWhenOp.java:127)
2024-07-03T12:02:32.4946481Z at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73)
2024-07-03T12:02:32.4948145Z at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.onFailure(UniToMultiPublisher.java:104)
2024-07-03T12:02:32.4950072Z at io.smallrye.mutiny.operators.uni.UniOnItemConsume$UniOnItemComsumeProcessor.onFailure(UniOnItemConsume.java:55)
2024-07-03T12:02:32.4951824Z at io.smallrye.mutiny.operators.uni.UniOperatorProcessor.onFailure(UniOperatorProcessor.java:55)
2024-07-03T12:02:32.4953441Z at io.smallrye.mutiny.operators.uni.UniOperatorProcessor.onFailure(UniOperatorProcessor.java:55)
2024-07-03T12:02:32.4955044Z at io.smallrye.mutiny.vertx.AsyncResultUni.lambda$subscribe$1(AsyncResultUni.java:37)
2024-07-03T12:02:32.4956365Z at io.smallrye.mutiny.vertx.DelegatingHandler.handle(DelegatingHandler.java:25)
2024-07-03T12:02:32.4957545Z at io.vertx.core.impl.future.FutureImpl$4.onFailure(FutureImpl.java:188)
2024-07-03T12:02:32.4958738Z at io.vertx.core.impl.future.FutureImpl$ListenerArray.onFailure(FutureImpl.java:316)
2024-07-03T12:02:32.4959958Z at io.vertx.core.impl.future.FutureBase.emitFailure(FutureBase.java:81)
2024-07-03T12:02:32.4961038Z at io.vertx.core.impl.future.FutureImpl.tryFail(FutureImpl.java:278)
2024-07-03T12:02:32.4961914Z at io.vertx.core.Promise.fail(Promise.java:89)
2024-07-03T12:02:32.4962921Z at io.vertx.amqp.impl.AmqpConnectionImpl.lambda$connect$5(AmqpConnectionImpl.java:139)
2024-07-03T12:02:32.4964387Z at io.vertx.proton.impl.ProtonClientImpl$ConnectCompletionHandler.handle(ProtonClientImpl.java:123)
2024-07-03T12:02:32.4966025Z at io.vertx.proton.impl.ProtonClientImpl.lambda$connectNetClient$1(ProtonClientImpl.java:98)
2024-07-03T12:02:32.4967338Z at io.vertx.core.impl.future.FutureImpl$4.onFailure(FutureImpl.java:188)
2024-07-03T12:02:32.4968474Z at io.vertx.core.impl.future.FutureBase.emitFailure(FutureBase.java:81)
2024-07-03T12:02:32.4969596Z at io.vertx.core.impl.future.FutureImpl.tryFail(FutureImpl.java:278)
2024-07-03T12:02:32.4970508Z at io.vertx.core.Promise.fail(Promise.java:89)
2024-07-03T12:02:32.4971504Z at io.vertx.core.net.impl.NetClientImpl.connectInternal(NetClientImpl.java:258)
2024-07-03T12:02:32.4972750Z at io.vertx.core.net.impl.NetClientImpl.lambda$null$4(NetClientImpl.java:320)
2024-07-03T12:02:32.4974084Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.handle(VertxImpl.java:1056)
2024-07-03T12:02:32.4975462Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.handle(VertxImpl.java:1027)
2024-07-03T12:02:32.4976539Z at io.vertx.core.impl.ContextImpl.emit(ContextImpl.java:328)
2024-07-03T12:02:32.4977566Z at io.vertx.core.impl.ContextImpl.emit(ContextImpl.java:321)
2024-07-03T12:02:32.4978569Z at io.vertx.core.impl.ContextInternal.emit(ContextInternal.java:209)
2024-07-03T12:02:32.4979697Z at io.vertx.core.impl.VertxImpl$InternalTimerHandler.run(VertxImpl.java:1045)
2024-07-03T12:02:32.4980860Z at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
2024-07-03T12:02:32.4982078Z at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153)
2024-07-03T12:02:32.4983581Z at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
2024-07-03T12:02:32.4985360Z at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
2024-07-03T12:02:32.4987175Z at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
2024-07-03T12:02:32.4988494Z at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
2024-07-03T12:02:32.4989779Z at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
2024-07-03T12:02:32.4991216Z at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
2024-07-03T12:02:32.4992623Z at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
2024-07-03T12:02:32.4993790Z at java.base/java.lang.Thread.run(Thread.java:840)
2024-07-03T12:02:32.4994705Z Suppressed: java.util.concurrent.RejectedExecutionException: Executor is being shut down
2024-07-03T12:02:32.4995938Z at org.jboss.threads.EnhancedQueueExecutor.rejectShutdown(EnhancedQueueExecutor.java:2121)
2024-07-03T12:02:32.4996530Z ... 59 more |
Status for workflow
|
Status for workflow
|
Status | Name | Step | Failures | Logs | Raw logs | Build scan |
---|---|---|---|---|---|---|
✔️ | JVM Tests - JDK 17 | Logs | Raw logs | 🚧 | ||
✔️ | JVM Tests - JDK 21 | Logs | Raw logs | 🚧 | ||
✔️ | JVM Tests - JDK 17 Windows | Failures | Logs | Raw logs | 🔍 |
Full information is available in the Build summary check run.
You can consult the Develocity build scans.
Failures
⚙️ JVM Tests - JDK 17 Windows #
- Failing: extensions/smallrye-reactive-messaging-amqp/deployment
! Skipped: integration-tests/reactive-messaging-amqp integration-tests/virtual-threads/amqp-virtual-threads
📦 extensions/smallrye-reactive-messaging-amqp/deployment
✖ io.quarkus.smallrye.reactivemessaging.amqp.AnonymousAmqpTest.test
line 30
- History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException: Condition with Lambda expression in io.quarkus.smallrye.reactivemessaging.amqp.AnonymousAmqpTest was not fulfilled within 1 minutes.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:78)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:26)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1006)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:975)
at io.quarkus.smallrye.reactivemessaging.amqp.AnonymousAmqpTest.test(AnonymousAmqpTest.java:30)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
✖ io.quarkus.smallrye.reactivemessaging.amqp.SecuredAmqpTest.test
line 28
- History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException: Condition with Lambda expression in io.quarkus.smallrye.reactivemessaging.amqp.SecuredAmqpTest was not fulfilled within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:78)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:26)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1006)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:975)
at io.quarkus.smallrye.reactivemessaging.amqp.SecuredAmqpTest.test(SecuredAmqpTest.java:28)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
✖ io.quarkus.smallrye.reactivemessaging.amqp.devmode.AmqpDevModeTest.testCodeUpdate
line 44
- History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException: Condition with Lambda expression in io.quarkus.smallrye.reactivemessaging.amqp.devmode.AmqpDevModeTest was not fulfilled within 1 minutes.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:78)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:26)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1006)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:975)
at io.quarkus.smallrye.reactivemessaging.amqp.devmode.AmqpDevModeTest.testCodeUpdate(AmqpDevModeTest.java:44)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
✖ io.quarkus.smallrye.reactivemessaging.amqp.devmode.nohttp.AmqpDevModeNoHttpTest.testConsumerUpdate
line 77
- History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException:
Assertion condition defined as a Lambda expression in io.quarkus.smallrye.reactivemessaging.amqp.devmode.nohttp.AmqpDevModeNoHttpTest
Expecting size of:
[]
to be greater than or equal to 5 but was 0 within 1 minutes.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
✖ io.quarkus.smallrye.reactivemessaging.amqp.devmode.nohttp.AmqpDevModeNoHttpTest.testProducerUpdate
line 48
- History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException:
Assertion condition defined as a Lambda expression in io.quarkus.smallrye.reactivemessaging.amqp.devmode.nohttp.AmqpDevModeNoHttpTest
Expecting size of:
[]
to be greater than or equal to 5 but was 0 within 1 minutes.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
Flaky tests - Develocity
⚙️ Maven Tests - JDK 17 Windows
📦 integration-tests/maven
✖ io.quarkus.maven.it.TestMojoIT.testThatTheTestsAreReRunMultiModule
- History
Condition with Lambda expression in io.quarkus.maven.it.continuoustesting.TestModeContinuousTestingMavenTestUtils was not fulfilled within 3 minutes.
-org.awaitility.core.ConditionTimeoutException
org.awaitility.core.ConditionTimeoutException: Condition with Lambda expression in io.quarkus.maven.it.continuoustesting.TestModeContinuousTestingMavenTestUtils was not fulfilled within 3 minutes.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:78)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:26)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1006)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:975)
at io.quarkus.maven.it.continuoustesting.TestModeContinuousTestingMavenTestUtils.waitForNextCompletion(TestModeContinuousTestingMavenTestUtils.java:50)
at io.quarkus.maven.it.LaunchMojoTestBase.testThatTheTestsAreReRunMultiModule(LaunchMojoTestBase.java:56)
✖ io.quarkus.maven.it.TestMojoIT.testThatTheTestsAreReRunMultiModule
- History
Condition with Lambda expression in io.quarkus.maven.it.continuoustesting.TestModeContinuousTestingMavenTestUtils was not fulfilled within 3 minutes.
-org.awaitility.core.ConditionTimeoutException
org.awaitility.core.ConditionTimeoutException: Condition with Lambda expression in io.quarkus.maven.it.continuoustesting.TestModeContinuousTestingMavenTestUtils was not fulfilled within 3 minutes.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:78)
at org.awaitility.core.CallableCondition.await(CallableCondition.java:26)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1006)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:975)
at io.quarkus.maven.it.continuoustesting.TestModeContinuousTestingMavenTestUtils.waitForNextCompletion(TestModeContinuousTestingMavenTestUtils.java:50)
at io.quarkus.maven.it.LaunchMojoTestBase.testThatTheTestsAreReRunMultiModule(LaunchMojoTestBase.java:56)
⚙️ Native Tests - Messaging1
📦 integration-tests/reactive-messaging-kafka
✖ io.quarkus.it.kafka.KafkaConnectorIT.testRequestReply
- History
iterable contents differ at index [3], expected: <reply-4> but was: <{"details":"Error id 96b7d4dc-f0e5-4a39-a80b-ffddbca17186-1","stack":""}>
-org.opentest4j.AssertionFailedError
org.opentest4j.AssertionFailedError: iterable contents differ at index [3], expected: <reply-4> but was: <{"details":"Error id 96b7d4dc-f0e5-4a39-a80b-ffddbca17186-1","stack":""}>
at io.quarkus.it.kafka.KafkaConnectorTest.testRequestReply(KafkaConnectorTest.java:111)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at io.quarkus.test.junit.QuarkusTestExtension.interceptTestMethod(QuarkusTestExtension.java:812)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
iterable contents differ at index [0], expected: <reply-1> but was: <{"details":"Error id 96b7d4dc-f0e5-4a39-a80b-ffddbca17186-1","stack":""}>
-org.opentest4j.AssertionFailedError
org.opentest4j.AssertionFailedError: iterable contents differ at index [0], expected: <reply-1> but was: <{"details":"Error id 96b7d4dc-f0e5-4a39-a80b-ffddbca17186-1","stack":""}>
at io.quarkus.it.kafka.KafkaConnectorTest.testRequestReply(KafkaConnectorTest.java:111)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at io.quarkus.test.junit.QuarkusTestExtension.interceptTestMethod(QuarkusTestExtension.java:812)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
@cescoffier can this be merged with 3.12 also ? |
No, there are breaking changes that we cannot backport. |
Thanks for quick response @cescoffier … Will this be included with next patch (3.12.3) version or next minor (3.13.x) release ? |
It will be in |
Thank you @geoand :) |
Update to gRPC 1.65.0 and Netty 4.1.111
This commit updates the gRPC version to 1.65.0 and enables the switch to Netty 4.1.111. Additionally, it updates several gRPC-related dependencies:
Disable Stork "least response time" IT when using the gRPC Java client. This is because, in gRPC 1.65.0, the load balancer is only called once if the calls are queued. The Vert.x-based client is still behaving normally. When using the gRPC Java client, there is a change in behavior, but the load balancer will still be called for non-concurrent calls.