Open Build Service

rubygem-tomte-protocol.spec Changed

tomte-protocol-1.1.1.gem/checksums.yaml.gz -> tomte-protocol-1.2.0.gem/checksums.yaml.gz Changed

tomte-protocol-1.1.1.gem/data/lib/tomte/protocol/endpoint/adapter.rb -> tomte-protocol-1.2.0.gem/data/lib/tomte/protocol/endpoint/adapter.rb Changed

tomte-protocol-1.1.1.gem/data/lib/tomte/protocol/endpoint/async.rb -> tomte-protocol-1.2.0.gem/data/lib/tomte/protocol/endpoint/async.rb Changed

@@ -83,9 +83,14 @@
     end
 
     def disconnect!(&block)
-
-      @client.disconnect do
-        log.debug "- Endpoint '#{name}', disconnected."
+      begin
+        @client.disconnect do
+          log.debug "- Endpoint '#{name}', disconnected."
+          block.call if block_given?
+        end
+      rescue
+        log.error "- Endpoint '#{name}', error in disconnect!: #{$!.to_s}".red
+        log.debug "\n |  #{$!.class.name} (#{$!.to_s})\n |  #{$!.backtrace.join("\n |  ")}".blue
         block.call if block_given?
       end
     end
@@ -135,7 +140,7 @@
 
     def tcp_connection_loss(conn, settings)
       log.error "= Endpoint '#{name}', tcp connection loss. reconnecting...".important!
-      conn.reconnect(false, 2)
+      conn.reconnect(false, 10)
     end
 
     def error(conn, connection_close)
@@ -150,15 +155,16 @@
     end
 
     def generic_on_tcp_connection_failure(settings)
-
       log.error "= Endpoint '#{name}' failed to connect to the broker.".important!
       log.debug settings.ai.subindent
+      raise ConnectionError.new "= Endpoint '#{name}' failed to connect to the broker."
     end
 
 
     def generic_on_possible_authentication_failure(settings)
       log.error "= Endpoint '#{name}' failed to authenticate to the broker.".important!
       log.debug settings.ai.subindent
+      raise AuthenticationError.new "= Endpoint '#{name}' failed to authenticate to the broker."
     end

tomte-protocol-1.1.1.gem/data/lib/tomte/protocol/version.rb -> tomte-protocol-1.2.0.gem/data/lib/tomte/protocol/version.rb Changed

tomte-protocol-1.1.1.gem/metadata.gz -> tomte-protocol-1.2.0.gem/metadata.gz Changed

Changes of Revision 2