0

いくつかの「製品」を処理するキューがあり、JSONを介して送信されます。{1、2、3、4}のような順序で受け取りますが、resqueは{1、3、2、4}で処理しました。Product古いバージョンはすでに処理された新しいバージョンをオーバーライドできるため、彼らが注文したresqueプロセスは非常に重要です。resqueを
次のように伝える方法はありprocess {job} orderede by {job.field_I_want}ますか？

編集：ジョブをキューに入れるコード

def produto
        if params[:json]
#          upload = params[:json]
#          content = upload.read
#          parsed_json = JSON(content)

          parsed_json = JSON(params[:json])
          parsed_json['idFila'] = params[:idFila]

          logger.info parsed_json

          Resque.enqueue(ProdutoWorker, parsed_json)
          render json: ActiveSupport::JSON.encode(Retorno.new(:status => "OK", :mensagem => "Produto recebido")), :status => :ok
        else
          render json: ActiveSupport::JSON.encode(Retorno.new(:status => "Erro", :mensagem => "Sem JSON")), :status => :not_found
        end

        rescue => exception
          render json: ActiveSupport::JSON.encode(Retorno.new(:status => "Erro", :mensagem => "#{exception}")), :status => :error
      end #Produto
4

1 に答える 1

0

resqueは、キューに入れられた順序でジョブを処理します。ジョブをキューに入れるコードを投稿できますか？

于 2012-06-04T19:45:09.217 に答える