Clarity regarding how to send requests from Server -> rsocket-js client(s) about spring-flights

[airduster]

never mind figured this out was passing responder incorrectly into rsocket-js constructor :/

[EBoshart]

Hi airduster, I'm running into the exact same issue you described
I am able to receive data through regular request / response, however I am not able to asynchronously send server data to all connected clients.

I'm trying to get your testFirstAndForget method to work, but whatever the server sends back is never received by the client.

My client configuration looks something like this:

client = new RSocketClient({ serializers: { data: JsonSerializer, metadata: JsonMetadataSerializer, }, setup: { // ms btw sending keepalive to server keepAlive: 10000, // ms timeout if no keepalive response lifetime: 20000, dataMimeType: 'application/json', metadataMimeType: "application/vnd.spring.rsocket.metadata+json", }, transport: new RSocketWebSocketClient({url: "ws://localhost:8080/rsocket"}), responder: new messageHandler() });

export class messageHandler { fireAndForget(payload) : void { console.log("received from server :" + payload.data) }

Any ideas would be greatly appreciated

[airduster]

Hi airduster, I'm running into the exact same issue you described
I am able to receive data through regular request / response, however I am not able to asynchronously send server data to all connected clients.

I'm trying to get your testFirstAndForget method to work, but whatever the server sends back is never received by the client.

My client configuration looks something like this:

client = new RSocketClient({ serializers: { data: JsonSerializer, metadata: JsonMetadataSerializer, }, setup: { // ms btw sending keepalive to server keepAlive: 10000, // ms timeout if no keepalive response lifetime: 20000, dataMimeType: 'application/json', metadataMimeType: "application/vnd.spring.rsocket.metadata+json", }, transport: new RSocketWebSocketClient({url: "ws://localhost:8080/rsocket"}), responder: new messageHandler() });

export class messageHandler { fireAndForget(payload) : void { console.log("received from server :" + payload.data) }

Any ideas would be greatly appreciated

Just seeing this. Your code looks correct. My guess is the client is receiving the message but it is being swallowed up somewhere in the rsocket-js code. Place a breakpoint deep inside the rsocket-js code as soon as a msg to determine where it is being swallowed up. Might have something to do with with RSocketStrategiesCustomizer. Did you define that bean as I described above?

[EBoshart]

Hi Airduster, thanks for your reply
A couple days after my original post I realised my error.

Whenever I reloaded my client because of local changes the server would still keep the old socket, then when iterating over the connected clients it would error because it could no longer find that socket, so I added an onError -> remove connection and that seems to solve it.