Skip to content

Instantly share code, notes, and snippets.

@jerzabek
Created January 17, 2019 07:09
Show Gist options
  • Save jerzabek/c005741169a0351897b704f94708ceac to your computer and use it in GitHub Desktop.
Save jerzabek/c005741169a0351897b704f94708ceac to your computer and use it in GitHub Desktop.
[main] INFO com.jarza.peepocop.main.PeepoCop - peepoCop v3.0.0
[main] INFO com.jarza.peepocop.main.PeepoCop -
[main] INFO discord4j.core.DiscordClientBuilder - Shard 0 with Discord4J (https://discord4j.com)
[main] INFO discord4j.core.DiscordClientBuilder - Shard 0 with Discord4J (https://discord4j.com)
[main] INFO com.zaxxer.hikari.HikariDataSource - PeepoCopDBPool - Starting...
[main] INFO com.zaxxer.hikari.HikariDataSource - PeepoCopDBPool - Start completed.
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Connected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[elastic-3] INFO com.jarza.peepocop.events.CommandManager - 16.01.2019 21:11:20
Executing: >servers
Command: servers
User: jarza#1289 (218787234910961665)
Guild: cuko bot (334657301862547456)
Channel: testing1 (498035506534285312)
[elastic-3] INFO com.jarza.peepocop.events.CommandManager - 16.01.2019 21:19:56
Executing: >servers
Command: servers
User: jarza#1289 (218787234910961665)
Guild: cuko bot (334657301862547456)
Channel: testing1 (498035506534285312)
[parallel-4] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 43269 ms
[parallel-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-4] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2242 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 127632
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 5120 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[elastic-3] INFO com.jarza.peepocop.events.CommandManager - 16.01.2019 21:26:38
Executing: >servers
Command: servers
User: jarza#1289 (218787234910961665)
Guild: cuko bot (334657301862547456)
Channel: testing1 (498035506534285312)
[elastic-3] INFO com.jarza.peepocop.events.CommandManager - 16.01.2019 21:26:38
Executing: >stats
Command: stats
User: jarza#1289 (218787234910961665)
Guild: cuko bot (334657301862547456)
Channel: testing1 (498035506534285312)
[elastic-3] INFO com.jarza.peepocop.events.CommandManager - 16.01.2019 21:38:41
Executing: >stats
Command: stats
User: jarza#1289 (218787234910961665)
Guild: cuko bot (334657301862547456)
Channel: testing1 (498035506534285312)
[elastic-3] INFO com.jarza.peepocop.events.CommandManager - 16.01.2019 21:49:03
Executing: >stats
Command: stats
User: jarza#1289 (218787234910961665)
Guild: cuko bot (334657301862547456)
Channel: testing1 (498035506534285312)
[elastic-3] INFO com.jarza.peepocop.events.CommandManager - 16.01.2019 21:56:29
Executing: >stats
Command: stats
User: jarza#1289 (218787234910961665)
Guild: cuko bot (334657301862547456)
Channel: testing1 (498035506534285312)
[parallel-2] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 44500 ms
[parallel-2] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-2] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-2] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2189 ms
[reactor-http-nio-2] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 457191
[reactor-http-nio-2] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-2] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Retry attempt 2 in 4358 ms
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[parallel-2] INFO com.jarza.peepocop.main.PeepoCop - Balancing member ping roles...
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.io.IOException: Connection reset by peer)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.io.IOException: Connection reset by peer
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:219)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:790)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:412)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.signalAsyncError(FluxWindowPredicate.java:324)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:483)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onError(FluxWindowPredicate.java:270)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:151)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:369)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundError(FluxReceive.java:358)
at reactor.netty.channel.ChannelOperations.onInboundError(ChannelOperations.java:398)
at reactor.netty.channel.ChannelOperationsHandler.exceptionCaught(ChannelOperationsHandler.java:185)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelHandlerAdapter.exceptionCaught(ChannelHandlerAdapter.java:87)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.handler.ssl.SslHandler.exceptionCaught(SslHandler.java:1074)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.DefaultChannelPipeline$HeadContext.exceptionCaught(DefaultChannelPipeline.java:1401)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.DefaultChannelPipeline.fireExceptionCaught(DefaultChannelPipeline.java:953)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.handleReadException(AbstractNioByteChannel.java:125)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:174)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:347)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:148)
... 6 more
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.FluxFilter] :
reactor.core.publisher.Flux.ofType(Flux.java:5796)
reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
Error has been observed by the following operator(s):
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:154)
|_ Flux.windowUntil ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:42)
|_ Flux.flatMap ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:43)
|_ Flux.map ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:44)
|_ Flux.compose ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:155)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:156)
|_ Flux.log ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:157)
|_ Flux.doOnNext ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:158)
|_ Flux.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:159)
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2775 ms
[reactor-http-nio-3] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 237230
[reactor-http-nio-3] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-3] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-3] INFO discord4j.gateway.client.0 - Retry attempt 2 in 3754 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-1] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[parallel-1] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 42118 ms
[parallel-1] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-1] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-1] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2328 ms
[reactor-http-nio-3] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 27127
[reactor-http-nio-3] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-3] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-3] INFO discord4j.gateway.client.0 - Retry attempt 2 in 3890 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-1] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[parallel-1] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 46018 ms
[parallel-1] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-1] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-1] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2078 ms
[reactor-http-nio-3] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 19265
[reactor-http-nio-3] WARN discord4j.gateway.0 - Triggering error sequence (discord4j.common.close.CloseException: WebSocket closed: 4003 Not authenticated.)
[reactor-http-nio-3] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 4003 Not authenticated.
at discord4j.gateway.DiscordWebSocketHandler.lambda$handle$5(DiscordWebSocketHandler.java:166)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:262)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:794)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:426)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:487)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onComplete(FluxWindowPredicate.java:290)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:160)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:135)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
[reactor-http-nio-3] INFO discord4j.gateway.client.0 - Retry attempt 2 in 5955 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[reactor-http-nio-1] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-4] ERROR reactor.netty.http.client.HttpClientConnect - [id: 0xa213bd9d, L:/192.168.178.103:41828 - R:discordapp.com/104.16.59.5:443] The connection observed an error
java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:347)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:148)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
[reactor-http-nio-1] WARN discord4j.gateway.0 - Triggering error sequence (java.io.IOException: Connection reset by peer)
[reactor-http-nio-1] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.io.IOException: Connection reset by peer
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:219)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:790)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:412)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.signalAsyncError(FluxWindowPredicate.java:324)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:483)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onError(FluxWindowPredicate.java:270)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:151)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:369)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundError(FluxReceive.java:358)
at reactor.netty.channel.ChannelOperations.onInboundError(ChannelOperations.java:398)
at reactor.netty.channel.ChannelOperationsHandler.exceptionCaught(ChannelOperationsHandler.java:185)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelHandlerAdapter.exceptionCaught(ChannelHandlerAdapter.java:87)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.handler.ssl.SslHandler.exceptionCaught(SslHandler.java:1074)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.DefaultChannelPipeline$HeadContext.exceptionCaught(DefaultChannelPipeline.java:1401)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.DefaultChannelPipeline.fireExceptionCaught(DefaultChannelPipeline.java:953)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.handleReadException(AbstractNioByteChannel.java:125)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:174)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:347)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:148)
... 6 more
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.FluxFilter] :
reactor.core.publisher.Flux.ofType(Flux.java:5796)
reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
Error has been observed by the following operator(s):
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:154)
|_ Flux.windowUntil ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:42)
|_ Flux.flatMap ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:43)
|_ Flux.map ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:44)
|_ Flux.compose ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:155)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:156)
|_ Flux.log ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:157)
|_ Flux.doOnNext ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:158)
|_ Flux.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:159)
[reactor-http-nio-1] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2218 ms
[reactor-http-nio-3] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 1237770
[reactor-http-nio-3] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-3] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-3] INFO discord4j.gateway.client.0 - Retry attempt 2 in 4315 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-1] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[parallel-2] INFO com.jarza.peepocop.main.PeepoCop - Balancing member ping roles...
[reactor-http-nio-1] WARN discord4j.gateway.0 - Triggering error sequence (discord4j.common.close.CloseException: WebSocket closed: 1000)
[reactor-http-nio-1] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1000
at discord4j.gateway.DiscordWebSocketHandler.lambda$handle$5(DiscordWebSocketHandler.java:166)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:262)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:794)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:426)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:487)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onComplete(FluxWindowPredicate.java:290)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:160)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:135)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
[reactor-http-nio-1] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2937 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 30106
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 3538 ms
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[parallel-4] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 44128 ms
[parallel-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-4] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2209 ms
[reactor-http-nio-2] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 5
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (discord4j.common.close.CloseException: WebSocket closed: 4003 Not authenticated.)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 4003 Not authenticated.
at discord4j.gateway.DiscordWebSocketHandler.lambda$handle$5(DiscordWebSocketHandler.java:166)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:262)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:794)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:426)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:487)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onComplete(FluxWindowPredicate.java:290)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:160)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:135)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 5569 ms
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[parallel-4] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 82353 ms
[parallel-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-4] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2641 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 3898
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 4846 ms
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[parallel-4] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 81970 ms
[parallel-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-4] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2973 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 15504
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 5117 ms
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-2] WARN discord4j.gateway.0 - Triggering error sequence (java.io.IOException: Connection reset by peer)
[reactor-http-nio-2] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.io.IOException: Connection reset by peer
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:219)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:790)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:412)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.signalAsyncError(FluxWindowPredicate.java:324)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:483)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onError(FluxWindowPredicate.java:270)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:151)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:369)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundError(FluxReceive.java:358)
at reactor.netty.channel.ChannelOperations.onInboundError(ChannelOperations.java:398)
at reactor.netty.channel.ChannelOperationsHandler.exceptionCaught(ChannelOperationsHandler.java:185)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelHandlerAdapter.exceptionCaught(ChannelHandlerAdapter.java:87)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.handler.ssl.SslHandler.exceptionCaught(SslHandler.java:1074)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.DefaultChannelPipeline$HeadContext.exceptionCaught(DefaultChannelPipeline.java:1401)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.DefaultChannelPipeline.fireExceptionCaught(DefaultChannelPipeline.java:953)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.handleReadException(AbstractNioByteChannel.java:125)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:174)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:347)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:148)
... 6 more
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.FluxFilter] :
reactor.core.publisher.Flux.ofType(Flux.java:5796)
reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
Error has been observed by the following operator(s):
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:154)
|_ Flux.windowUntil ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:42)
|_ Flux.flatMap ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:43)
|_ Flux.map ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:44)
|_ Flux.compose ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:155)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:156)
|_ Flux.log ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:157)
|_ Flux.doOnNext ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:158)
|_ Flux.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:159)
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2263 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 26829
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 3609 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[reactor-http-nio-2] WARN discord4j.gateway.0 - Triggering error sequence (java.io.IOException: Connection reset by peer)
[reactor-http-nio-2] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.io.IOException: Connection reset by peer
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:219)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onError(FluxPeekFuseable.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:790)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:412)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.signalAsyncError(FluxWindowPredicate.java:324)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:483)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onError(FluxWindowPredicate.java:270)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onError(FluxMapFuseable.java:134)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:358)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:151)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:369)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundError(FluxReceive.java:358)
at reactor.netty.channel.ChannelOperations.onInboundError(ChannelOperations.java:398)
at reactor.netty.channel.ChannelOperationsHandler.exceptionCaught(ChannelOperationsHandler.java:185)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelHandlerAdapter.exceptionCaught(ChannelHandlerAdapter.java:87)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught(ChannelInboundHandlerAdapter.java:131)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.handler.ssl.SslHandler.exceptionCaught(SslHandler.java:1074)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:256)
at io.netty.channel.DefaultChannelPipeline$HeadContext.exceptionCaught(DefaultChannelPipeline.java:1401)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:264)
at io.netty.channel.DefaultChannelPipeline.fireExceptionCaught(DefaultChannelPipeline.java:953)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.handleReadException(AbstractNioByteChannel.java:125)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:174)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:347)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:148)
... 6 more
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.FluxFilter] :
reactor.core.publisher.Flux.ofType(Flux.java:5796)
reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
Error has been observed by the following operator(s):
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.ofType ⇢ reactor.netty.http.websocket.WebsocketInbound.receiveFrames(WebsocketInbound.java:80)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:154)
|_ Flux.windowUntil ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:42)
|_ Flux.flatMap ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:43)
|_ Flux.map ⇢ discord4j.gateway.ZlibDecompressor.completeMessages(ZlibDecompressor.java:44)
|_ Flux.compose ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:155)
|_ Flux.map ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:156)
|_ Flux.log ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:157)
|_ Flux.doOnNext ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:158)
|_ Flux.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:159)
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2110 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 23240
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 5468 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-2] WARN discord4j.gateway.0 - Triggering error sequence (discord4j.common.close.CloseException: WebSocket closed: 1006 java.nio.channels.ClosedChannelException)
[reactor-http-nio-2] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.nio.channels.ClosedChannelException
at discord4j.gateway.DiscordWebSocketHandler.lambda$handle$5(DiscordWebSocketHandler.java:166)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:262)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:271)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:794)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:426)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.checkTerminated(FluxWindowPredicate.java:487)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drainLoop(FluxWindowPredicate.java:435)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.drain(FluxWindowPredicate.java:379)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onComplete(FluxWindowPredicate.java:290)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onComplete(FluxOnAssembly.java:363)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:160)
at reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:381)
at reactor.netty.http.client.WebsocketClientOperations.onInboundClose(WebsocketClientOperations.java:156)
at reactor.netty.channel.ChannelOperationsHandler.channelInactive(ChannelOperationsHandler.java:121)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
at io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:75)
at io.netty.handler.codec.MessageAggregator.channelInactive(MessageAggregator.java:417)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
at io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:75)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:390)
at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:355)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:390)
at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:355)
at io.netty.handler.ssl.SslHandler.channelInactive(SslHandler.java:1054)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1429)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:947)
at io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:826)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:474)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2642 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 409781
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 2662 ms
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[parallel-4] WARN discord4j.gateway.client.0 - Missing heartbeat ACK for 43921 ms
[parallel-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to zombie or failed connection)
[parallel-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to zombie or failed connection
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.GatewayClient.lambda$null$5(GatewayClient.java:186)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:350)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:130)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxInterval$IntervalRunnable.run(FluxInterval.java:123)
at reactor.core.scheduler.PeriodicWorkerTask.call(PeriodicWorkerTask.java:59)
at reactor.core.scheduler.PeriodicWorkerTask.run(PeriodicWorkerTask.java:73)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to zombie or failed connection
... 16 more
[parallel-4] INFO discord4j.gateway.client.0 - Retry attempt 1 in 2545 ms
[reactor-http-nio-4] INFO discord4j.gateway.handler.0 - Attempting to RESUME from 5669
[reactor-http-nio-4] WARN discord4j.gateway.0 - Triggering error sequence (java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation)
[reactor-http-nio-4] ERROR discord4j.gateway.client.0 - Gateway client error
discord4j.common.close.CloseException: WebSocket closed: 1006 java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
at discord4j.gateway.DiscordWebSocketHandler.error(DiscordWebSocketHandler.java:231)
at discord4j.gateway.PayloadHandlers.handleInvalidSession(PayloadHandlers.java:93)
at discord4j.gateway.PayloadHandlers.handle(PayloadHandlers.java:62)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:422)
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:264)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.drain(FluxCreate.java:914)
at reactor.core.publisher.FluxCreate$LatestAsyncSink.next(FluxCreate.java:843)
at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:190)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:940)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1490)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.checkTerminated(FluxWindowPredicate.java:715)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:609)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:695)
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onComplete(FluxWindowPredicate.java:761)
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:228)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:353)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:205)
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:321)
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:319)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:536)
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:142)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at discord4j.common.close.CloseHandlerAdapter.channelRead(CloseHandlerAdapter.java:44)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1436)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1203)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1247)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoZip] :
reactor.core.publisher.Mono.zip(Mono.java:947)
discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
Error has been observed by the following operator(s):
|_ Mono.zip ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:172)
|_ Mono.doOnError ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:173)
|_ Mono.then ⇢ discord4j.gateway.DiscordWebSocketHandler.handle(DiscordWebSocketHandler.java:174)
|_ Flux.doFinally ⇢ reactor.netty.http.client.WebsocketFinalizer.lambda$handle$6(WebsocketFinalizer.java:75)
|_ Mono.flatMapMany ⇢ reactor.netty.http.client.WebsocketFinalizer.handle(WebsocketFinalizer.java:74)
|_ Flux.doOnComplete ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:203)
|_ Flux.doOnError ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:204)
|_ Flux.doOnCancel ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:205)
|_ Flux.doOnTerminate ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:206)
|_ Flux.then ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:207)
|_ Mono.zip ⇢ discord4j.gateway.GatewayClient.lambda$execute$12(GatewayClient.java:209)
Caused by: java.lang.RuntimeException: Reconnecting due to non-resumable session invalidation
... 80 more
[reactor-http-nio-4] INFO discord4j.gateway.client.0 - Retry attempt 2 in 3513 ms
[reactor-http-nio-2] INFO discord4j.gateway.client.0 - Reconnected to Gateway
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{334657301862547456} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{327892735963037696} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{357827314555420675} isAvailable: true
[elastic-2] INFO com.jarza.peepocop.main.PeepoCop - Guild ready: Snowflake{451928530461130775} isAvailable: true
Killed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment