fix(cluster) add missing error handling in Postgres strategy

From #2709
Kong · Jul 19, 2017 · 982af59 · 982af59
1 parent e061962
commit 982af59
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/kong/cluster_events/strategies/postgres.lua b/kong/cluster_events/strategies/postgres.lua
@@ -98,6 +98,9 @@ function _M:select_interval(channels, min_at, max_at)
     end
 
     local res, err = self.db:query(q)
+    if not res then
+      return nil, err
+    end
 
     local page = #res > 0 and 1 or 0