fix failing tests after timeout change

Author: matthewgoslett

tests/KafkaPubSubAdapterTest.php

@@ -49,7 +49,7 @@ public function testSubscribeWithNullMessage()
         $unsubscribeMessage->payload = 'unsubscribe';
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($unsubscribeMessage);
 
@@ -80,7 +80,7 @@ public function testSubscribeWithPartitionEofErrorCode()
         $message->payload = null;
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($message);
 
@@ -93,7 +93,7 @@ public function testSubscribeWithPartitionEofErrorCode()
         $unsubscribeMessage->payload = 'unsubscribe';
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($unsubscribeMessage);
 
@@ -124,7 +124,7 @@ public function testSubscribeWithTimedOutErrorCode()
         $message->payload = null;
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($message);
 
@@ -137,7 +137,7 @@ public function testSubscribeWithTimedOutErrorCode()
         $unsubscribeMessage->payload = 'unsubscribe';
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($unsubscribeMessage);
 
@@ -168,7 +168,7 @@ public function testSubscribeWithMessagePayload()
         $message->payload = 'a:1:{s:5:"hello";s:5:"world";}';
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($message);
 
@@ -182,7 +182,7 @@ public function testSubscribeWithMessagePayload()
         $unsubscribeMessage->payload = 'unsubscribe';
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($unsubscribeMessage);
 
@@ -213,7 +213,7 @@ public function testSubscribeWithErrorThrowsException()
         $message = new MockKafkaErrorMessage();
 
         $consumer->shouldReceive('consume')
-            ->with(300)
+            ->with(120000)
             ->once()
             ->andReturn($message);