diff --git a/src/models/StratumV1Client.ts b/src/models/StratumV1Client.ts
index 071374e..ce0159b 100644
--- a/src/models/StratumV1Client.ts
+++ b/src/models/StratumV1Client.ts
@@ -83,8 +83,9 @@ export class StratumV1Client extends EasyUnsubscribe {
         try {
             parsedMessage = JSON.parse(message);
         } catch (e) {
-            console.log(e);
+            console.log("Invalid JSON");
             this.promiseSocket.end();
+            return;
         }
 
         switch (parsedMessage.method) {
diff --git a/src/services/discord.service.ts b/src/services/discord.service.ts
index d97c953..d1cd8dc 100644
--- a/src/services/discord.service.ts
+++ b/src/services/discord.service.ts
@@ -103,6 +103,16 @@ export class DiscordService implements OnModuleInit {
         }
     }
 
+    public async notifyRestarted() {
+        if (this.bot == null) {
+            return;
+        }
+
+        const guild = await this.bot.guilds.fetch(this.guildId);
+        const channel = await guild.channels.fetch(this.channelId) as TextChannel;
+        channel.send(`Server Restarted.`);
+    }
+
     public async notifySubscribersBlockFound(height: number, block: Block, message: string) {
         if (this.bot == null) {
             return;
diff --git a/src/services/notification.service.ts b/src/services/notification.service.ts
index ce76fda..f643426 100644
--- a/src/services/notification.service.ts
+++ b/src/services/notification.service.ts
@@ -14,7 +14,7 @@ export class NotificationService implements OnModuleInit {
     ) { }
 
     async onModuleInit(): Promise<void> {
-
+        await this.discordService.notifyRestarted();
     }
 
     public async notifySubscribersBlockFound(address: string, height: number, block: Block, message: string) {