Tests/Transport/PubSub/PublisherTest.php 1 location
|
@@ 146-158 (lines=13) @@
|
143 |
|
* @param null $correlationId |
144 |
|
* @return CmobiAMQPMessage |
145 |
|
*/ |
146 |
|
protected function getCmobiAMQPMessage($msg = '', $correlationId = null) |
147 |
|
{ |
148 |
|
$msgMock = $this->getMockBuilder(CmobiAMQPMessage::class) |
149 |
|
->disableOriginalConstructor() |
150 |
|
->getMock(); |
151 |
|
$msgMock->method('get') |
152 |
|
->willReturn('correlation_id') |
153 |
|
->willReturn($correlationId); |
154 |
|
$msgMock->method('getBody') |
155 |
|
->willReturn($msg); |
156 |
|
|
157 |
|
return $msgMock; |
158 |
|
} |
159 |
|
} |
Tests/Transport/Rpc/RpcClientTest.php 1 location
|
@@ 136-148 (lines=13) @@
|
133 |
|
* @param null $correlationId |
134 |
|
* @return CmobiAMQPMessage |
135 |
|
*/ |
136 |
|
protected function getCmobiAMQPMessage($msg = '', $correlationId = null) |
137 |
|
{ |
138 |
|
$msgMock = $this->getMockBuilder(CmobiAMQPMessage::class) |
139 |
|
->disableOriginalConstructor() |
140 |
|
->getMock(); |
141 |
|
$msgMock->method('get') |
142 |
|
->willReturn('correlation_id') |
143 |
|
->willReturn($correlationId); |
144 |
|
$msgMock->method('getBody') |
145 |
|
->willReturn($msg); |
146 |
|
|
147 |
|
return $msgMock; |
148 |
|
} |
149 |
|
} |
Tests/Transport/Worker/TaskTest.php 1 location
|
@@ 99-111 (lines=13) @@
|
96 |
|
* @param null $correlationId |
97 |
|
* @return CmobiAMQPMessage |
98 |
|
*/ |
99 |
|
protected function getCmobiAMQPMessage($msg = '', $correlationId = null) |
100 |
|
{ |
101 |
|
$msgMock = $this->getMockBuilder(CmobiAMQPMessage::class) |
102 |
|
->disableOriginalConstructor() |
103 |
|
->getMock(); |
104 |
|
$msgMock->method('get') |
105 |
|
->willReturn('correlation_id') |
106 |
|
->willReturn($correlationId); |
107 |
|
$msgMock->method('getBody') |
108 |
|
->willReturn($msg); |
109 |
|
|
110 |
|
return $msgMock; |
111 |
|
} |
112 |
|
} |