270 questions
0
votes
0
answers
26
views
STOMP and internationalization (I18N)
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 #...
- 1,623
0
votes
0
answers
104
views
How do I subscribe to a user's destination in Spring Messaging WebSockets?
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(&...
- 24k
0
votes
0
answers
39
views
Spring StreamBridge and CloudEvents adding non-Avro complaint headers
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 = ...
0
votes
0
answers
79
views
Spring message not recognised correctly in other languages except English
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=...
- 3
0
votes
0
answers
182
views
Subscribers don't reconnect to the subscription when there is no traffic #2599
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(
...
0
votes
1
answer
156
views
How to consume null payloads with spring-pulsar from Apache Pulsar topic?
Consider the code for consuming messages from Apache Pulsar that is set up with spring-pulsar:
@PulsarListener(
subscriptionName = "hello-pulsar-sub-2",
topics = "#{...
- 396
-1
votes
1
answer
80
views
English to Spanish translation not working in JSP file
I am using this code to read property
<div class="form-group">
<label for="training" class="form-check-label mt-30"> ...
- 299
0
votes
1
answer
864
views
How to use @SqsListener with multiple object types?
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:
@...
- 2,065
1
vote
0
answers
501
views
How to integrate stomp/websockets using spring boot messaging with Jetty 10?
Some backstory:
I am working on a spring boot application which uses the spring-boot-starter-websocket library to update a frontend client with messages using STOMP.
The setup is as per spring docs - ...
- 11
0
votes
1
answer
1k
views
SqsListener Header take message body instead message attribute
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.
@...
- 1,729
0
votes
1
answer
133
views
How to get the flow back to current channel after output channel is processed in Spring Integration?
I have below channel defined in my spring integration xml.
<int:chain id="channel1" input-channel="inChannel" output-channel="outChannel">
1. <int:...
- 156
1
vote
0
answers
292
views
Kafka producer takes longer time to return acknowledgement
The application that I work for has some moderate amounts of 15k-17k req/sec events to be published to event-hub in Azure,
The event configuration looks as below:
metadata.max.age.ms: 180000
...
- 33
1
vote
1
answer
809
views
Spring and Google Cloud PubSub - subscribing to events
Following documentation, there are multiple ways to integrate Google Cloud PubSub events with Spring application:
Spring Cloud GCP has several modules for sending messages to Pub/Sub
topics and ...
- 399
1
vote
1
answer
917
views
Spring Boot: Architecting Application with Both Web and non-Web CLI processes as a monolith
I am looking for the best way to implement a single-module Spring Boot project, which can run as multiple processes (1) serving REST API or (2) running one of many CLI processes.
Details:
We have ...
- 11
1
vote
0
answers
177
views
Spring Boot Stomp With AWS ActiveMQ for thousands of Concurrent Connections
I am trying to build a Spring STOMP based application for exposing API's, we are using AWS ActiveMQ(AmazonMQ) as external broker for relaying STOMP messages.
We are observing an issue when we are ...
- 93
0
votes
1
answer
395
views
What happens to undelivered messages in Spring Simple Message Broker
I am using spring-messaging and spring-websocket modules to transmit messages between client and server over websockets. At the moment, I am using the "Simple Message Broker" that comes in-...
- 151
3
votes
1
answer
3k
views
Producer callback in Spring Cloud Stream using StreamBridge
I'm wondering a way to perform a callback using StreamBridge, I want to do something similar to KafkaTemplate.send that returns a ListenableFuture.
Is it possible with spring cloud stream to publish ...
- 103
0
votes
1
answer
879
views
How to fix 'java.lang.ClassCastException: class java.util.LinkedHashMap cannot be cast to class' error?
I am working on a Spring project in Java that recieves messages from a Google Pub/Sub subscription. However, my code fails to parse these incoming messages. The messages are given in a JSON format. A ...
user9808476
0
votes
1
answer
312
views
Dispatcher has no subscribers for outgoing sftp channel
I'm using spring-integration-sftp and my goal is to push local file to SFTP (just that for now, without confirmation or anything else). My configuration is as follows:
@EnableIntegration
@...
- 42
0
votes
1
answer
68
views
Which component is creating null-consumerMonitor-# threads?
Recently we started to test the Direct Container Factory in one of our microservices, the main motivation to change container factory is we want to reduce the thread number that process messages from ...
- 44
0
votes
0
answers
138
views
Custom Message Headers support when using functional bean definitons
I am unable to extract custom Message headers in a Function<Message,?> when using functional bean definitions for Spring cloud function.
Is there any way to extract the user defined Messsage ...
0
votes
0
answers
282
views
Corrupted payload sending Protobuff message using MQTT
I have got device simulator written in python which sent Protobuff messages using mqtt paho client. Problem occurs when I consume those messages by another client written in Java(also eclipse paho). ...
- 3
0
votes
1
answer
890
views
How do you add reactive interceptors to Spring Boot annotated controllers?
I've set up rsocket metrics using rsocket-micrometer on the CLIENT side, by configuring the RSocketConnector with interceptors, like this (Kotlin):
rSocketReqesterBuilder.rsocketConnector { ...
- 350
0
votes
1
answer
569
views
Spring Cloud Stream migration
I've noticed that @Output -> @StreamListener approach has been deprecated and totally rewritten, to be used with Supplier/Consumer approach. It's said that all functionalities has been preserved in ...
- 840
2
votes
3
answers
8k
views
How can I pass MessageGroupId for FIFO SNS
I've tried the following code:
private final NotificationMessagingTemplate notificationMessagingTemplate;
public void send(final T payload, final Object groupId) {
final ImmutableMap<String, ...
- 1,017