Какво е поведението при използване на следната конструкция (последната версия на Spring). Не мога да го намеря в документацията. @RabbitListener(queues = {"q1", "q2", "q3"}) public class MyListener { В какъв ред се обработват съобщенията от...

Случаят на използване е сървърът да се свърже с хиляди потребителски имейл акаунти и да надуши входящата поща в java, за предпочитане с java mail и пролетна интеграция/amqp/rabbit mq тип мащабируема инфраструктура. И имап неактивен тип връзки и...

След като създадох основна настройка на spring-amqp, виждам, че за всеки тип съобщение, което искам да изпратя (използвайки POJO на съобщения), трябва да декларирам опашката в конфигурацията на spring. Така че за всяка двойка от тези:...

В момента използвам springAMQP за комуникация между java и моя RabbitMQ възел. Изпращам данни на Protobuf. Бих искал да преобразувам/каст/анализирам полученото съобщение в съответния ProtoClass. Ето фрагмента от моя конвертор: @Override...

Ето какво имам (накратко) <int-amqp:inbound-channel-adapter auto-startup="false" listener-container="clientListenerContainer" channel="fromRabbitClientChannel" connection-factory="rabbitConnectionFactory" /> <bean...

Опитвам се да се свържа с RabbitMQ през SSL. Проследих документацията за RabbitMQ SSL, свързана тук https://www.rabbitmq.com/ssl.html Съгласно документацията на RabbitMQ SSL, свързването чрез SSLv3 и TLSv1 не се препоръчва поради известни...

ние използваме rabbit MQ и Spring Integration в нашия проект. Всяко съобщение има режим на доставка, заглавка, свойства и част от полезния товар. Искаме да добавим свойства, т.е.) приоритет със стойност 2 (всяко цяло число), полезен товар с "тестово...

Има ли някаква функционалност, вградена в spring-amqp, която би улеснила повторното поставяне на съобщения за мъртви писма? Мога да напиша код, за да го направя, но изглежда като толкова обичаен случай на употреба, който би се вписал добре в рамката.

Това е текущата ми пролетна amqp конфигурация <rabbit:connection-factory id="rabbitConnectionFactory" port="${rabbitmq.port}" host="${rabbitmq.host}" username="${rabbitmq.username}" password="${rabbitmq.password}"/> <rabbit:admin...

Имам многопотребителско приложение, в което включих Spring AMQP, за да изпращам съобщения до моя RabbitMQ сървър, след като тествах различни потребители, забелязах, че едновременните влизания в различен акаунт биха накарали други потребители да...

Имам изискване, при което имам 1 директен обмен и 5 различни опашки, свързани с него с уникален ключ за маршрутизиране. По принцип всяка опашка е предназначена за различни потребителски крайни точки. Използвам регистъра на крайната точка, управляван...

Моят въпрос е много подобен на този: RabbitTemplate получаване и повторна опашка За съжаление е маркиран като отговорен въпреки че отговорът не отговаря на нуждите ми. Искам да имитирам функционалността на потребителския интерфейс на...