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 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 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 = ...

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

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=...

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 am using StreamingPull mechanism to receive messages from the Pub/Sub. Here is only 2 overriding for default SubscriberFactory settings: @Bean public SubscriberFactory subscriberFactory( ...

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 ...

Consider the code for consuming messages from Apache Pulsar that is set up with spring-pulsar: @PulsarListener( subscriptionName = "hello-pulsar-sub-2", topics = "#{...

I'm doing an event based system which consists of multiple services that communicate via kind of domain events. All services are on spring boot 3.1.3 and send messages via activemq artemis. I've got ...

I am using this code to read property <div class="form-group"> <label for="training" class="form-check-label mt-30"> ...

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....

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: @...