@@ 89-92 (lines=4) @@ | ||
86 | $queueName = $this->stompQueueName; |
|
87 | if ($routingKey != '') { |
|
88 | switch($this->client->brokerVendor) { |
|
89 | case 'Apollo': |
|
90 | $routingKey = str_replace('#', '**', $routingKey); |
|
91 | $queueName = rtrim($queueName, '.') . '.' . ltrim($routingKey, '.'); |
|
92 | break; |
|
93 | case 'AMQ': |
|
94 | default: |
|
95 | $routingKey = str_replace('#', '>', $routingKey); |
|
@@ 94-96 (lines=3) @@ | ||
91 | $queueName = rtrim($queueName, '.') . '.' . ltrim($routingKey, '.'); |
|
92 | break; |
|
93 | case 'AMQ': |
|
94 | default: |
|
95 | $routingKey = str_replace('#', '>', $routingKey); |
|
96 | $queueName = rtrim($queueName, '.') . '.' . ltrim($routingKey, '.'); |
|
97 | } |
|
98 | } |
|
99 | return $queueName; |