checkpoint

in lib/aws/kclrb/checkpointer.rb [66:86]


      def checkpoint(sequence_number=nil)
        @io_proxy.write_action('checkpoint', 'sequenceNumber' => sequence_number)
        
        action = @io_proxy.read_action
        
        
        
        
        if action && action['action'] == 'checkpoint'
          raise CheckpointError.new(action['error'])  if action['error']
        else
          
          
          
          
          
          
          raise CheckpointError.new('InvalidStateException')
        end
      end