Skip to main content
Filter by
Sorted by
Tagged with
0 votes
0 answers
39 views

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 ...
user30673520's user avatar
1 vote
0 answers
112 views

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', ...
linkser lin's user avatar
0 votes
0 answers
19 views

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 ...
seal_90's user avatar
0 votes
0 answers
53 views

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 ...
fernando1979's user avatar
  • 1,959
0 votes
0 answers
18 views

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 ...
Jumple's user avatar
  • 35
1 vote
0 answers
49 views

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 ...
Anant Gupta's user avatar
  • 1,169
2 votes
1 answer
4k views

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 ...
ASD's user avatar
  • 21
5 votes
0 answers
369 views

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 ...
aha's user avatar
  • 3,769
1 vote
0 answers
105 views

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|...
nightlytrails's user avatar
2 votes
0 answers
139 views

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....
Кирилл Мололкин's user avatar
0 votes
1 answer
544 views

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 ...
metrotrain's user avatar
0 votes
1 answer
190 views

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 ...
Maciej Lach's user avatar
  • 1,691
0 votes
1 answer
512 views

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 ...
Gergo's user avatar
  • 308
2 votes
2 answers
2k views

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....
rupweb's user avatar
  • 3,368
0 votes
1 answer
221 views

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 ...
Essam Almansouri's user avatar
1 vote
3 answers
745 views

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 ...
Shivangi Varshney's user avatar
-1 votes
1 answer
653 views

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)...
Mahdi Amini's user avatar
1 vote
0 answers
937 views

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 ...
user1578872's user avatar
  • 9,268
3 votes
0 answers
495 views

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-...
user1578872's user avatar
  • 9,268
1 vote
2 answers
114 views

I have config class for RSocketSecurity Something like that @Configuration @EnableRSocketSecurity @EnableReactiveMethodSecurity class RSocketAuthConfiguration { and authorization for it (allows only ...
Анна Цицилюк's user avatar
3 votes
2 answers
943 views

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 ...
Stezy's user avatar
  • 400
3 votes
1 answer
2k views

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-...
user1578872's user avatar
  • 9,268
0 votes
1 answer
890 views

I've set up rsocket metrics using rsocket-micrometer on the CLIENT side, by configuring the RSocketConnector with interceptors, like this (Kotlin): rSocketReqesterBuilder.rsocketConnector { ...
Eric J Turley's user avatar
1 vote
0 answers
118 views

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 ...
gadams00's user avatar
  • 879
4 votes
0 answers
339 views

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, ...
reperion's user avatar
  • 149
1 vote
0 answers
428 views

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 ...
Bitan Biswas's user avatar
1 vote
2 answers
1k views

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() ....
RamPrakash's user avatar
  • 3,600
2 votes
1 answer
982 views

I have simple Spring boot RSocket service @MessageMapping("msend") public Flux<String> msend(String message) { log.info("msend channel publish " + message); ...
Armen Arzumanyan's user avatar
3 votes
1 answer
568 views

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 '...
Kami Wan's user avatar
  • 774
4 votes
1 answer
266 views

I'm using the Spring support for RSocket, specifically the request-stream model. I.e.: @MessageMapping("stream") Flux<SubscriptionMessage> stream(final SubscriptionMessage request, @...
BobW's user avatar
  • 91
3 votes
1 answer
3k views

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(...
user3549576's user avatar
3 votes
0 answers
137 views

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 ...
Shahul's user avatar
  • 69
1 vote
0 answers
342 views

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 ...
Karthik Palanivelu 's user avatar
1 vote
1 answer
1k views

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/...
codependent's user avatar
  • 24.7k
2 votes
2 answers
2k views

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: ...
codependent's user avatar
  • 24.7k
1 vote
1 answer
2k views

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 @...
Karthik Prasad's user avatar