@@ 44-55 (lines=12) @@ | ||
41 | $this->assertInstanceOf(QueueInterface::class, $queue); |
|
42 | } |
|
43 | ||
44 | public function testGetExchange() |
|
45 | { |
|
46 | $subscriberBuilder = new SubscriberBuilder( |
|
47 | 'test_exchange', |
|
48 | ExchangeType::FANOUT, |
|
49 | $this->getConnectionManagerMock(), |
|
50 | $this->getLoggerMock(), |
|
51 | [] |
|
52 | ); |
|
53 | ||
54 | $this->assertEquals('test_exchange', $subscriberBuilder->getExchangeName()); |
|
55 | } |
|
56 | ||
57 | public function testGetExchangeType() |
|
58 | { |
|
@@ 57-68 (lines=12) @@ | ||
54 | $this->assertEquals('test_exchange', $subscriberBuilder->getExchangeName()); |
|
55 | } |
|
56 | ||
57 | public function testGetExchangeType() |
|
58 | { |
|
59 | $subscriberBuilder = new SubscriberBuilder( |
|
60 | 'test_exchange', |
|
61 | ExchangeType::DIRECT, |
|
62 | $this->getConnectionManagerMock(), |
|
63 | $this->getLoggerMock(), |
|
64 | [] |
|
65 | ); |
|
66 | ||
67 | $this->assertEquals(ExchangeType::DIRECT, $subscriberBuilder->getExchangeType()); |
|
68 | } |
|
69 | ||
70 | /** |
|
71 | * @return CmobiAMQPConnectionInterface |