'JSONRCFeedFormatter', * 'uri' => "redis://127.0.0.1:6379/rc.$wgDBname", * ); * * @since 1.22 */ class RedisPubSubFeedEngine implements RCFeedEngine { /** * @see RCFeedEngine::send */ public function send( array $feed, $line ) { $parsed = wfParseUrl( $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 ); if ( $conn !== false ) { $conn->publish( $channel, $line ); return true; } else { return false; } } }