| @@ 131-149 (lines=19) @@ | ||
| 128 | ); |
|
| 129 | } |
|
| 130 | ||
| 131 | public function testGetExchangeDeclare() |
|
| 132 | { |
|
| 133 | $queueBag = new SubscriberQueueBag('test', ExchangeType::DIRECT); |
|
| 134 | ||
| 135 | $this->assertEquals( |
|
| 136 | [ |
|
| 137 | 'test', |
|
| 138 | ExchangeType::DIRECT, |
|
| 139 | false, |
|
| 140 | false, |
|
| 141 | false, |
|
| 142 | false, |
|
| 143 | false, |
|
| 144 | null, |
|
| 145 | null |
|
| 146 | ], |
|
| 147 | $queueBag->getExchangeDeclare() |
|
| 148 | ); |
|
| 149 | } |
|
| 150 | ||
| 151 | public function testBadTypeInGetExchangeDeclare() |
|
| 152 | { |
|
| @@ 151-170 (lines=20) @@ | ||
| 148 | ); |
|
| 149 | } |
|
| 150 | ||
| 151 | public function testBadTypeInGetExchangeDeclare() |
|
| 152 | { |
|
| 153 | $queueBag = new SubscriberQueueBag('test', ExchangeType::DIRECT); |
|
| 154 | ||
| 155 | $this->assertNotEquals( |
|
| 156 | [ |
|
| 157 | 'test', |
|
| 158 | ExchangeType::FANOUT, |
|
| 159 | false, |
|
| 160 | false, |
|
| 161 | false, |
|
| 162 | false, |
|
| 163 | false, |
|
| 164 | false, |
|
| 165 | null, |
|
| 166 | null |
|
| 167 | ], |
|
| 168 | $queueBag->getExchangeDeclare() |
|
| 169 | ); |
|
| 170 | } |
|
| 171 | } |
|