lib/polyn/cli/schema_loader.rb in polyn-cli-0.1.4 vs lib/polyn/cli/schema_loader.rb in polyn-cli-0.1.5

@@ -111,10 +111,10 @@
       def load_existing_events
         sub = client.subscribe("#{key_prefix}.>")
 
         loop do
           msg                                                     = sub.next_msg
-          existing_events[msg.subject.gsub("#{key_prefix}.", "")] = msg.data
+          existing_events[msg.subject.gsub("#{key_prefix}.", "")] = msg.data unless msg.data.empty?
         # A timeout is the only mechanism given to indicate there are no
         # more messages
         rescue NATS::IO::Timeout
           break
         end