CoreRabbitMQ

public interface CoreRabbitMQ

Предоставляет доступ к API RabbitMQ.

Methods

basicCancel

void basicCancel(String exchange, CoreSelection coreSelection, String operation)

Отменяет подписку выборки на сообщения от коммутатора.

Parameters:

  • exchange – Имя коммутатора.

  • coreSelection – Выборка CoreSelection.

  • operation – Имя операции - обработчика.

basicConsume

void basicConsume(String exchange, CoreSelection selection, String operation)

Выполняет подписку выборки на сообщения от коммутатора.

Parameters:

  • exchange – Имя коммутатора.

  • selection – Выборка CoreSelection.

  • operation – Имя операции - обработчика. Метод должен иметь один аргумент типа String.

basicPublish

void basicPublish(String exchange, String message)

Метод отправляет сообщение в коммутатор.

Parameters:

  • exchange – Имя коммутатора.

  • message – Сообщение

Throws:

exchangeDelete

boolean exchangeDelete(String name, boolean deleteFromRabbit)

Метод удаляет коммутатор (точку обмена) c серверов Global и Rabbit.

При удалении коммутатора производится отписка всех потребителей сообщений, подписанных методом basicConsume(java.lang.String, ru.bitec.gtk.core.gl.selection.CoreSelection, java.lang.String)

Parameters:

  • name – Имя коммутатора.

  • deleteFromRabbit – Если true, точка обмена будет удалена на сервере Rabbit, иначе только на сервере Global.

Returns:

true, если точка существовала и была удалена, иначе - false.

getHost

String getHost()

Возвращает сетевое имя или IP сервера RabbitMQ.

Возвращается значение, указанное в конфигурации сервера.

Returns:

Сетевое имя или IP.

getPassword

String getPassword()

Возвращает пароль, используемый для подключения к серверу RabbitMQ.

Возвращается значение, указанное в конфигурации сервера.

Returns:

Пароль.

getPort

Integer getPort()

Возвращает порт сервера RabbitMQ.

Возвращается значение, указанное в конфигурации сервера.

Returns:

Порт.

getUserName

String getUserName()

Возвращает имя пользователя, используемое для подключения к серверу RabbitMQ.

Возвращается значение, указанное в конфигурации сервера.

Returns:

Имя пользователя.

getVirtualHost

String getVirtualHost()

Возвращает имя виртуального узла на сервере RabbitMQ, соответствующее текущему экземпляру сервера Global.

Возвращается значение, указанное в конфигурации сервера. Сервер RabbitMQ может обслуживать несколько независимых виртуальных узлов.

Returns:

Виртуальный адрес узла.

isConnected

boolean isConnected()

Флаг указывает на состояние подключения к серверу RabbitMQ.

Returns:

true, если подключение установлено.

isEnabled

boolean isEnabled()

Флаг указывает на доступность функциональности клиента RabbitMQ в конфигурации ‘global3.config.xml’ сервера.

Returns:

true, если конфигурация содержит параметры подключения к серверу RabbitMQ и свойство ‘enabled = “true”’ или не указано. Иначе - false.