Not printing reconnect-event as error

gateway/src/main/java/discord4j/gateway/DefaultGatewayClient.java

@@ -33,6 +33,7 @@
 import discord4j.gateway.retry.GatewayException;
 import discord4j.gateway.retry.GatewayStateChange;
 import discord4j.gateway.retry.PartialDisconnectException;
+import discord4j.gateway.retry.ReconnectException;
 import io.netty.buffer.ByteBuf;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.*;
@@ -259,7 +260,13 @@ public Mono<Void> execute(String gatewayUrl) {
                             .then();
 
                     return Mono.zip(httpFuture, readyHandler, receiverFuture, senderFuture, heartbeatHandler)
-                            .doOnError(t -> log.error(format(context, "{}"), t.toString()))
+                            .doOnError(t -> {
+                                if(t instanceof ReconnectException) {
+                                    log.info(format(context, "{}"), t.getMessage());
+                                } else {
+                                    log.error(format(context, "{}"), t.toString());
+                                }
+                            })
                             .doOnTerminate(heartbeat::stop)
                             .doOnCancel(() -> sessionHandler.close())
                             .then();

gateway/src/main/java/discord4j/gateway/GatewayWebsocketHandler.java

@@ -20,6 +20,7 @@
 import discord4j.common.close.DisconnectBehavior;
 import discord4j.gateway.retry.GatewayException;
 import discord4j.gateway.retry.PartialDisconnectException;
+import discord4j.gateway.retry.ReconnectException;
 import io.netty.buffer.ByteBuf;
 import io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
 import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
@@ -150,7 +151,9 @@ public void close(DisconnectBehavior behavior) {
      * @param error the cause for this session termination
      */
     public void error(Throwable error) {
-        log.info(format(context, "Triggering error sequence: {}"), error.toString());
+        if (!(error instanceof ReconnectException)) {
+            log.info(format(context, "Triggering error sequence: {}"), error.toString());
+        }
         close(DisconnectBehavior.retryAbruptly(error));
     }
 }

gateway/src/main/java/discord4j/gateway/PayloadHandlers.java

@@ -18,8 +18,9 @@
 
 import discord4j.discordjson.json.gateway.*;
 import discord4j.discordjson.possible.Possible;
-import discord4j.gateway.json.*;
+import discord4j.gateway.json.GatewayPayload;
 import discord4j.gateway.retry.GatewayException;
+import discord4j.gateway.retry.ReconnectException;
 import reactor.util.Logger;
 import reactor.util.Loggers;
 
@@ -81,7 +82,7 @@ private static void handleHeartbeat(PayloadContext<Heartbeat> context) {
     }
 
     private static void handleReconnect(PayloadContext<?> context) {
-        context.getHandler().error(new RuntimeException("Reconnecting due to reconnect packet received"));
+        context.getHandler().error(new ReconnectException("Reconnecting due to reconnect packet received"));
     }
 
     private static void handleInvalidSession(PayloadContext<InvalidSession> context) {
@@ -107,7 +108,8 @@ private static void handleHello(PayloadContext<Hello> context) {
             client.sender().next(GatewayPayload.resume(
                     ImmutableResume.of(client.token(), client.getSessionId(), client.sequence().get())));
         } else {
-            IdentifyProperties props = ImmutableIdentifyProperties.of(System.getProperty("os.name"), "Discord4J", "Discord4J");
+            IdentifyProperties props = ImmutableIdentifyProperties.of(System.getProperty("os.name"), "Discord4J",
+                    "Discord4J");
             IdentifyOptions options = client.identifyOptions();
             int[] shard = new int[]{options.getShardIndex(), options.getShardCount()};
             Identify identify = Identify.builder()
@@ -118,7 +120,8 @@ private static void handleHello(PayloadContext<Hello> context) {
                     .largeThreshold(250)
                     .shard(shard)
                     .presence(Optional.ofNullable(options.getInitialStatus()).map(Possible::of).orElse(Possible.absent()))
-                    .guildSubscriptions(options.getIntents().isAbsent() ? Possible.of(options.isGuildSubscriptions()) : Possible.absent())
+                    .guildSubscriptions(options.getIntents().isAbsent() ?
+                            Possible.of(options.isGuildSubscriptions()) : Possible.absent())
                     .build();
             log.debug(format(context.getContext(), "Identifying to Gateway"), client.sequence().get());
             client.sender().next(GatewayPayload.identify(identify));

gateway/src/main/java/discord4j/gateway/retry/ReconnectException.java

@@ -0,0 +1,12 @@
+package discord4j.gateway.retry;
+
+/**
+ * An exception class to handle gateway reconnects via reconnect opcode
+ */
+public class ReconnectException extends RuntimeException {
+
+    public ReconnectException(String message) {
+        super(message);
+    }
+}
+