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キーを取得しています。
これらのメッセージを処理する必要があり、応答のみを取得したいと考えています。
私はあなたの応答を待っています。
ありがとう、アヌプ