в нашем текущем приложении мы используем Spring AMQP следующим образом: <rabbit:connection-factory id="cachingConnectionFactory" username="${rabbitmq.connection.username}"...

Связано с вопросом autowire simpmessagingtemplate У меня проблема с классом ExecutorSubscribeableChannel. Я хочу, чтобы сервер отправлял асинхронное сообщение в браузер. Как я могу правильно использовать ExecutorSubscribeableChannel ?...

Я пытаюсь использовать веб-сокеты Spring с Genson вместо Jackson . Когда я пытаюсь подключиться с клиента, я получаю следующее: java.lang.IllegalStateException: A SockJsMessageCodec is required but not available: Add Jackson 2 to the...

Я разрабатываю систему уведомлений в реальном времени в Spring 4 , используя встроенный брокер сообщений и STOMP через WebSocket . сильный>. Я хотел бы иметь возможность отправлять сообщения конкретному пользователю в соответствии с его...

В моем приложении используется Spring Framework 4, включенный в модуль обмена сообщениями Spring (с ключевыми абстракциями из проекта Spring Integration, такими как Message, MessageChannel, MessageHandler и другие, которые могут служить основой для...

Я пытаюсь использовать брокера ActiveMQ для доставки сообщения двум потребителям, слушающим автоматическую тему, с использованием средств интеграции Spring. Вот мои компоненты конфигурации (общие для издателей и подписчиков):...

документация для Spring WebSockets гласит: 4.4.13. Пользовательские направления Приложение может отправлять сообщения, предназначенные для определенного пользователя, а поддержка STOMP в Spring для этой цели распознает места...

Поскольку мы не используем Stomp для нашего сервера websocket, spring не предлагает структуру брокера сообщений. Мое видение состоит в том, чтобы использовать паб / подписку Spring для обмена сообщениями с хранилищем сообщений Redis для разработчиков...

Я не могу создать прослушиватель очереди работ с помощью Spring Boot и SQS (сообщение отправляется и отображается в пользовательском интерфейсе SQS) @MessageMapping или @SqsListener не работают Java: 11 Spring Boot: 2.1.7 Зависимость:...

Я пытаюсь отправлять прямые сообщения пользователю. Приложение не выполнило аутентификацию, поэтому существует временное решение для создания пользователей сеанса веб-сокета, как вы можете видеть в добавленном коде. @Configuration...

Spring Integration - ограничения емкости очереди производителя Мы используем удаленное разделение с MessageChannelPartitionHandler для отправки сообщений о разделе в очередь (ActiveMQ) для выбора и обработки рабочих. Задание имеет огромные данные...