all messages seems to receive an ack about sneakers HOT 4 CLOSED

require 'sneakers'

Sneakers.configure :timeout_job_after => 1800

class QueueWorkerBackoffice
  include Sneakers::Worker
  from_queue(
    'backoffice',
    :durable => true,
    :ack => false,
    :threads => 5,
    :prefetch => 5
  )


  def work(msg)

    puts "WORKING..."

    begin
      data = Lovethesign::Queue.unserialize(msg)

      # logging queue_message to db
      queue_message = QueueMessage.create({
        message_class: data[:class],
        message_method: data[:method],
        params: data[:params],
        url: data[:url],
        queue: data[:queue],
        site: Site.by_code(data[:site]),
      })
      BackofficeMailer.queue_message_info(queue_message).deliver # sending email



      case data[:class]
      when 'order' # order
        puts "ORDER #{data[:params][:order][:order_id]} found in queue"
        if data[:method] == "order"
          data[:params][:order][:products].each do |p|
            adjust_value = -p[:qty].to_i
            message = "updated from order #{data[:params][:order][:order_id]}"
            Stock.adjust_by_value! p[:model], adjust_value, nil, message
            puts "updating stock of #{p[:model]} with #{adjust_value}"
            Stock.notify_sites! p[:model]
            puts "notifying sites for #{p[:model]} stock change to #{Stock.value_per_sku(p[:model])}"
            $backoffice.log "stock updating #{p[:model]}, adjust_value: #{adjust_value}"
          end
        end
      end

      ack!


    rescue StandardError => e
      error_output = "#{e.message}\n#{e.backtrace.join("\n")}"
      BackofficeMailer.generic_message("error in QueueWorkerBackoffice", error_output).deliver # sending email

      reject!

      raise e
    end

  end

end

2014-08-27T07:59:00Z p-15485 t-ow7tmadlw ERROR: could not obtain a database connection within 5.000 seconds (waited 5.000 seconds)

2014-08-27T17:39:26Z p-4933 t-otj62rojk ERROR: timeout