Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
    RupWeb
    @rupweb
    image.png
    0001 Error {000}: [00000201] No handler for destination ''
    at the client
    so on the server we have
        @MessageMapping("quotes")
        Flux<Object> quotes(@Payload String message) {            
            return priceService.generatePrices(message);
        }
    on the client
        var stream = client.RequestStream(
            resultmapper: result => (Data: PdxNet.Deserialize<QuoteClient>(result.data), Metadata: PdxNet.Deserialize<QuoteClient>(result.metadata)),
            data: PdxNet.Serialize(quoteRequest), metadata: PdxNet.Serialize(quoteRequest));
    sorry for the n00b route questions on net client ! ;0
    RupWeb
    @rupweb
    hang on i think we've got it now
    RupWeb
    @rupweb
    nope... how can I route the client.RequestStream binary call to the quotes endpoint please?
    RupWeb
    @rupweb
    After setting up the binary stream with C# [Serializable] objects (as above resultmapper and data) then I am using the stream.ForEachAsync
    await stream.ForEachAsync(quotes => Console.WriteLine($"RawDemo.OnNext===>[{quotes.Metadata}]{quotes.Data}"));
    Oleh Dokuka
    @OlegDokuka
    @rupweb you have to encode route in a proper way
    in rsocket-.net we do not have composite metadata support as of this moment
    thus, you would need to do that yourselves or you would need to encode your route as a plain string
    I have no idea how PdxNet works, but it is defenitelly will not be handled by spring
    also, rsocket-routing is not the right place, better to ask at https://gitter.im/rsocket/rsocket-dotnet for the dotnet impl
    RupWeb
    @rupweb
    thanks.... i got a string implementation going using
        byte[] intBytes = BitConverter.GetBytes(6);
        string stringBytes = Encoding.Default.GetString(intBytes, 0, 1);
        metaData = stringBytes + "quotes";
        var stringclient = new RSocketClient.ForStrings(client);    //A simple client that uses UTF8 strings instead of bytes.
        await stringclient.RequestStream(json, metaData)
            .ForEachAsync((result) =>
            {
                Console.WriteLine($"Result ===> {result}");
             });
    just want to get the binary impl going
    Oleh Dokuka
    @OlegDokuka
    var client = new RSocketClient(new WebSocketTransport("ws://localhost:8080/"));
                await client.ConnectAsync(new RSocketOptions()
                {
                    MetadataMimeType = "message/x.rsocket.routing.v0",
                    DataMimeType = "application/octet-stream"
                });
    
    
                Console.WriteLine("Requesting Raw Protobuf Stream...");
    
                var route = new ReadOnlySequence<byte>(new byte[]
                {
                    (byte) Encoding.UTF8.GetByteCount("request.stream")
                }.Concat(Encoding.UTF8.GetBytes("request.stream")).ToArray());
    
                //Make a Raw binary call just to show how it's done.
                var stream = client.RequestStream(
                    resultmapper: result => (Data: Encoding.UTF8.GetString(result.data.ToArray()), Metadata: Encoding.UTF8.GetString(result.metadata.ToArray())),
                    data: new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("test")), metadata: route);
    
                await stream.ForEachAsync(persons => Console.WriteLine($"RawDemo.OnNext===>[{persons.Metadata}]{persons.Data}"));
    that what works for me
    RupWeb
    @rupweb
    Thanks :) got the route working
    Oleh Dokuka
    @OlegDokuka
    @rupweb as I mentioned before, this gitter channel is for a different project, can we move our future conversations to https://gitter.im/rsocket/rsocket-dotnet
    also, what you mentioned looks like a bug
    thus better to create an issue at the https://github.com/rsocket/rsocket-net/issues/new/choose
    Bau Nguyen Van
    @baudcctak54_gitlab
    hi Oleh. Can i implement routing client in javascript?
    2 replies
    kevin
    @kevinat

    Hi Oleh, Can I use this dependency in my spring boot project?

      <dependency>
          <groupId>io.rsocket.routing</groupId>
          <artifactId>rsocket-routing-broker-spring</artifactId>
          <version>0.3.0-SNAPSHOT</version>
        </dependency>

    I configured spring snapshot repo in my pom, but got "Not authorized" when compile.

    5 replies
    pedrorlmarques
    @pedrorlmarques
    Hello, is there any plan to have a rsocket-routing-client for JS?
    1 reply
    Anders Clausen
    @AndersClausen
    @OlegDokuka @spencergibb would RSocket work with Hashicorp Consul or is it one-or-the-other?
    Spencer Gibb
    @spencergibb
    I think so. we plan on integrating with discovery to find the cluster
    Anders Clausen
    @AndersClausen
    Excellent. Thanks for the quick reply
    Eric Turley
    @ericjturley
    Hiya :)
    I'm trying to figure out how RSocket will work across a traditional Application Load Balancer (as opposed to a Network Load Balancer) behind that are ephemeral K8s pods.
    Is it somehow stateless in some way - particuarly with regard to a REQUEST-CHANNEL mode. If a pod went down, how could that work be transitioned?
    If this is documented, I'd be happy if you just pointed me at it.
    11 replies
    Jon Brisbin
    @jbrisbin
    hey there! just wondering what state rsocket-routing is in and if it's worth building a new component on? no docs, no readme, etc...
    2 replies
    Philippe Soares
    @psoares
    Hi! Does anyone know what happened to netifi?
    18 replies
    utkarsh2811
    @utkarsh2811
    hi guys, I am trying to setup rsocket client for a rsocket server which is built using RSocketRequester wrapper. In other words, my client is a regular java app whereas is my server is springboot app, hence having this wrapper RSocketRequester. Any help on how I can do this?
    2 replies
    the current problem that I face is my server is having certain methods which are annotated with some routes example: @MessageMapping("pipeline.transformers.next") but i dont understand how to route to these methods from my client without using RSocketRequester wrapper which has built in methods like route(...)
    Azurine
    @jeehyun-lee
    Hello, is there NO updates here?
    I was using 0.2.0-SNAPSHOT and now gradle couldn't find it anymore.
    Oleh Dokuka
    @OlegDokuka
    It is because bintray went out
    We will fix that soon
    Bau Nguyen Van
    @baudiachatb:matrix.org
    [m]

    Hi everyone.
    I have a question.

    is Rsocket-routing-client-spring support spring security?

    i was cofig spring security for Rsocket-routing-client-spring but it have not effect.

    sbansal-tetragon
    @sbansal-tetragon
    Hi everyone, when do you reckon rsocket broker will be ready for production use ?
    sbansal-tetragon
    @sbansal-tetragon
    I am looking to use RoutingRSocketRequester with backpressure and retry but cant find a way to pass that as property in my client. is there a way to do it ?
    sameer asaad
    @sameer_asaad_twitter
    Is there an example on how to use rSocket-broker without spring?
    fgfaure
    @fgfaure

    hi there, I found rsocket really interesting and promising. With a colleague of mine, we have setup a little poc to test many features of RSocket and RSocket spring libs.

    As for now, we have setup web javascript client talking to a java broker built ontop of rsocket-routing-broker-spring.
    And our javascript client uses js libs rsocket-core and rsocket-websocket-client.

    BUT (there is always a but), our js client can't succeed in connecting to java broker. And the error thrown back to brower app states the following:
    RSocket error 0x3 (REJECTED_SETUP): RouteSetup not found in metadata. See error source property for details.

    Partial Stack

    RSocket open channel request error: Error: RSocket error 0x3 (REJECTED_SETUP): RouteSetup not found in metadata. See error source property for details.
    at createErrorFromFrame (RSocketFrame.js?626d:271)
    at RSocketMachineImpl._handleConnectionFrame (RSocketMachine.js?4c6f:605)
    at Object.eval [as onNext] (RSocketMachine.js?4c6f:252)
    at FlowableSubscriber.onNext (Flowable.js?468d:249)
    at ReassemblySubscriber.onNext (ReassemblyDuplexConnection.js?899c:132)
    at eval (RSocketWebSocketClient.js?9ba9:80)
    at Set.forEach (<anonymous>)
    at WebSocket.eval (RSocketWebSocketClient.js?9ba9:80)

    As far as we understand it, web-app doesn't send setup configuration as expected by java broker but we can not find any useful documentation or ressource.

    So, here our question, does someone have a pure javascript example or sample showing how a js client sends a valid RouteSetup to a java broker?

    Thanks in advance

    PS : Please be kind for any english mistakes (not fluent) ;)

    kevin
    @kevinat
    @OlegDokuka What about scalecube services? Looks like it takes all benefit of rsocket and reactive, and no centralized broker needed. Is this a rsocket-routing-broker alternative? or something different?
    Lachsokhour
    @Lachsokhour
    This message was deleted
    Lachsokhour
    @Lachsokhour
    hello everyone, @OlegDokuka how to implement io.rsocket.routing-client with angular