From e03f2661b4fa7c103bfe6816312fc1d1b70ce03d Mon Sep 17 00:00:00 2001
From: FireMasterK <20838718+FireMasterK@users.noreply.github.com>
Date: Wed, 21 Jul 2021 02:57:28 +0530
Subject: [PATCH] Add null check for pubsub.

---
 src/main/java/me/kavin/piped/Main.java | 19 ++++++++++---------
 1 file changed, 10 insertions(+), 9 deletions(-)

diff --git a/src/main/java/me/kavin/piped/Main.java b/src/main/java/me/kavin/piped/Main.java
index a2837fb..267187d 100644
--- a/src/main/java/me/kavin/piped/Main.java
+++ b/src/main/java/me/kavin/piped/Main.java
@@ -44,15 +44,16 @@ public class Main {
                     Collections.shuffle(channels);
 
                     for (String channelId : channels)
-                        Multithreading.runAsyncLimitedPubSub(() -> {
-                            Session sess = DatabaseSessionFactory.createSession();
-                            try {
-                                ResponseHelper.subscribePubSub(channelId, sess);
-                            } catch (IOException | InterruptedException e) {
-                                e.printStackTrace();
-                            }
-                            sess.close();
-                        });
+                        if (channelId != null)
+                            Multithreading.runAsyncLimitedPubSub(() -> {
+                                Session sess = DatabaseSessionFactory.createSession();
+                                try {
+                                    ResponseHelper.subscribePubSub(channelId, sess);
+                                } catch (IOException | InterruptedException e) {
+                                    e.printStackTrace();
+                                }
+                                sess.close();
+                            });
 
                     s.close();
                 } catch (Exception e) {