RedisPubSubFeedEngine.php

Go to the documentation of this file.

<?php
class RedisPubSubFeedEngine implements RCFeedEngine {
    public function send( array $feed, $line ) {
        $parsed = parse_url( $feed['uri'] );
        $server = $parsed['host'];
        $options = array( 'serializer' => 'none' );
        $channel = 'rc';

        if ( isset( $parsed['port'] ) ) {
            $server .= ":{$parsed['port']}";
        }
        if ( isset( $parsed['query'] ) ) {
            parse_str( $parsed['query'], $options );
        }
        if ( isset( $parsed['pass'] ) ) {
            $options['password'] = $parsed['pass'];
        }
        if ( isset( $parsed['path'] ) ) {
            $channel = str_replace( '/', '.', ltrim( $parsed['path'], '/' ) );
        }
        $pool = RedisConnectionPool::singleton( $options );
        $conn = $pool->getConnection( $server );
        $conn->publish( $channel, $line );
    }
}