Результаты поиска по запросу "amqp"
когда умирает канал AMQP / RabbitMQ без соединений?
У меня есть простая тестовая программа RabbitMQ, которая случайным образом ставит сообщения в очередь, а другая читает их, используя Spring-AMQP. Если потребитель умирает (например, убивая процесс, не имея возможности закрыть его соединение или ...
Рабочие пулы и многопользовательские очереди с RabbitMQ
Я работаю над веб-приложением, которое является мультитенантным облачным приложением (множество клиентов, у каждого из которых есть своя отдельная «среда», но все на общих наборах аппаратного обеспечения), и мы представляем пользователю ...
Блокирует и получает пакетные сообщения с RabbitMq
Я пытаюсь использовать RabbitMq более нетрадиционным способом (хотя в этот момент я могу выбрать любую другую реализацию очереди сообщений, если это необходимо). Вместо того, чтобы отправлять push-сообщения Rabbit моим потребителям, потребитель ...
Установка AMQP через PECL
Я пытаюсь установитьРасширение RabbitMQ PECL [http://pecl.php.net/package/amqp] но после запуска sudo pecl install amqpЯ получаю следующее зашифрованное сообщение об ошибке, которое не помогло найти исчерпывающий поиск в Google. У меня ...
Особые преимущества NServiceBus перед простым RabbitMQ
Есть ли какие-либо преимущества использования NServiceBus по сравнению с простым использованием драйвера .net для RabbitMQ (при условии, что мы можем заменить MSMQ на AMQP). Предоставляет ли NSB какие-либо дополнительные функции или абстракции, ...
Message Broker против MOM (Message-Oriented Middleware)
Я немного сбит с толку относительно разницы между брокером сообщений, например RabbitMQ и промежуточное ПО, ориентированное на сообщения. Я не могу найти много информации, кроме того, что в Википедии. При поиске MOM я нахожу информацию о AMQP, в ...
Получение количества неподтвержденных сообщений в очереди RabbitMQ из Java / Spring
есть ли способ вернуть количество неподтвержденных сообщений? Я использую этот код, чтобы получить количество сообщений в очереди: DeclareOk declareOk = amqpAdmin.getRabbitTemplate().execute( new ChannelCallback<DeclareOk>() { public DeclareOk ...
Пружинная интеграция - Queue / Poller, кажется, исчерпывает пул потоков без каких-либо действий
У меня есть приложение интеграции Spring, прикрепленное к брокеру AMQP. Я хочу получать сообщения из очереди amqp и обновлять записи в БД. Чтобы повысить производительность, у меня есть пул работников, позволяющих выполнять несколько обновлений ...