国产+高潮+在线,国产 av 仑乱内谢,www国产亚洲精品久久,51国产偷自视频区视频,成人午夜精品网站在线观看

請(qǐng)問webman/stomp怎么訂閱和發(fā)布ActiveMQ的topic[解決]

oliusha

問題描述

請(qǐng)問webman/stomp怎么訂閱和發(fā)布ActiveMQ的topic。請(qǐng)高手解答一下，謝謝。

// 隊(duì)列名
    public $queue = 'iot.cli.xxxxxx';

    // 連接名，對(duì)應(yīng) stomp.php 里的連接`
    public $connection = 'default';

    // 值為 client 時(shí)需要調(diào)用$ack_resolver->ack()告訴服務(wù)端已經(jīng)成功消費(fèi)
    // 值為 auto   時(shí)無(wú)需調(diào)用$ack_resolver->ack()
    public $ack = 'auto';

    // 消費(fèi)
    public function consume($data, AckResolver $ack_resolver = null)
    {
        // 如果是數(shù)據(jù)是數(shù)組，需要自行反序列化
        var_export(json_decode($data, true)); // 輸出 ['to' => 'tom@gmail.com', 'content' => 'hello']
        // 告訴服務(wù)端，已經(jīng)成功消費(fèi)
        $ack_resolver->ack(); // ack為 auto時(shí)可以省略此調(diào)用
    }
683 0 0
0個(gè)回答
年代過于久遠(yuǎn)，無(wú)法發(fā)表回答
??