1

Iron.mq を使用しています。このコードを使用して、iron.io キューにメッセージをプッシュしました

public function reminder(){

    $section_url = Input::get('section_url');
    $selectdate = Input::get('selectdate');
    $email = Auth::user()->email;

    $MailQueue = new MailQueue;
    $data = [];
    $data['system_name'] = $section_url;
    $data['date_selected'] = $selectdate;

    $job_id = Queue::push('UserController@fire',$data);
    $MailQueue->job_id = $job_id;
    $MailQueue->user_id = Auth::user()->id;
    $MailQueue->system_name = $section_url;
    $MailQueue->date_selected = $selectdate;
    $MailQueue->save();
      return 1 ;
}

今、私はアイアンからのこれらのメッセージを処理し、自分のウェブページに応答したいと思っています。

Route::post('queue/receive', function(){
    return Queue::marshal();
});

これは私が鉄で申し込んだルートです。

laravelのドキュメントに従ってfire関数を作成しました。

public function fire($job, $data){
    $job_id = $job->getJobId(); // Get job id 
    $Testjob = new Testjob;
    $Testjob->name = $job_id;
    $Testjob->save();
    return 'this is testing';
}

今、私はプロセスについての考えを持っていません。データベース テーブルにエントリがない場合のプロセスの実行方法。鉄のキューに入れられたこれらのメッセージを処理する方法を教えてください。応答がありません。メッセージをプッシュしてからDBに保存するときにのみ、rendomキーを取得しています。

これらのメッセージを処理する必要があり、応答のみを取得したいと考えています。

私はあなたの応答を待っています。

ありがとう、アヌプ

4

0 に答える 0