Вопросы по теме 'spring-messaging'

Внутренняя подписка на сообщения spring-websocket
Я использую spring-websocket для отправки сообщений клиентам браузера. Мои настройки почти идентичны настройкам в примере портфолио , и я отправляю сообщения, используя Операции по отправке сообщений : MessageSendingOperations<String>...
876 просмотров

Обмен сообщениями с Spring и внешними брокерами сообщений
Мой вариант использования рассматривает трех действующих лиц: Производитель сообщений (например, Удаленный сервер ); брокер сообщений (например, RabbitMQ ); Потребитель сообщений ( весеннее - веб-приложение на собственной AS )....
1075 просмотров

Spring SimpMessagingTemplate
У меня есть приложение, которое получает некоторые данные от RabbitMQ. Все работает нормально, я имею в виду в классе, где у меня есть аннотация @EnableScheduling. @Scheduled(fixedDelay = 5000) public void volumeGraphData() { Random r = new...
1582 просмотров

Как установить время ожидания в JmsMessagingTemplate.sendAndReceive
Я использую sendAndReceive из JmsMessagingTemplate в контроллере MVC, но если ответное сообщение не отправляется, кажется, что ответ будет ждать вечно. В документации указано, что: Возвращает: ответ, возможно нулевой, если сообщение не может...
7105 просмотров

Как отправить сообщение об ошибке клиентам STOMP с помощью Spring WebSocket?
Я использую реализацию Spring STOMP через WebSocket с полнофункциональным брокером ActiveMQ. Когда пользователи SUBSCRIBE входят в тему, существует некоторая логика разрешений, которую они должны пройти, прежде чем будут успешно подписаны. Я...
9896 просмотров

Отправить STOMP ERROR из программы Spring Websocket
У меня есть приложение Spring Websocket Stomp, которое принимает запросы SUBSCRIBE. В приложении у меня есть обработчик для SUBSCRIBE, то есть @Component public class SubscribeStompEventHandler implements...
5622 просмотров

Spring: отправка нескольких сообщений с помощью цикла
Скажем, у меня есть собственный модуль в Spring XD (я использую Spring XD + Spring Integration + hibernate). Модуль в основном получает что-то из БД (скажем, я сохраняю его с помощью объекта гибернации, поэтому я использую объект под названием...
2704 просмотров

Уведомления Spring Boot WebSockets
В моем приложении Spring Boot я пытаюсь реализовать функцию уведомлений на основе WebSockets. Я предоставил следующую конфигурацию: @Configuration @EnableWebSocketMessageBroker public class WebSocketConfig extends...
1780 просмотров

Перехватить входящее сообщение Spring Cloud Stream SubscribableChannel
Поскольку метод postReceive из org.springframework.messaging.support.ChannelInterceptor не вызывается в org.springframework.messaging.SubscribableChannel . Есть ли способ перехватить все входящие сообщения для метода annotated...
2309 просмотров

Как глобально обрабатывать исключение Spring WebSockets/Spring Messaging?
Вопрос Есть ли способ глобально обработать Spring Messaging MessageDeliveryException , вызванный ошибкой (обычно недостаточно прав) в модуле Spring WebSocket? Случай использования Я внедрил Spring WebSockets поверх STOMP для поддержки...
2257 просмотров

Определение BackoffStrategy для SQS в AWS
Я хочу настроить стратегию отсрочки для sqs в приложении Spring. Что я сделал: @Bean public ConnectionFactory sqsConnectionFactory() { PredefinedBackoffStrategies.ExponentialBackoffStrategy backoffStrategy = new...
2838 просмотров

Spring WebSocket и обслуживание атрибутов области сеанса
Я использую Spring MVC для обработки запросов пользователей. У каждого пользователя есть собственное «хранилище», скрытое за компонентом области действия сеанса. Проблема, которую я пытаюсь решить прямо сейчас, заключается в том, как обслуживать эти...
37 просмотров

Почему функциональность STOMP в spring-websocket зависит от Spring MVC?
В настоящее время я пытаюсь использовать STOMP с веб-сокетами, используя webflux. Чтобы отправить сообщение в тему STOMP, мне нужно использовать SimpMessagingTemplate , чему способствует автоматическая настройка весенней загрузки, когда я добавляю...
1819 просмотров