need help : subscribe on topic not working

[LovepreetSinghLotey]

SocketUtils.instance.stompClient!!.topic("topic.58.rooms")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({ topicMessage ->
println("topicMessage : ${topicMessage.payload}")
//this block is not working
}, { throwable -> throwable.printStackTrace() })

//code is written in kotlin
response from server is coming, and being loggin in the logcat but not receiving in the above subscribe block.

[testGumar]

Use this library its working fine in all use cases

https://github.com/SayyedUmar/Stomp-Android-Client

[LovepreetSinghLotey]

same problem occured with the library too, and it is the same library as this one @SayyedUmar

[testGumar]

What error are you getting, share the source code if possible here?

…

On Wed, May 1, 2019, 10:21 LovepreetSinghLotey ***@***.***> wrote: same problem occured with the library too, and it is the same library as this one @SayyedUmar <https://github.com/SayyedUmar> — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#145 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/ABV2UDFIBNKK4HVABI2Z4ITPTEOUDANCNFSM4HI6NGRQ> .

[marain87]

I am using the latest Spring boot 2 & RabbitMQ.
I also have this problem. Finally, I found that the problem is in "RabbitPathMatcher",
The "path" and "dest" are different.

You may need to custom your own PathMatcher.
My case is in "check3" solved.

`public class RabbitPathMatcher implements PathMatcher {

@Override
public boolean matches(String path, StompMessage msg) {
    String dest = msg.findHeader(StompHeader.DESTINATION);
    if (dest == null) return false;
    // for example string "lorem.ipsum.*.sit":

    // split it up into ["lorem", "ipsum", "*", "sit"]
    String[] split = path.split("\\.");
    ArrayList<String> transformed = new ArrayList<>();
    // check for wildcards and replace with corresponding regex
    for (String s : split) {
        switch (s) {
            case "*":
                transformed.add("[^.]+");
                break;
            case "#":
                // TODO: make this work with zero-word
                // e.g. "lorem.#.dolor" should ideally match "lorem.dolor"
                transformed.add(".*");
                break;
            default:
                transformed.add(s.replaceAll("\\*", ".*"));
                break;
        }
    }
    // at this point, 'transformed' looks like ["lorem", "ipsum", "[^.]+", "sit"]
    StringBuilder sb = new StringBuilder();
    for (String s : transformed) {
        if (sb.length() > 0) sb.append("\\.");
        sb.append(s);
    }
    String join = sb.toString();
    // join = "lorem\.ipsum\.[^.]+\.sit"
    Boolean check1 = dest.matches(join);

    //2nd check for same path
    Boolean check2 = path.equals(dest);

    //3rd check for last path e.g. (path : /exchange/amq.topic/100 , dest : /topic/100)
    Boolean check3 = false;
    if (transformed.size() > 0) {
        String lastPath = transformed.get(transformed.size() - 1);
        check3 = path.endsWith(lastPath);
    }

    return (check1 || check2 || check3);
}

}
`

[AlbertTitov]

Are you sure that you subscribe to the sending topic as well? -
mStompClient.send("/topic/hello-msg-mapping", "My first STOMP message!").subscribe();