Questions tagged [spring-boot-rsocket]
9 questions
4
votes
1 answer
How to tell RSocket to read data stream by Java 8 Stream which backed by Blocking queue
I have the following scenario whereby my program is using blocking queue to process message asynchronously. There are multiple RSocket clients who wish to receive this message. My design is such a way that when a message arrives in the blocking…
Saji
- 111
- 6
4
votes
0 answers
RSocket-JS + RSocketResumableTransport not working
RSocketResumableTransport does not seems to be working. I have below code where i am using RSocketResumableTransport but it never connects to the server(spring-boot version 2.4.0-M1). I am using rsocket-websocket-client": "0.0.19" version. Below is…
shankar
- 73
- 6
3
votes
0 answers
RSocket Java(Server) / C# (client) : Cannot decode to [ch.Person]GenericMessage
I want to communicate between a RSocket server (written in java using spring boot rsocket) and a C# client using directly the official rsocket .net library : https://github.com/rsocket/rsocket-net
Unfortunately, the java server has trouble to decode…
Alexandre
- 99
- 5
2
votes
2 answers
Why RSocket connection retry is using multiple (different) threads every time
I have the below program that connects to a Spring boot rsocket server running on localhost:7999.
I have configured the connector Retry.fixedDelay(Integer.MAX_VALUE, Duration.ofSeconds(5))
As you can see the the RSocketRequester is Mono so it should…
Saji
- 111
- 6
1
vote
0 answers
Rsocket-js client +Spring RsocketServer. when FluxSink<>.create() to send messages. client does not receive message when js client reloads web browser
My Spring boot serves as a rsocket server.
spring-boot-starter-rsocket v2.5.2 and spring-boot-starter v 2.5.2
App has a controller like so-
@MessageMapping("request.stream")
public Flux requestStream(@Payload String userInfo) throws…
user2198890
- 11
- 1
1
vote
2 answers
How to detect if RSocket connection is successfull?
I have the following program through which I can detect the connection failure i.e doBeforeRetry.
Can someone tell me how to detect the successful connection or reconnection. I want to integrate a Health Check program that monitors this connection,…
Saji
- 111
- 6
1
vote
1 answer
RSocket reconnect is not working when the server is restarted in the mid way
I am trying to test the reconnection feature of RSocket but it is not working when the sever was brought down in between and restart.
Step 1: Started the client when the server is down
16:02:35.351 [main] DEBUG io.netty.channel.DefaultChannelId -…
Saji
- 111
- 6
1
vote
0 answers
WebFlux+RSocket, How to pass flux from RSocket to WebFlux
I'm trying to use WebFlux with RSocket, The sample application has server and client applications. both running on WebFlux and RSocket, my rsocket communication type is request-stream. client-server application runs perfectly fine for couple…
Karthik Prasad
- 9,662
- 10
- 64
- 112
0
votes
1 answer
How to add trace id to tracing log by spring boot 3 rsocket?
I try to upgrade spring boot from 2.7 to 3.0. and the project use rsocket. I was use Spring Cloud Sleuth to get trace id into log file. and upgrade to spring boot 3, change to use io.micrometer:micrometer-tracing.
how do I add trace log into…
J. Hu
- 53
- 8