From: Aaron Schulz <aschulz@wikimedia.org>
Date: Fri, 22 Apr 2016 19:12:29 +0000 (-0700)
Subject: Fix EventRelayerKafka IDEA errors
X-Git-Tag: 1.31.0-rc.0~7206^2
X-Git-Url: https://git.heureux-cyclage.org/?p=lhc%2Fweb%2Fwiklou.git;a=commitdiff_plain;h=6fd345a2e505b059768a70e23e33eef67ea3c40a

Fix EventRelayerKafka IDEA errors

Change-Id: I2808cb3cefb4d97f5ae2650554076c92b0d877d9
---

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 {