I have a EventListener that gets connect requests of a Stomp Spring Server. @Component public class WebSocketEventListener { @EventListener public void handleWebSocketConnectListener(...

Trying to follow the documentation I would like to send a message to the user's destination and subscribe to it from a browser. The full demo is available here but basically I have @MessageMapping(&...

I have the following demo app this includes a JWTDecoder I can add to fake real auth @Configuration @Profile("fake-jwt") class FakeJwtConfig { @Bean fun jwtDecoder(): JwtDecoder { ...

I am using the STOMP websocket protocol with a Spring Boot backend and an Angular/RxStomp frontend. Clients can subscribe to a channel like /topics/jobs/123 to receive notifications/events about job #...

I am trying to use StreamBridge to publish messages to GCP pubsub in CloudEvents format and use Avro for schema validation. Here is the message building snippet Message<Person> ce = ...

We have a design where the front end connects to backend nodes by Websockets. Consider an example where Frontend node 1 (connects websocket) -----> server node1 Then server node1 cache the session ...

I have an application that exposes WebSocket endpoint with following config @Configuration @EnableWebSocketMessageBroker public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { ...

I'm currently working on library using spring boot 2.7. In the process of migrating to spring boot 3.1.4 I got an error on a class where: import org.springframework.cloud.aws.messaging.core....

In cds-messages.properties we have defined the message 409003=''{0}'' is a required field (*). For the same in error-messages-label-mapping.properties file we have defined the variable names name=...

I've tried the following code: private final NotificationMessagingTemplate notificationMessagingTemplate; public void send(final T payload, final Object groupId) { final ImmutableMap<String, ...

I have an issue which happends periodically in my system, but causes major problems. We use GCP Pub/Sub and sometimes subscriber receives a message with exactly 1 minute delay. In these cases only the ...

I am trying to migrate some application code from Spring Boot with rabbitmq to Spring Boot with SQS. I'd like my application to listen to a queue, but handle multiple object types, like this: @...

I am using StreamingPull mechanism to receive messages from the Pub/Sub. Here is only 2 overriding for default SubscriberFactory settings: @Bean public SubscriberFactory subscriberFactory( ...

My project currently has test code that connects to an ActiveMQ broker configured as follows: import lombok.extern.slf4j.Slf4j; import org.apache.activemq.broker.BrokerService; @Slf4j public class ...

I have code below to receive message and an attribute from the AWS SQS. The message body is as expected. However, the attribute "sourceId" is always taking the message body json as value. @...