36 questions
0
votes
0
answers
39
views
Enabling tracing in Spring RSocket client
There is a RSocket server which I am interacting with. This RSocket server has tracing enabled.
Meaning, when I, and actually other clients talk to it, I can see server side traces in Grafana Cloud ...
1
vote
0
answers
112
views
get an error when using rsocket-js to communicate with Spring-rsocket when the data transferred is large then 65536
I'm tesing rsocket-js on web browser using rsocket-websocket-client.
Client code,running on web browser:
async function initRequest() {
const transportOpts = {
url: 'ws:' + '127.0.0.1:6565',
...
0
votes
0
answers
19
views
Spring RSocket API
I have two microservice cluster environments across the public network. The clusters communicate with the http protocol. Currently, a small number of businesses need to communicate across the ...
0
votes
0
answers
53
views
"Pending acquire queue has reached its maximum size.." error in the RSocket server responding to a RSocket client
I am trying to understand the next error thrown by a Spring boot application(above all the first 4 lines) that is using RSocket protocol to respond to another application acting as a RSocket client. I ...
0
votes
0
answers
18
views
Use one port building a RSocket network
I'm new in Spring RSocket. Based on the official documentation and related articles online, I understand that one service needs to configure an RSocket port to act as a "server," while ...
1
vote
0
answers
49
views
How to get some metadata from client in @ConnectMapping for RSocket Java Spring
I now receive an rsocket connection in my spring project, and then I want to read some metadata from the client which initiated the connection, how should I pass/retrieve it?
@ConnectMapping
public ...
2
votes
1
answer
4k
views
Spring Boot 3.2.0 Upgrade: "Authentication Manager Cannot Be Null" with RSocketSecurity
I recently upgraded my Spring Boot application to version 3.2.0 (along with Spring Framework 6.1.1 and Spring Security 6.2.0). Post-upgrade, I am encountering an issue where the contextLoads() test ...
5
votes
0
answers
369
views
Using Spring RSocket in a traditional Servlet-based Spring application
Is it somehow possible to use Spring's RSocket integration in a "traditional" servlet-based Spring application without having to sacrifice functionality that Spring offers according to the ...
1
vote
0
answers
105
views
Spring boot rSocket endpoints can be accessed over WebFlux port
I have a spring boot server with both WebFlux controller and an rSocket controller
06-15 12:15:11.273|INFO|o.s.b.w.e.netty.NettyWebServer:111|main --- Netty started on port 8080
06-15 12:15:11.291|...
2
votes
0
answers
139
views
Processing headers with rsocket in spring boot application
I am testing RSocket request-response logic and have some problem with processing headers.
I am using spring boot 2.7.9 with Kotlin.
My Controller:
package com.mol.rsocket.controller
import com.mol....
0
votes
1
answer
544
views
what is the difference between RSocket and Spring webflux websocket?
What is the difference between Spring webflux WebSocket and RSocket? I am trying to implement reactive websocket in my spring boot project but I see RSocket under a separate section on the spring ...
0
votes
1
answer
190
views
Rsocket-java stream: How to replace/update the JWT token within Flux.retryWhen(...)?
Given the rsocket client retrieving data from server using stream semantic, I would like to utilize Flux.retryWhen(retryBackoffSpec) mechanizm to reconnect in case connection is lost. Streaming ...
0
votes
1
answer
512
views
Rsocket-js Unable to set destination route when connection to channel react native client
I am new to Rsocket and reactive Websocket and I develop an application where I need multiple channels, where my clients can subscribe. Until now I tried 2 solutions but unfortunately non of them ...
2
votes
2
answers
2k
views
rSocket websocket postman testing mime types and endpoints
I am using spring-boot-starter-webflux and spring-boot-starter-rsocket version 2.7.1
The rSocket transport is set to websocket like this:
spring.rsocket.server.transport=websocket
spring.rsocket....
0
votes
1
answer
221
views
Multiple producers for one consumer or request
I can see that I can route one request to a responder and that there's different implementations like fireAndForget and all that but I have a case where producers are responsible for their subset of ...
1
vote
3
answers
745
views
How to pass JWT token in Metadata in Rsocket Client in Spring Boot
I have added routes and JWT token in metadata but while passing token from RSocket client to RSocket server it is adding extra bytes in token.
Client side code -----------
ByteBuf ...
-1
votes
1
answer
653
views
Flutter RSocket client not connecting to RSocket API created using Spring Boot
I'm playing with RSocket in Flutter.
I've created two RSocket apis like below:
@MessageMapping("stream")
Flux<Long> numbers(){
return Flux.interval(Duration.ofSeconds(1)...
1
vote
0
answers
937
views
Spring rsocket security with Webflux security
My Application is a Spring Webflux application with Spring boot version 2.6.6.
Since, I have a chat and notification requirement for the logged in user, trying to use RSocket over websocket for ...
3
votes
0
answers
495
views
Spring Boot - RSocket over websocket - Server responders not working
I am using Spring boot 2.6.3. This is a Spring webflux project and using RSocket over Websoocket for Notification.
Server side:-
build.gradle,
implementation 'org.springframework.boot:spring-boot-...
1
vote
2
answers
114
views
How to make the path public in RSocketSecurity(Spring)
I have config class for RSocketSecurity
Something like that
@Configuration
@EnableRSocketSecurity
@EnableReactiveMethodSecurity
class RSocketAuthConfiguration {
and authorization for it (allows only ...
3
votes
2
answers
943
views
Spring RSocket over WebSocket - Access user information from HTTP session
In my web application, users login using a username/password combination and get a session cookie. When initiating a WebSocket connection, I can easily access the user information in the ...
3
votes
1
answer
2k
views
RSocket over websocket - reactor.core.Exceptions$ErrorCallbackNotImplemented: java.util.concurrent.CancellationException: Disposed
I am using Spring webflux for general requirement and Spring RSocket over websocket for server push & chat requirement.
Spring boot version - 2.5.6
implementation 'org.springframework.boot:spring-...
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 { ...
1
vote
0
answers
118
views
spring rsocket response metadata
When using spring-boot-starter-rsocket is there a way to send response metadata from a MessageMapping-annotated method? I also don't see a way for RSocketRequester to receive metadata (all ...
4
votes
0
answers
339
views
Spring reactor rsocket connection limits
I'm managing socket client using spring integration TCP and try to use RSocket.
My target server has connections limit so I need like max-connections.
Would RSocket support this?
If It's not support, ...
1
vote
0
answers
428
views
RSocket : RejectedResumeException (0x4): unknown resume token
I am using rsocket starter in Spring Boot (2.5.3). I have a requester and responder set up and its working quite well (for all kind of rsocket communication). The issue is when I am trying to ...
1
vote
2
answers
1k
views
RSocket Metadata - custom object
I am playing with rsocket-java.
Is there any way to send custom object via metadata.?
I saw this code sample in their documenation.
RSocketStrategies strategies = RSocketStrategies.builder()
....
2
votes
1
answer
982
views
Java RSocket client connect with Spring RSocket channel
I have simple Spring boot RSocket service
@MessageMapping("msend")
public Flux<String> msend(String message) {
log.info("msend channel publish " + message);
...
3
votes
1
answer
568
views
Does spring-rsocket support return a RejectedSetupException in @ConnectMapping annotated method?
I follow the spring-rsocket-demo project to complete my code. I add some authentication logic in my server side code as follows. You can see I throw a exception in the after the authentication logic '...
4
votes
1
answer
266
views
Is there a way to see the REQUEST_N exchanges in Spring RSocket
I'm using the Spring support for RSocket, specifically the request-stream model. I.e.:
@MessageMapping("stream")
Flux<SubscriptionMessage> stream(final SubscriptionMessage request, @...
3
votes
1
answer
3k
views
rsocket routing metadata using RSocket-Java for Spring Rsocket Server
How do I setup routing metadata (in payload using just RSocket-Java when server is using Spring Boot Rsocket.
Flux<Payload> s = connection.flatMapMany(requester -> requester.requestStream(...
3
votes
0
answers
137
views
Adding CORS Configuration with Spring + RSocket + Websocket
How do I add CORS configuration to restrict to a set of allowed hosts to make requests to a websocket exposed via RSocket?
I tried @CrossOrigin annotation without any luck and I have tried adding the ...
1
vote
0
answers
342
views
RSocket Database (Cassandra or Postgresql) Performance study
I am trying to use RSocket for Microservices within my org. As we have lot to communicate and fetch from databases like Cassandra and Postgresql, I observed a dip in performance.
When I run a sample ...
1
vote
1
answer
1k
views
repeatWhenEmpty operator doesn't work in the context of an RSocket websocket request but it does in HTTP calls
I've come across a strange behaviour with the repeatWhenEmpty operator that doesn't make any sense to me. I uploaded a repository on Github with a minimum reproducible sample: https://github.com/...
2
votes
2
answers
2k
views
RSocket Js client not getting elements generated from a Spring Boot RSocket Server
Sample project available on Github: https://github.com/codependent/rsocket-rating-service
A Spring Boot RSocket server message mapping expects a requestResponse request, returning a simple POJO:
...
1
vote
1
answer
2k
views
RSocketRequester doesn't consider datamimeType
Trying to use Protobuf with RSocket, Requester doesn't consider dataMimeType set to application/protobuf or application/vnd.google.protobuf. I get error No decoder
Client Application
@...