Contents

module ScribeThrift #:nodoc: all
  class SafeClient  
    def initialize(client, transport, reset = false)
      @client = client 
      @transport = transport
      @reset = reset
    end
    
    def reset_transport
      @transport.close rescue nil
      @transport.open
    end
    
    def method_missing(*args)
      reset_transport if @reset
      @client.send(*args)
    rescue IOError, UnavailableException, Thrift::ProtocolException, Thrift::ApplicationException, Thrift::TransportException
      reset_transport
      @client.send(*args)
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
scribe-0.1.2	lib/scribe/safe_client.rb
scribe-0.1.1	lib/scribe/safe_client.rb
scribe-0.1	lib/scribe/safe_client.rb