cog/stupidmq

stupid message queue

StupidMessageQueue

Message Queue based on Symfony Components, _(*1)

Usage

Be carefull : FileAdapter is not yet working, please use AdapterPdoMysql instead., _(*2)

Providing messages :, _(*3)

$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' );

Consuming messages :, _(*4)

$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();

Giving feedback, _(*5)

$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'
);

Todo

• Terminate FileAdapter