Skip to content

Commit

Permalink
fixed topic queue usage
Browse files Browse the repository at this point in the history
  • Loading branch information
petr_bilek committed Jun 13, 2017
1 parent 4af438f commit ac8e87e
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ To use this in the grid, add this to ConsumerExtension configuration:
```yml
rabbitmqLoggerConsumer:
exceptionFileRoute:
route: get-tracy-exception-file2
route: get-tracy-exception-file
secret: xxx
....
```
Expand Down Expand Up @@ -167,9 +167,9 @@ If you installed Kdyby/Console extension, you can use this commands:
- **rabbitmqLoggerConsumer:list** to list and remove messages from queue.
- **rabbitmqLoggerConsumer:save** to list, save messages to database and remove from queue (Kdyby/Doctine extension needed).

While **rabbitmqLoggerConsumer:save** takes messages from queue described in configuration,
**rabbitmqLoggerConsumer:list** require queue name as argument to avoid accidentally removing message from queue.
You can use **rabbitmqLoggerConsumer:queue** to create new queue.
While *rabbitmqLoggerConsumer:save* takes messages from queue described in configuration,
*rabbitmqLoggerConsumer:list* require queue name as argument to avoid accidentally removing message from queue.
You can use *rabbitmqLoggerConsumer:queue* to create new queue.

```sh
php www/index.php rabbitmqLoggerConsumer:queue spy-whats-going-on exception # create queue for 'exception' routing key
Expand Down
Binary file added assets/ublaboo-grid-thumb.png
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added assets/ublaboo-grid.png
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
2 changes: 1 addition & 1 deletion src/RabbitLogger.php
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ private function publishLog($priority, $errorText, $exceptionFile = null) {
$routingKey = $priority;
$exOpt = $this->producer->getExchangeOptions();
if ($exOpt['type'] === 'topic') {
$routingKey .= "." . $guid;
$routingKey .= "." . $this->guid;
}

$this->producer->publish(json_encode($message), $routingKey);
Expand Down

0 comments on commit ac8e87e

Please sign in to comment.