protected void init() {
            _messageService = new MessageService(_host, _port);
            try {
                _messageService.register(_clientId);
                _queue = _messageService.getQueue(_queueId);
            } catch (ClientAlreadyExistsException e) {
                e.printStackTrace();
            } catch (ClientRegisterFailureException e) {
                e.printStackTrace();
            } catch (QueueGetException e) {
                e.printStackTrace();
            } catch (ClientNotRegisteredException e) {
                e.printStackTrace();
            } catch (QueueDoesNotExistException e) {
                e.printStackTrace();
            }
        }