Skip to content

Commit

Permalink
Echo errors to Exceptions
Browse files Browse the repository at this point in the history
  • Loading branch information
Pavel committed Nov 1, 2017
1 parent 1648a1f commit 881c072
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 7 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,6 @@ composer require stomp-utils
- $headers - массив заголовков сообщения;
- $transactionId - Идентификатор транзакции.

### Получение сообщений из очеред в режиме демона
### Получение сообщений из очереди в режиме демона
Для начала необходимо реализовать класс, который будет обрабатывать полученное сообщение. Он должен наследоваться от класса ```Tochka\Integration\Stomp\BaseWorker``` и реализовывать метод ```handle()```.
Далее необходимо реализовать класс, который будет слушать сообщения из очереди. Класс должен наследоваться от ```Tochka\Integration\Stomp\Listener```. В классе нужно переопределить метод ```generateHandler()```, который должен возвращать объект-обработчик сообщения, который должен являться экземпляром ```Tochka\Integration\Stomp\BaseWorker```.
15 changes: 9 additions & 6 deletions src/StompClient.php
Original file line number Diff line number Diff line change
Expand Up @@ -15,11 +15,13 @@ class StompClient
/**
* @var Stomp
*/
private $stomp;
protected $stomp;

private $hosts;
private $login;
private $pw;
protected $hosts;
protected $login;
protected $pw;

protected $errors = [];

/**
* Примеры $connectionString:
Expand Down Expand Up @@ -87,9 +89,10 @@ public function getConnection(): \Stomp
*/
public function newConnection()
{
$this->errors = [];
$stomp = $this->initStomp();
if (!($stomp instanceof Stomp)) {
throw new StompClientException("Couldn't connect to Brocker by provided hosts: " . print_r($this->hosts, true));
throw new StompClientException("Couldn't connect to Brocker by provided hosts: " . implode('; ', $this->errors));
}

$this->stomp = $stomp;
Expand Down Expand Up @@ -126,7 +129,7 @@ private function connect($url, $login, $pw)
try {
return new Stomp($url, $login, $pw, ['accept-version' => '1.2']);
} catch (StompException $e) {
//nothing to do?
$this->errors[] = $url . ': ' . $e->getMessage();
}

return null;
Expand Down

0 comments on commit 881c072

Please sign in to comment.