cog/stupidmq

此包已被弃用且不再维护。未建议替代包。

笨拙的消息队列

维护者

详细信息

github.com/krichprollsch/stupidMessageQueue

主页

源代码

问题

安装数: 13,921

依赖: 1

建议者: 0

安全性: 0

星标: 1

关注者: 1

分支: 1

公开问题: 0

1.0.1 2014-08-07 07:10 UTC

Requires

  • php: >=5.3.3

Requires (Dev)

MIT caacef7fab9dee8375aca8ffdf10557658337808

  • Pierre Tachoire <pierre.tachoire.woop@gmail.com>

message queue

This package is not auto-updated.

Last update: 2022-02-01 12:22:31 UTC

README

基于 Symfony 组件的消息队列

使用方法

请注意：FileAdapter 尚未工作，请使用 AdapterPdoMysql 代替。

提供消息

$adpater = new \Cog\StupiMQ\AdapterFile( sys_get_temp_dir() );
$channel = new \Cog\StupiMQ\Channel( $adapter );
$queue = new \Cog\StupiMQ\Queue( $channel, 'myQueue' );

$queue->publish( 'hello world' );

消费消息

$adpater = new \Cog\StupiMQ\AdapterFile( sys_get_temp_dir() );
$channel = new \Cog\StupiMQ\Channel( $adapter );
$queue = new \Cog\StupiMQ\Queue( $channel, 'myQueue' );

$message = $queue->consume();

提供反馈

$adpater = new \Cog\StupiMQ\AdapterFile( sys_get_temp_dir() );
$channel = new \Cog\StupiMQ\Channel( $adapter );
$queue = new \Cog\StupiMQ\Queue( $channel, 'myQueue' );

$message = $queue->consume();
$queue->feedback(
    $message-getId(),
    CoG\StupidMQ\Message\MessageInterface::STATE_DONE),
    'my feedback'
);

待办事项

  • 终止 FileAdapter