public function onError(ConnectionInterface $conn, \Exception $exception)
    {
        $message = $exception->getMessage();
        $conn->close();
        $this->console->error(sprintf('Error: %s', $message));
    }
public function onError(ConnectionInterface $conn, \Exception $exception)
    {
        $message = $exception->getMessage();
        $conn->close();
        $this->console->error(sprintf('Error: %s', $message));
    }
public function onError ( ConnectionInterface $ conn , \ Exception $ exception ) { $ message = $ exception -> getMessage ( ) ; $ conn -> close ( ) ; $ this -> console -> error ( sprintf ( 'Error: %s' , $ message ) ) ; }
Perform action on error.

@param ConnectionInterface $conn      [description]
@param Exception           $exception [description]

@return [type] [description]
Perform action on error .