From 6fd345a2e505b059768a70e23e33eef67ea3c40a Mon Sep 17 00:00:00 2001 From: Aaron Schulz Date: Fri, 22 Apr 2016 12:12:29 -0700 Subject: [PATCH] Fix EventRelayerKafka IDEA errors Change-Id: I2808cb3cefb4d97f5ae2650554076c92b0d877d9 --- includes/libs/eventrelayer/EventRelayerKafka.php | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/includes/libs/eventrelayer/EventRelayerKafka.php b/includes/libs/eventrelayer/EventRelayerKafka.php index 3555a232a8..999eb43935 100644 --- a/includes/libs/eventrelayer/EventRelayerKafka.php +++ b/includes/libs/eventrelayer/EventRelayerKafka.php @@ -7,7 +7,6 @@ use Kafka\Produce; * 'relayerConfig' => [ 'class' => 'EventRelayerKafka', 'KafkaEventHost' => 'localhost:9092' ], */ class EventRelayerKafka extends EventRelayer { - /** * Configuration. * @@ -25,9 +24,11 @@ class EventRelayerKafka extends EventRelayer { /** * Create Kafka producer. * - * @param Config $config + * @param array $params */ public function __construct( array $params ) { + parent::__construct( $params ); + $this->config = new HashConfig( $params ); if ( !$this->config->has( 'KafkaEventHost' ) ) { throw new InvalidArgumentException( "KafkaEventHost must be configured" ); @@ -40,17 +41,12 @@ class EventRelayerKafka extends EventRelayer { */ protected function getKafkaProducer() { if ( !$this->producer ) { - $this->producer = Produce::getInstance( null, null, $this->config->get( 'KafkaEventHost' ) ); + $this->producer = Produce::getInstance( + null, null, $this->config->get( 'KafkaEventHost' ) ); } return $this->producer; } - /** - * (non-PHPdoc) - * - * @see EventRelayer::doNotify() - * - */ protected function doNotify( $channel, array $events ) { $jsonEvents = array_map( 'json_encode', $events ); try { -- 2.20.1