Результаты поиска по запросу "amqp"
Как заставить Spring RabbitMQ создать новую очередь?
В моем (ограниченном) опыте с rabbit-mq, если вы создаете новый прослушиватель для очереди, которая еще не существует, очередь создается автоматически. Я пытаюсь использовать проект Spring AMQP с rabbit-mq для настройки прослушивателя, и вместо ...
Как заставить Spring RabbitMQ создать новую очередь?
В моем (ограниченном) опыте с rabbit-mq, если вы создаете нового слушателя для очереди, которая неПока не существует, очередь создается автоматически. Я'...
Пружинная интеграция - Queue / Poller, кажется, исчерпывает пул потоков без каких-либо действий
У меня есть приложение интеграции Spring, прикрепленное к брокеру AMQP. Я хочу получать сообщения из очереди amqp и обновлять записи в БД. Чтобы повысить производительность, у меня есть пул работников, позволяющих выполнять несколько обновлений ...
Получение количества неподтвержденных сообщений в очереди RabbitMQ из Java / Spring
есть ли способ вернуть количество неподтвержденных сообщений? Я использую этот код, чтобы получить количество сообщений в очереди: DeclareOk declareOk = amqpAdmin.getRabbitTemplate().execute( new ChannelCallback<DeclareOk>() { public DeclareOk ...
Message Broker против MOM (Message-Oriented Middleware)
Я немного сбит с толку относительно разницы между брокером сообщений, например RabbitMQ и промежуточное ПО, ориентированное на сообщения. Я не могу найти много информации, кроме того, что в Википедии. При поиске MOM я нахожу информацию о AMQP, в ...
Message Broker против MOM (Message-Oriented Middleware)
Я немного сбит с толку относительно разницы между брокером сообщений, например RabbitMQ и промежуточное ПО, ориентированное на сообщения. Я могу'не могу ...