lib/apnserver/server.rb in bpoweski-apnserver-0.1.3 vs lib/apnserver/server.rb in bpoweski-apnserver-0.1.6

@@ -20,11 +20,16 @@
         EventMachine::PeriodicTimer.new(1) do
           unless @queue.empty?
             size = @queue.size
             size.times do 
               @queue.pop do |notification|
-                @client.connect! unless @client.connected?
-                @client.write(notification)
+                begin
+                  @client.connect! unless @client.connected?
+                  @client.write(notification)
+                rescue Errno::EPIPE
+                  puts "Caught Errno::EPIPE adding notification back to queue"
+                  @queue.push(notification)
+                end
               end
             end
           end
         end
       end