search

ribasco / async-gamequery-lib

A high-performance java game query library designed for steam/source based games and others
https://ribasco.github.io/async-gamequery-lib/
Apache License 2.0
125 stars 27 forks source link

bug: reading the rules of a V Rising server sometimes fails #230

Open DarkAtra opened 2 months ago

DarkAtra commented 2 months ago

Hello, i'm the maintainer of the v-rising-discord-bot and just received two reports where users of my bot ran into timeout issues. A closer look revealed that the rules query was causing the timeout while all other queries (playerlist and server info) succeeded as expected.

This is one of the servers in question: https://www.battlemetrics.com/servers/vrising/27556679 I've added a reproducer here: https://github.com/DarkAtra/v-rising-discord-bot/blob/6b7038d1f525d6e3433a69e50d0ddd09fe75fcb6/src/main/kotlin/de/darkatra/vrising/discord/clients/serverquery/ServerQueryClient.kt#L47-L54

MandoDB commented 2 months ago

Hi, im the server owner for La Station, I autorize him for using my server ip/query port for testing. But dont crash my server

DarkAtra commented 2 months ago

hey @ribasco, any chance you could have a look at it?

DarkAtra commented 2 months ago

Just so that we have logs in case the linked server no longer exists:

Logs

``` 23:10:59.250 [main] DEBUG com.ibasco.agql.core.util.Platform -- PLATFORM => Initializing global thread pool (Pool Size: 13, Max Pool Size: 2147483647, Keep Alive Time (ms): 9223372036854775807) 23:10:59.281 [main] DEBUG com.ibasco.agql.core.util.Platform -- PLATFORM => Registered global shutdown hook for shared executor service(s) 23:10:59.281 [main] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryClient -- [1695895624] CLIENT => Initialzied new client 'SourceQueryClient' with ID '1814696519' 23:10:59.286 [main] DEBUG com.ibasco.agql.core.util.Option -- Consolidating options for 'SourceQueryOptions' (Size: 30) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_CIRCBREAKER_DELAY : 1000 (failsafeCircuitBreakerDelay) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_CIRCBREAKER_ENABLED : true (failsafeCircuitBreakerEnabled) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLD : 13 (failsafeCircuitBreakerFailureThreshold) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLDING_CAP : 26 (failsafeCircuitBreakerFailureThresholdingCapacity) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_CIRCBREAKER_SUCCESS_THRESHOLD : 1 (failsafeCircuitBreakerSuccessThreshold) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_ENABLED : true (failsafeEnabled) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RATELIMIT_ENABLED : true (failsafeRateLimitEnabled) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RATELIMIT_MAX_EXEC : 650 (failsafeRateLimitMaxExec) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RATELIMIT_MAX_WAIT_TIME : 10000 (failsafeRateLimitMaxWaitTime) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RATELIMIT_PERIOD : 5000 (failsafeRateLimitPeriod) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RATELIMIT_TYPE : SMOOTH (failsafeRateLimitType) 23:10:59.300 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RETRY_BACKOFF_DELAY : 50 (failsafeRetryBackoffDelay) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RETRY_BACKOFF_DELAY_FACTOR : 1.5 (failsafeRetryBackoffDelayFactor) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RETRY_BACKOFF_ENABLED : false (failsafeRetryBackoffEnabled) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RETRY_BACKOFF_MAX_DELAY : 5000 (failsafeRetryBackoffMaxDelay) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RETRY_DELAY : 1000 (failsafeRetryDelay) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RETRY_ENABLED : true (failsafeRetryRetryEnabled) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] ConnectOptions => FAILSAFE_RETRY_MAX_ATTEMPTS : 5 (failsafeRetryMaxAttempts) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_CIRCBREAKER_DELAY : 1000 (failsafeCircuitBreakerDelay) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_CIRCBREAKER_ENABLED : true (failsafeCircuitBreakerEnabled) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLD : 3 (failsafeCircuitBreakerFailureThreshold) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLDING_CAP : 5 (failsafeCircuitBreakerFailureThresholdingCapacity) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_CIRCBREAKER_SUCCESS_THRESHOLD : 1 (failsafeCircuitBreakerSuccessThreshold) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_ENABLED : true (failsafeEnabled) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RATELIMIT_ENABLED : false (failsafeRateLimitEnabled) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RATELIMIT_MAX_EXEC : 650 (failsafeRateLimitMaxExec) 23:10:59.301 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RATELIMIT_MAX_WAIT_TIME : 10000 (failsafeRateLimitMaxWaitTime) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RATELIMIT_PERIOD : 5000 (failsafeRateLimitPeriod) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RATELIMIT_TYPE : SMOOTH (failsafeRateLimitType) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RETRY_BACKOFF_DELAY : 50 (failsafeRetryBackoffDelay) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RETRY_BACKOFF_DELAY_FACTOR : 1.5 (failsafeRetryBackoffDelayFactor) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RETRY_BACKOFF_ENABLED : false (failsafeRetryBackoffEnabled) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RETRY_BACKOFF_MAX_DELAY : 5000 (failsafeRetryBackoffMaxDelay) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RETRY_DELAY : 1000 (failsafeRetryDelay) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RETRY_ENABLED : true (failsafeRetryRetryEnabled) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] FailsafeOptions => FAILSAFE_RETRY_MAX_ATTEMPTS : 5 (failsafeRetryMaxAttempts) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] GeneralOptions => CONNECTION_POOLING : true (globalPooling ) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] GeneralOptions => POOL_MAX_CONNECTIONS : 13 (globalMaxPooledConnections) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] GeneralOptions => POOL_TYPE : ADAPTIVE (globalPoolType ) 23:10:59.302 [main] INFO com.ibasco.agql.core.util.Option -- [SourceQueryMessenger] GeneralOptions => READ_TIMEOUT : 5000 (globalReadTimeOut) 23:10:59.333 [main] DEBUG com.ibasco.agql.core.util.Platform -- [UTIL] CHANNEL_CLASS => Falling back to java NIO transport 23:10:59.335 [main] DEBUG com.ibasco.agql.core.util.Platform -- getOrCreateEventLoopGroup(): Creating new Event Loop Group instance for executor service 'java.util.concurrent.ThreadPoolExecutor@10959ece[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]' (Num of Threads: 13, Use Native: true) 23:10:59.349 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (556281560) 23:10:59.349 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (1205445235) 23:10:59.349 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (1267655902) 23:10:59.349 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (670663110) 23:10:59.349 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (454104863) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (290579508) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (767904468) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (1180244251) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (1432569632) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (1259174396) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (1276709283) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (1116094714) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- Creating new task queue: io.netty.util.internal.shaded.org.jctools.queues.MpscUnboundedArrayQueue (227755469) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.util.Platform -- createEventLoopGroup(): Created event loop group with: 13 threads (Executor Service: java.util.concurrent.ThreadPoolExecutor@10959ece[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]) 23:10:59.350 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- CHANNEL_FACTORY (INIT) => Channel Class 'class io.netty.channel.socket.nio.NioDatagramChannel' 23:10:59.350 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- CHANNEL_FACTORY (INIT) => Executor Service: 'java.util.concurrent.ThreadPoolExecutor@10959ece[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]' 23:10:59.350 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- CHANNEL_FACTORY (INIT) => Event Loop Group: 'io.netty.channel.nio.NioEventLoopGroup@5a45133e' (Event Loop Threads: 13) 23:10:59.351 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => Initializing Bootstrap 23:10:59.352 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => Channel Class 'NioDatagramChannel' 23:10:59.352 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => Channel Factory: 'com.ibasco.agql.core.transport.AbstractNettyChannelFactory$1@5824a83d' 23:10:59.352 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] Using a receive buffer allocator type of 'FIXED' 23:10:59.352 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] Fixed Allocator Parameters (Size: 9216) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- =================================================================================================================== 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => Default Channel Options 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- =================================================================================================================== 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (1) Channel Option: 'SO_SNDBUF' (Value: 1048576) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (2) Channel Option: 'WRITE_BUFFER_WATER_MARK' (Value: WriteBufferWaterMark(low: 32768, high: 65536)) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (3) Channel Option: 'ALLOCATOR' (Value: PooledByteBufAllocator(directByDefault: true)) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (4) Channel Option: 'SO_RCVBUF' (Value: 1048576) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (5) Channel Option: 'RCVBUF_ALLOCATOR' (Value: io.netty.channel.FixedRecvByteBufAllocator@402c4085) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (6) Channel Option: 'CONNECT_TIMEOUT_MILLIS' (Value: 3000) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (7) Channel Option: 'AUTO_READ' (Value: true) 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- =================================================================================================================== 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => Auto initializing channel attributes whose autoCreate flag is set 23:10:59.367 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- =================================================================================================================== 23:10:59.368 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (1) Attribute: 'globalWriteTimeout' (Default Value: 5000) 23:10:59.369 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (2) Attribute: 'globalReadTimeOut' (Default Value: 5000) 23:10:59.369 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- =================================================================================================================== 23:10:59.369 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => Populating default channel attributes (explicitly set by client/messenger) 23:10:59.369 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- =================================================================================================================== 23:10:59.369 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => (1) Attribute: 'globalReadTimeOut' = '5000' (Default: 5000) 23:10:59.369 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- =================================================================================================================== 23:10:59.369 [main] DEBUG com.ibasco.agql.core.transport.AbstractNettyChannelFactory -- [INIT] TRANSPORT (BOOTSTRAP) => Successfully Initialized Bootstrap (Event Loop Group: 'NioEventLoopGroup', Channel Class: 'NioDatagramChannel', Default Channel Handler: 'com.ibasco.agql.core.transport.NettyChannelInitializer@451001e5') 23:10:59.379 [main] DEBUG com.ibasco.agql.core.transport.pool.DefaultNettyChannelPoolFactoryProvider -- POOL_FACTORY_PROVIDER => Created channel pool factory: com.ibasco.agql.core.transport.pool.SimpleNettyChannelPoolFactory@169bb4dd (Pool Type: ADAPTIVE) 23:10:59.379 [main] DEBUG com.ibasco.agql.core.transport.pool.NettyPooledChannelFactory -- [INIT] POOL => Using channel pool factory 'com.ibasco.agql.core.transport.pool.SimpleNettyChannelPoolFactory@169bb4dd' 23:10:59.380 [main] DEBUG com.ibasco.agql.core.transport.pool.NettyPooledChannelFactory -- [INIT] POOL => Using channel pool map 'com.ibasco.agql.core.transport.pool.MessageChannelPoolMap@2d0399f4' 23:10:59.381 [main] DEBUG com.ibasco.agql.core.NettyTransport -- [INIT] TRANSPORT => Set ResourceLeakDetector level to 'PARANOID' 23:10:59.381 [main] DEBUG com.ibasco.agql.core.AbstractClient -- [REQ:EWN1YTF0SOU] SEND => Sending request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' to '/185.200.246.67:9877' for messenger 'SourceQueryMessenger' (Executor: io.netty.channel.nio.NioEventLoopGroup@5a45133e) 23:10:59.393 [agql-el-1-1] DEBUG com.ibasco.agql.core.transport.pool.SimpleNettyChannelPoolFactory -- [INIT] POOL => Initialized SimpleNettyChannelPool (Address: /185.200.246.67:9877, Instance: SimpleNettyChannelPool#1074191793) 23:10:59.393 [agql-el-1-1] DEBUG com.ibasco.agql.core.transport.pool.NettyPooledChannelFactory -- [POOL] Acquiring channel for address '/185.200.246.67:9877' (Channel Pool: com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1, Pool Size: 0) 23:10:59.394 [agql-el-1-2] DEBUG com.ibasco.agql.core.transport.FailsafeChannelFactory -- CHANNEL_FACTORY (FailsafeChannelFactory) => Acquiring channel for address '/185.200.246.67:9877' (Supplier: com.ibasco.agql.core.transport.FailsafeChannelFactory$ChannelSupplier@461835e, Attempt: 0, Executions: 0, Last Result: null, Last Failure: null) 23:10:59.419 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5] HANDLER => Channel Created 23:10:59.420 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryChannelFactory -- INIT => Registering Source Query INBOUND Handlers 23:10:59.425 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryChannelFactory -- INIT => Registering Source Query OUTBOUND Handlers 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] HANDLER => Channel is not pooled. Registering timeout handlers 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.util.Netty -- [980963a5] TRANSPORT => Registered READ/WRITE Timeout Handlers 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] ======================================================================================================================================================== 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] Initializing handlers for channel '980963a5' (Pooled: NO) 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] ======================================================================================================================================================== 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : initializer = com.ibasco.agql.core.transport.NettyChannelInitializer@451001e5 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : DefaultChannelPoolHandler$1#0 = com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler$1@907c8fa 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : responseDecoder = com.ibasco.agql.core.transport.handlers.MessageDecoder@750cbc 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : SourceQueryPacketDecoder#0 = com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQueryPacketDecoder@66c91854 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : SourceQuerySplitPacketAssembler#0 = com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler@1aac27d3 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : SourceQueryChallengeDecoder#0 = com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeDecoder@2ddb7c64 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : SourceQueryInfoDecoder#0 = com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoDecoder@563858f 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : SourceQueryPlayersDecoder#0 = com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersDecoder@2bc626cf 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] INBOUND : SourceQueryRulesDecoder#0 = com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesDecoder@502f0edb 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] BOTH : messageRouter = com.ibasco.agql.core.transport.handlers.MessageRouter@26e160e6 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] OUTBOUND: SourceQueryRulesEncoder#0 = com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder@3f37c648 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] OUTBOUND: SourceQueryPlayersEncoder#0 = com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersEncoder@25dd6f3f 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] OUTBOUND: SourceQueryInfoEncoder#0 = com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoEncoder@dace489 23:10:59.427 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] OUTBOUND: SourceQueryChallengeEncoder#0 = com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeEncoder@20e7538a 23:10:59.428 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] OUTBOUND: requestEncoder = com.ibasco.agql.core.transport.handlers.MessageEncoder@2163c458 23:10:59.428 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] OUTBOUND: writeTimeout = com.ibasco.agql.core.transport.handlers.WriteTimeoutHandler@6f09f3dc 23:10:59.428 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyChannelInitializer -- [980963a5] ======================================================================================================================================================== 23:10:59.431 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5] HANDLER => Channel Acquired. (Local Address: '0:0:0:0:0:0:0:0', Remote Address: 'N/A') (POOLED) 23:10:59.431 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5] (SourceQuerySplitPacketAssembler) INB => Channel acquired. Creating new assembler for channel '[id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' 23:10:59.432 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyContextChannelFactory -- [980963a5] CHANNEL_FACTORY (NettyContextChannelFactory) => Initializing NEW context for channel '(POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' with envelope '/185.200.246.67:9877' (Event Loop: agql-el-1-3) 23:10:59.432 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5] CONTEXT => Initializing context properties for channel '(POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' (Local: /[0:0:0:0:0:0:0:0]:62191, Remote: null) 23:10:59.432 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5] CONTEXT => Attached auto-release listener 23:10:59.432 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyContextChannelFactory -- [980963a5] CHANNEL_FACTORY => Updating context address for channel '(POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' -> /185.200.246.67:9877 23:10:59.433 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5] Acquired context (request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:10:59.433 [rate-limiter-3-1] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Preparing context for transport (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:10:59.434 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Sending request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' to transport 23:10:59.434 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Intercepted request of type 'MessageEnvelope' (Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877) 23:10:59.435 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:10:59.435 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:10:59.435 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:10:59.435 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => ACCEPTED message 'MessageEnvelope' 23:10:59.442 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Encoding query request 'SourceQueryRulesRequest' to DatagramPacket (9 bytes): 0xFF 0xFF 0xFF 0xFF 0x56 0xFF 0xFF 0xFF 0xFF 23:10:59.442 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Writing message 'DatagramPacket(=> /185.200.246.67:9877, AdvancedLeakAwareByteBuf(PooledUnsafeDirectByteBuf(ridx: 0, widx: 9, cap: 9)))' to transport (Request Id: EWN1YTF0SOU, Type: SourceQueryRulesRequest) 23:10:59.444 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Registered ReadTimeoutHandler (Read Timeout: 5000 ms) 23:10:59.444 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Request has been sent and processed through the channel's pipeline (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:10:59.525 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageDecoder -- [980963a5 : EWN1YTF0SOU] INB => Received incoming data from server of type: DatagramPacket (765185466) (Length: 9 bytes) 23:10:59.525 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageDecoder -- [980963a5 : EWN1YTF0SOU] INB => Passing decoded message (AdvancedLeakAwareByteBuf) to the next handler(s) 23:10:59.525 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageDecoder -- [980963a5 : EWN1YTF0SOU] INB => Data Dump for 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| ff ff ff ff 41 0e 3e 82 46 |....A.>.F | +--------+-------------------------------------------------+----------------+ 23:10:59.526 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQueryPacketDecoder -- [980963a5 : EWN1YTF0SOU] INB => DECODED 'AdvancedLeakAwareByteBuf' into "'SourceQuerySinglePacket' Header: 0x41 0x00 0x00 0x00 (65)" 23:10:59.526 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => REJECTED 'SourceQuerySinglePacket' 23:10:59.526 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryChallengeDecoder) INB => REJECTED message of type 'SourceQuerySinglePacket' (Reason: Rejected by the concrete handler) 23:10:59.526 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryInfoDecoder) INB => Rejected message 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' with response header '65' (Expected request: class com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoRequest, Expected response header: 73) 23:10:59.526 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryInfoDecoder) INB => REJECTED message of type 'SourceQuerySinglePacket' (Reason: Rejected by the concrete handler) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryPlayersDecoder) INB => Rejected message 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' with response header '65' (Expected request: class com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayerRequest, Expected response header: 68) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryPlayersDecoder) INB => REJECTED message of type 'SourceQuerySinglePacket' (Reason: Rejected by the concrete handler) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryRulesDecoder) INB => Accepted message 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' with response header '65' (Expected request: class com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesRequest, Expected response header: 69) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryRulesDecoder) INB => ACCEPTED message of type 'SourceQuerySinglePacket' 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryRulesDecoder) INB => Got challenge response: 1182940686 (0x0E 0x3E 0x82 0x46) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryRulesDecoder) INB => Resending 'SourceQueryRulesRequest' request with challenge (Challenge: 1182940686 (0x0E 0x3E 0x82 0x46), Destination: /185.200.246.67:9877) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Intercepted request of type 'MessageEnvelope' (Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => ACCEPTED message 'MessageEnvelope' 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Encoding query request 'SourceQueryRulesRequest' to DatagramPacket (9 bytes): 0xFF 0xFF 0xFF 0xFF 0x56 0x0E 0x3E 0x82 0x46 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Writing message 'DatagramPacket(=> /185.200.246.67:9877, AdvancedLeakAwareByteBuf(PooledUnsafeDirectByteBuf(ridx: 0, widx: 9, cap: 9)))' to transport (Request Id: EWN1YTF0SOU, Type: SourceQueryRulesRequest) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Registered ReadTimeoutHandler (Read Timeout: 5000 ms) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryRulesDecoder) INB => Successfully sent re-auth request to the pipline: Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryRulesDecoder) INB => Releasing reference counted message 'SourceQuerySinglePacket' (Decoded message: null) 23:10:59.527 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageInboundHandler -- [980963a5 : EWN1YTF0SOU] (SourceQueryRulesDecoder) INB => No decoded message received. Do not propagate. 23:10:59.528 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Read Complete 23:10:59.528 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (INBOUND) => Read Complete 23:11:04.530 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler -- [980963a5 : EWN1YTF0SOU] INB => Firing ReadTimeoutException (Time: 5000 ms) 23:11:04.531 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (ERROR) => Type: ReadTimeoutException, Message: N/A (Channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191], Pooled: true) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:04.532 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Received response for request 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877' (Error: ReadTimeoutException) 23:11:04.532 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => [ERROR] Received response in error (Request: 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877', Error: ReadTimeoutException) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:04.534 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Skipping auto release 23:11:05.535 [agql-el-1-4] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Retrying request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' for server address '/185.200.246.67:9877'. Closing existing context. 23:11:05.539 [agql-el-1-4] DEBUG com.ibasco.agql.core.transport.pool.NettyPooledChannelFactory -- [POOL] Acquiring channel for address '/185.200.246.67:9877' (Channel Pool: com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1, Pool Size: 1) 23:11:05.539 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Released (Active: true, Open: true, Registered: true) 23:11:05.539 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Removed READ/WRITE Timeout Handlers 23:11:05.539 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel closed. Forcing reset of assembler 23:11:05.539 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.packets.util.SourceLazySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] ASSEMBLER => Successfully reset assembler 23:11:05.539 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT (RELEASE) => Context released (Pooled) 23:11:05.540 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Acquired. (Local Address: '0:0:0:0:0:0:0:0', Remote Address: 'N/A') (POOLED) 23:11:05.540 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel acquired. Creating new assembler for channel '[id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' 23:11:05.541 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyContextChannelFactory -- [980963a5 : EWN1YTF0SOU] CHANNEL_FACTORY (NettyContextChannelFactory) => Initializing EXISTING context for channel '[980963a5 : EWN1YTF0SOU]' to '/185.200.246.67:9877' (Response Promise: java.util.concurrent.CompletableFuture@228ca01a[Completed exceptionally: com.ibasco.agql.core.exceptions.ReadTimeoutException]) 23:11:05.541 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Acquired context (request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:05.541 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool -- [com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1] Acquired an existing healthy channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191] for address '/185.200.246.67:9877' (Local: /[0:0:0:0:0:0:0:0]:62191, Active: true) 23:11:05.541 [rate-limiter-3-1] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Preparing context for transport (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:05.541 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Local address not updated for envelope Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Resetting response promise for request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Resetting context properties (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Attached auto-release listener 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Sending request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' to transport 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Intercepted request of type 'MessageEnvelope' (Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877) 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:05.542 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => ACCEPTED message 'MessageEnvelope' 23:11:05.543 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Encoding query request 'SourceQueryRulesRequest' to DatagramPacket (9 bytes): 0xFF 0xFF 0xFF 0xFF 0x56 0x0E 0x3E 0x82 0x46 23:11:05.543 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Writing message 'DatagramPacket(=> /185.200.246.67:9877, AdvancedLeakAwareByteBuf(PooledUnsafeDirectByteBuf(ridx: 0, widx: 9, cap: 9)))' to transport (Request Id: EWN1YTF0SOU, Type: SourceQueryRulesRequest) 23:11:05.544 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Registered ReadTimeoutHandler (Read Timeout: 5000 ms) 23:11:05.544 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Request has been sent and processed through the channel's pipeline (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:10.546 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler -- [980963a5 : EWN1YTF0SOU] INB => Firing ReadTimeoutException (Time: 5000 ms) 23:11:10.546 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (ERROR) => Type: ReadTimeoutException, Message: N/A (Channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191], Pooled: true) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:10.547 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Received response for request 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877' (Error: ReadTimeoutException) 23:11:10.547 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => [ERROR] Received response in error (Request: 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877', Error: ReadTimeoutException) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:10.548 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Skipping auto release 23:11:11.550 [agql-el-1-5] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Retrying request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' for server address '/185.200.246.67:9877'. Closing existing context. 23:11:11.551 [agql-el-1-5] DEBUG com.ibasco.agql.core.transport.pool.NettyPooledChannelFactory -- [POOL] Acquiring channel for address '/185.200.246.67:9877' (Channel Pool: com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1, Pool Size: 0) 23:11:11.551 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Released (Active: true, Open: true, Registered: true) 23:11:11.551 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Removed READ/WRITE Timeout Handlers 23:11:11.551 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel closed. Forcing reset of assembler 23:11:11.551 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.packets.util.SourceLazySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] ASSEMBLER => Successfully reset assembler 23:11:11.552 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT (RELEASE) => Context released (Pooled) 23:11:11.552 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Acquired. (Local Address: '0:0:0:0:0:0:0:0', Remote Address: 'N/A') (POOLED) 23:11:11.552 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel acquired. Creating new assembler for channel '[id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' 23:11:11.552 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyContextChannelFactory -- [980963a5 : EWN1YTF0SOU] CHANNEL_FACTORY (NettyContextChannelFactory) => Initializing EXISTING context for channel '[980963a5 : EWN1YTF0SOU]' to '/185.200.246.67:9877' (Response Promise: java.util.concurrent.CompletableFuture@2e081f98[Completed exceptionally: com.ibasco.agql.core.exceptions.ReadTimeoutException]) 23:11:11.552 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Acquired context (request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:11.552 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool -- [com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1] Acquired an existing healthy channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191] for address '/185.200.246.67:9877' (Local: /[0:0:0:0:0:0:0:0]:62191, Active: true) 23:11:11.552 [rate-limiter-3-1] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Preparing context for transport (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Local address not updated for envelope Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Resetting response promise for request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Resetting context properties (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Attached auto-release listener 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Sending request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' to transport 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Intercepted request of type 'MessageEnvelope' (Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877) 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:11.553 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => ACCEPTED message 'MessageEnvelope' 23:11:11.554 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Encoding query request 'SourceQueryRulesRequest' to DatagramPacket (9 bytes): 0xFF 0xFF 0xFF 0xFF 0x56 0x0E 0x3E 0x82 0x46 23:11:11.554 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Writing message 'DatagramPacket(=> /185.200.246.67:9877, AdvancedLeakAwareByteBuf(PooledUnsafeDirectByteBuf(ridx: 0, widx: 9, cap: 9)))' to transport (Request Id: EWN1YTF0SOU, Type: SourceQueryRulesRequest) 23:11:11.555 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Registered ReadTimeoutHandler (Read Timeout: 5000 ms) 23:11:11.555 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Request has been sent and processed through the channel's pipeline (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:16.556 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler -- [980963a5 : EWN1YTF0SOU] INB => Firing ReadTimeoutException (Time: 5000 ms) 23:11:16.557 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (ERROR) => Type: ReadTimeoutException, Message: N/A (Channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191], Pooled: true) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:16.558 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Received response for request 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877' (Error: ReadTimeoutException) 23:11:16.558 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => [ERROR] Received response in error (Request: 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877', Error: ReadTimeoutException) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:16.559 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Skipping auto release 23:11:17.561 [agql-el-1-6] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Retrying request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' for server address '/185.200.246.67:9877'. Closing existing context. 23:11:17.561 [agql-el-1-6] DEBUG com.ibasco.agql.core.transport.pool.NettyPooledChannelFactory -- [POOL] Acquiring channel for address '/185.200.246.67:9877' (Channel Pool: com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1, Pool Size: 0) 23:11:17.561 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Released (Active: true, Open: true, Registered: true) 23:11:17.562 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Removed READ/WRITE Timeout Handlers 23:11:17.562 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel closed. Forcing reset of assembler 23:11:17.562 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.packets.util.SourceLazySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] ASSEMBLER => Successfully reset assembler 23:11:17.562 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT (RELEASE) => Context released (Pooled) 23:11:17.562 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Acquired. (Local Address: '0:0:0:0:0:0:0:0', Remote Address: 'N/A') (POOLED) 23:11:17.562 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel acquired. Creating new assembler for channel '[id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyContextChannelFactory -- [980963a5 : EWN1YTF0SOU] CHANNEL_FACTORY (NettyContextChannelFactory) => Initializing EXISTING context for channel '[980963a5 : EWN1YTF0SOU]' to '/185.200.246.67:9877' (Response Promise: java.util.concurrent.CompletableFuture@336a7f0d[Completed exceptionally: com.ibasco.agql.core.exceptions.ReadTimeoutException]) 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Acquired context (request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool -- [com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1] Acquired an existing healthy channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191] for address '/185.200.246.67:9877' (Local: /[0:0:0:0:0:0:0:0]:62191, Active: true) 23:11:17.563 [rate-limiter-3-1] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Preparing context for transport (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Local address not updated for envelope Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Resetting response promise for request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Resetting context properties (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Attached auto-release listener 23:11:17.563 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Sending request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' to transport 23:11:17.564 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Intercepted request of type 'MessageEnvelope' (Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877) 23:11:17.564 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:17.564 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:17.564 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:17.564 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => ACCEPTED message 'MessageEnvelope' 23:11:17.565 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Encoding query request 'SourceQueryRulesRequest' to DatagramPacket (9 bytes): 0xFF 0xFF 0xFF 0xFF 0x56 0x0E 0x3E 0x82 0x46 23:11:17.565 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Writing message 'DatagramPacket(=> /185.200.246.67:9877, AdvancedLeakAwareByteBuf(PooledUnsafeDirectByteBuf(ridx: 0, widx: 9, cap: 9)))' to transport (Request Id: EWN1YTF0SOU, Type: SourceQueryRulesRequest) 23:11:17.565 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Registered ReadTimeoutHandler (Read Timeout: 5000 ms) 23:11:17.565 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Request has been sent and processed through the channel's pipeline (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:22.567 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler -- [980963a5 : EWN1YTF0SOU] INB => Firing ReadTimeoutException (Time: 5000 ms) 23:11:22.567 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (ERROR) => Type: ReadTimeoutException, Message: N/A (Channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191], Pooled: true) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:22.568 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Received response for request 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877' (Error: ReadTimeoutException) 23:11:22.568 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => [ERROR] Received response in error (Request: 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877', Error: ReadTimeoutException) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:22.569 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Skipping auto release 23:11:23.570 [agql-el-1-7] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Retrying request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' for server address '/185.200.246.67:9877'. Closing existing context. 23:11:23.571 [agql-el-1-7] DEBUG com.ibasco.agql.core.transport.pool.NettyPooledChannelFactory -- [POOL] Acquiring channel for address '/185.200.246.67:9877' (Channel Pool: com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1, Pool Size: 1) 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Released (Active: true, Open: true, Registered: true) 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Removed READ/WRITE Timeout Handlers 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel closed. Forcing reset of assembler 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.packets.util.SourceLazySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] ASSEMBLER => Successfully reset assembler 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT (RELEASE) => Context released (Pooled) 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Acquired. (Local Address: '0:0:0:0:0:0:0:0', Remote Address: 'N/A') (POOLED) 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel acquired. Creating new assembler for channel '[id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191]' 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.NettyContextChannelFactory -- [980963a5 : EWN1YTF0SOU] CHANNEL_FACTORY (NettyContextChannelFactory) => Initializing EXISTING context for channel '[980963a5 : EWN1YTF0SOU]' to '/185.200.246.67:9877' (Response Promise: java.util.concurrent.CompletableFuture@1ee83222[Completed exceptionally: com.ibasco.agql.core.exceptions.ReadTimeoutException]) 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Acquired context (request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:23.571 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool -- [com.ibasco.agql.core.transport.pool.SimpleNettyChannelPool@4006ddb1] Acquired an existing healthy channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191] for address '/185.200.246.67:9877' (Local: /[0:0:0:0:0:0:0:0]:62191, Active: true) 23:11:23.571 [rate-limiter-3-1] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Preparing context for transport (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Local address not updated for envelope Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Resetting response promise for request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Resetting context properties (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Attached auto-release listener 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Sending request 'SourceQueryRulesRequest[id=EWN1YTF0SOU]' to transport 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Intercepted request of type 'MessageEnvelope' (Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877) 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.challenge.SourceQueryChallengeEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.info.SourceQueryInfoEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.players.SourceQueryPlayersEncoder -- [980963a5 : EWN1YTF0SOU] OUT => REJECTED message 'MessageEnvelope' (Reason: Rejected by concrete handler) 23:11:23.572 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => ACCEPTED message 'MessageEnvelope' 23:11:23.573 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.rules.SourceQueryRulesEncoder -- [980963a5 : EWN1YTF0SOU] OUT => Encoding query request 'SourceQueryRulesRequest' to DatagramPacket (9 bytes): 0xFF 0xFF 0xFF 0xFF 0x56 0x0E 0x3E 0x82 0x46 23:11:23.573 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Writing message 'DatagramPacket(=> /185.200.246.67:9877, AdvancedLeakAwareByteBuf(PooledUnsafeDirectByteBuf(ridx: 0, widx: 9, cap: 9)))' to transport (Request Id: EWN1YTF0SOU, Type: SourceQueryRulesRequest) 23:11:23.574 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (OUTBOUND) => Registered ReadTimeoutHandler (Read Timeout: 5000 ms) 23:11:23.574 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyTransport -- [980963a5 : EWN1YTF0SOU] TRANSPORT => Request has been sent and processed through the channel's pipeline (Request: SourceQueryRulesRequest[id=EWN1YTF0SOU]) 23:11:28.575 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler -- [980963a5 : EWN1YTF0SOU] INB => Firing ReadTimeoutException (Time: 5000 ms) 23:11:28.576 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.handlers.MessageRouter -- [980963a5 : EWN1YTF0SOU] ROUTER (ERROR) => Type: ReadTimeoutException, Message: N/A (Channel: (POOLED) [id: 0x980963a5, L:/[0:0:0:0:0:0:0:0]:62191], Pooled: true) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:28.577 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => Received response for request 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877' (Error: ReadTimeoutException) 23:11:28.577 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER => [ERROR] Received response in error (Request: 'Msg: [REQ:EWN1YTF0SOU], Type: SourceQueryRulesRequest, From: /[0:0:0:0:0:0:0:0]:62191, To: /185.200.246.67:9877', Error: ReadTimeoutException) com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) 23:11:28.580 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- Maximum number of attempts reached for request (Attempts: 5, Max Attempts: 5) com.ibasco.agql.core.exceptions.MessengerException: com.ibasco.agql.core.exceptions.ReadTimeoutException at com.ibasco.agql.core.NettyMessenger.wrapException(NettyMessenger.java:256) at java.base/java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1311) at java.base/java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1280) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162) at com.ibasco.agql.core.NettyChannelContext.markInError(NettyChannelContext.java:361) at com.ibasco.agql.core.NettyMessenger.receive(NettyMessenger.java:311) at com.ibasco.agql.core.NettyChannelContext.receive(NettyChannelContext.java:375) at com.ibasco.agql.core.transport.handlers.MessageRouter.exceptionCaught(MessageRouter.java:208) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler.exceptionCaught(SourceQuerySplitPacketAssembler.java:149) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.core.transport.handlers.MessageDecoder.exceptionCaught(MessageDecoder.java:93) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) Caused by: com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) ... 16 common frames omitted 23:11:28.583 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] MESSENGER (SourceQueryMessenger) => Releasing context 'NettyChannelContext#2247491 :: 980963a5 :: SourceQueryRulesRequest[id=EWN1YTF0SOU]' in error com.ibasco.agql.core.exceptions.MessengerException: com.ibasco.agql.core.exceptions.MaxAttemptsReachedException: com.ibasco.agql.core.exceptions.ReadTimeoutException at com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger.lambda$buildFallbackPolicy$0(SourceQueryMessenger.java:151) at dev.failsafe.Fallback.lambda$builderOfException$0(Fallback.java:106) at dev.failsafe.internal.FallbackImpl.applyStage(FallbackImpl.java:68) at dev.failsafe.internal.FallbackExecutor.lambda$applyAsync$2(FallbackExecutor.java:94) at dev.failsafe.internal.FallbackExecutor.lambda$applyAsync$5(FallbackExecutor.java:109) at java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) at dev.failsafe.internal.RetryPolicyExecutor.lambda$handleAsync$5(RetryPolicyExecutor.java:155) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863) at java.base/java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:887) at java.base/java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2325) at dev.failsafe.internal.RetryPolicyExecutor.lambda$handleAsync$6(RetryPolicyExecutor.java:150) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) at dev.failsafe.Functions.lambda$getPromiseOfStage$2(Functions.java:152) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162) at com.ibasco.agql.core.NettyChannelContext.markInError(NettyChannelContext.java:361) at com.ibasco.agql.core.NettyMessenger.receive(NettyMessenger.java:311) at com.ibasco.agql.core.NettyChannelContext.receive(NettyChannelContext.java:375) at com.ibasco.agql.core.transport.handlers.MessageRouter.exceptionCaught(MessageRouter.java:208) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler.exceptionCaught(SourceQuerySplitPacketAssembler.java:149) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.core.transport.handlers.MessageDecoder.exceptionCaught(MessageDecoder.java:93) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) Caused by: com.ibasco.agql.core.exceptions.MaxAttemptsReachedException: com.ibasco.agql.core.exceptions.ReadTimeoutException at com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger.lambda$buildFallbackPolicy$0(SourceQueryMessenger.java:150) ... 52 common frames omitted Caused by: com.ibasco.agql.core.exceptions.ReadTimeoutException: null at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) ... 16 common frames omitted 23:11:28.583 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger -- [980963a5 : EWN1YTF0SOU] Closing context 23:11:28.584 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Channel Released (Active: true, Open: true, Registered: true) 23:11:28.584 [agql-el-1-3] DEBUG com.ibasco.agql.core.transport.pool.DefaultChannelPoolHandler -- [980963a5 : EWN1YTF0SOU] HANDLER => Removed READ/WRITE Timeout Handlers 23:11:28.584 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] (SourceQuerySplitPacketAssembler) INB => Channel closed. Forcing reset of assembler 23:11:28.584 [agql-el-1-3] DEBUG com.ibasco.agql.protocols.valve.source.query.common.packets.util.SourceLazySplitPacketAssembler -- [980963a5 : EWN1YTF0SOU] ASSEMBLER => Successfully reset assembler 23:11:28.584 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT (RELEASE) => Context released (Pooled) 23:11:28.584 [agql-el-1-3] DEBUG com.ibasco.agql.core.NettyChannelContext -- [980963a5 : EWN1YTF0SOU] CONTEXT => Skipping auto release Exception in thread "main" java.util.concurrent.CompletionException: com.ibasco.agql.core.exceptions.MaxAttemptsReachedException: com.ibasco.agql.core.exceptions.ReadTimeoutException at com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger$RequestContext.completion(SourceQueryMessenger.java:368) at com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger$RequestContext.access$1000(SourceQueryMessenger.java:279) at com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger.lambda$send$1(SourceQueryMessenger.java:240) at java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:934) at java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:911) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162) at dev.failsafe.spi.FailsafeFuture.completeResult(FailsafeFuture.java:101) at dev.failsafe.AsyncExecutionImpl.complete(AsyncExecutionImpl.java:153) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) at dev.failsafe.internal.RetryPolicyExecutor.lambda$handleAsync$5(RetryPolicyExecutor.java:155) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863) at java.base/java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:887) at java.base/java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2325) at dev.failsafe.internal.RetryPolicyExecutor.lambda$handleAsync$6(RetryPolicyExecutor.java:150) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) at dev.failsafe.Functions.lambda$getPromiseOfStage$2(Functions.java:152) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162) at com.ibasco.agql.core.NettyChannelContext.markInError(NettyChannelContext.java:361) at com.ibasco.agql.core.NettyMessenger.receive(NettyMessenger.java:311) at com.ibasco.agql.core.NettyChannelContext.receive(NettyChannelContext.java:375) at com.ibasco.agql.core.transport.handlers.MessageRouter.exceptionCaught(MessageRouter.java:208) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.protocols.valve.source.query.common.handlers.SourceQuerySplitPacketAssembler.exceptionCaught(SourceQuerySplitPacketAssembler.java:149) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.core.transport.handlers.MessageDecoder.exceptionCaught(MessageDecoder.java:93) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:346) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:325) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:317) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.readTimedOut(ReadTimeoutHandler.java:78) at com.ibasco.agql.core.transport.handlers.ReadTimeoutHandler.channelIdle(ReadTimeoutHandler.java:63) at io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:503) at io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:475) at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:153) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:840) Caused by: com.ibasco.agql.core.exceptions.MaxAttemptsReachedException: com.ibasco.agql.core.exceptions.ReadTimeoutException at com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger.lambda$buildFallbackPolicy$0(SourceQueryMessenger.java:150) at dev.failsafe.Fallback.lambda$builderOfException$0(Fallback.java:106) at dev.failsafe.internal.FallbackImpl.applyStage(FallbackImpl.java:68) at dev.failsafe.internal.FallbackExecutor.lambda$applyAsync$2(FallbackExecutor.java:94) at dev.failsafe.internal.FallbackExecutor.lambda$applyAsync$5(FallbackExecutor.java:109) at java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150) ... 47 more Caused by: com.ibasco.agql.core.exceptions.ReadTimeoutException at com.ibasco.agql.core.exceptions.ReadTimeoutException.(ReadTimeoutException.java:27) ... 16 more ```