diff --git a/src/Connection/WebdisConnection.php b/src/Connection/WebdisConnection.php index b546852b..dbdb4a2b 100644 --- a/src/Connection/WebdisConnection.php +++ b/src/Connection/WebdisConnection.php @@ -61,8 +61,9 @@ class WebdisConnection implements NodeConnectionInterface } $this->parameters = $parameters; - $this->resource = $this->createCurl($parameters); - $this->reader = $this->createReader($parameters); + + $this->resource = $this->createCurl(); + $this->reader = $this->createReader(); } /** @@ -109,11 +110,12 @@ class WebdisConnection implements NodeConnectionInterface /** * Initializes cURL. * - * @param ParametersInterface $parameters Initialization parameters for the connection. * @return resource */ - private function createCurl(ParametersInterface $parameters) + private function createCurl() { + $parameters = $this->getParameters(); + $options = array( CURLOPT_FAILONERROR => true, CURLOPT_CONNECTTIMEOUT_MS => $parameters->timeout * 1000, @@ -135,10 +137,9 @@ class WebdisConnection implements NodeConnectionInterface /** * Initializes the phpiredis protocol reader. * - * @param ParametersInterface $parameters Initialization parameters for the connection. * @return resource */ - private function createReader(ParametersInterface $parameters) + private function createReader() { $reader = phpiredis_reader_create(); @@ -337,9 +338,8 @@ class WebdisConnection implements NodeConnectionInterface public function __wakeup() { $this->assertExtensions(); - $parameters = $this->getParameters(); - $this->resource = $this->createCurl($parameters); - $this->reader = $this->createReader($parameters); + $this->resource = $this->createCurl(); + $this->reader = $this->createReader(); } }