Skip to content
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

Merged
merged 1 commit into from
Jul 4, 2024

Conversation

cescoffier
Copy link
Member

@cescoffier cescoffier commented Jul 1, 2024

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:

  • 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 the gRPC Java client, there is a change in behavior, but the load balancer will still be called for non-concurrent calls.

@quarkus-bot quarkus-bot bot added area/dependencies Pull requests that update a dependency file area/grpc gRPC area/netty labels Jul 1, 2024
@geoand geoand added the triage/waiting-for-ci Ready to merge when CI successfully finishes label Jul 1, 2024

This comment has been minimized.

@geoand
Copy link
Contributor

geoand commented Jul 1, 2024

gRPC is giving us trouble...

@cescoffier
Copy link
Member Author

Yeah, will have a look. They likely changed the mechanism

@cescoffier cescoffier force-pushed the grpc-1.65.0-netty.4.1.111 branch from e22d298 to 49b85f2 Compare July 2, 2024 07:08
@cescoffier
Copy link
Member Author

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.

@geoand
Copy link
Contributor

geoand commented Jul 2, 2024

:(

This comment has been minimized.

This comment has been minimized.

Copy link

github-actions bot commented Jul 2, 2024

🙈 The PR is closed and the preview is expired.

This comment has been minimized.

This comment has been minimized.

@cescoffier
Copy link
Member Author

These opentelemetry test failures might be related.

@geoand
Copy link
Contributor

geoand commented Jul 3, 2024

The same tests have been failing in other PRs as well, so let's hold off until we find the cause

@geoand
Copy link
Contributor

geoand commented Jul 3, 2024

Rebasing onto main might actually do the trick

@cescoffier
Copy link
Member Author

Hum, I've another PR totally unrelated with the same set of failures.

@geoand
Copy link
Contributor

geoand commented Jul 3, 2024

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.
@cescoffier cescoffier force-pushed the grpc-1.65.0-netty.4.1.111 branch from f73aeea to 2891ca4 Compare July 3, 2024 08:29

This comment has been minimized.

@geoand
Copy link
Contributor

geoand commented Jul 3, 2024

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

Copy link

quarkus-bot bot commented Jul 3, 2024

Status for workflow Quarkus Documentation CI

This is the status report for running Quarkus Documentation CI on commit 2891ca4.

✅ The latest workflow run for the pull request has completed successfully.

It should be safe to merge provided you have a look at the other checks in the summary.

@gsmet gsmet merged commit e9d6790 into quarkusio:main Jul 4, 2024
55 checks passed
@quarkus-bot quarkus-bot bot added this to the 3.13 - main milestone Jul 4, 2024
@quarkus-bot quarkus-bot bot removed the triage/waiting-for-ci Ready to merge when CI successfully finishes label Jul 4, 2024
Copy link

quarkus-bot bot commented Jul 4, 2024

Status for workflow Quarkus CI

This is the status report for running Quarkus CI on commit 2891ca4.

Failing Jobs

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 cescoffier deleted the grpc-1.65.0-netty.4.1.111 branch July 5, 2024 12:52
@sivareddyp
Copy link

@cescoffier can this be merged with 3.12 also ?

@cescoffier
Copy link
Member Author

No, there are breaking changes that we cannot backport.

@sivareddyp
Copy link

sivareddyp commented Jul 12, 2024

Thanks for quick response @cescoffier
Which version of quarkus contains netty 4.1.111.Final ?

Will this be included with next patch (3.12.3) version or next minor (3.13.x) release ?

@geoand
Copy link
Contributor

geoand commented Jul 12, 2024

It will be in 3.13

@sivareddyp
Copy link

Thank you @geoand :)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
Development

Successfully merging this pull request may close these issues.

4 participants