Not Found

The requested URL was not found on this server.

Additionally, a 404 Not Found error was encountered while trying to use an ErrorDocument to handle the request.

1#@!#!123s

: / opt / remi / php82 / root / usr / share / doc / pecl / nsq / examples /

Filename : sub.php

back

<?php 

//sub

$nsq_lookupd = new NsqLookupd("127.0.0.1:4161"); //the nsqlookupd http addr
$nsq = new Nsq();

$config = array(
    "topic" => "test",
    "channel" => "struggle",
    "rdy" => 10,
    "connect_num" => 1, 
    "retry_delay_time" => 5000,  // after 5000 msec, message will be retried
    "auto_finish" => true,
);
//new NsqMessage();

$nsq->subscribe($nsq_lookupd, $config, function($msg,$bev){

    try{
        echo $msg->payload . " " . "attempts:".$msg->attempts."\n";
        //do something
    }catch(Exception $e){

        if($msg->attempts < 3){
            //the message will be retried after you configure retry_delay_time 
            throw new Exception(""); 
        }else{
            echo $e->getMessage();
            return;
        }
    }
    //$msg->touch($bev,$msg->message_id); //if you callback run long time ,you can use this function 

});

Name	Size	Last Modified	Owner	Permissions
deferred_pub.php	0.512 KB	September 17 2021 5:44:54	root	0644
identify_pub.php	0.467 KB	September 17 2021 5:44:54	root	0644
identify_sub.php	1.441 KB	September 17 2021 5:44:54	root	0644
pub.php	0.331 KB	September 17 2021 5:44:54	root	0644
sub.php	0.859 KB	September 17 2021 5:44:54	root	0644

2017 © D7net \| D704T team