You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "onder sezgin (JIRA)" <ji...@apache.org> on 2017/03/29 20:59:41 UTC

[jira] [Assigned] (CAMEL-10949) Websocket clients get message from all resources on one port

     [ https://issues.apache.org/jira/browse/CAMEL-10949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

onder sezgin reassigned CAMEL-10949:
------------------------------------

    Assignee: onder sezgin

> Websocket clients get message from all resources on one port 
> -------------------------------------------------------------
>
>                 Key: CAMEL-10949
>                 URL: https://issues.apache.org/jira/browse/CAMEL-10949
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-websocket
>            Reporter: Ravi Godbole
>            Assignee: onder sezgin
>            Priority: Minor
>
> Routebuider configuration in which only resource URI is different while port is same.
> 1. newsTopic
> 2. stockQuoteTopic
>  Ideally other clients connecting to newsTopic should get messages published
>  on this topic only but they are also getting messages published on stockQuoteTopic.
>  On further investigation I found out that memory store used to by sendAll
>  is shared by all resource uri for a given port in the server.
>  from("activemq:topic:newsTopic").to("websocket://
>  0.0.0.0:9090/newsTopic?sendToAll=true");
>         from("activemq:topic:stockQuoteTopic").to("websocket://
>  0.0.0.0:9090/stockQuoteTopic?sendToAll=true");
>  Sample Ouput received from client 
>  2017-03-06 15:35:15.789:INFO::main: Logging initialized @313ms
>  Connected to server
>  Message received from server:MSFT        [ published on stockQuoteTopic. Expected ..]
>  Message received from server:CNBC News   [ published on newsTopic. should not have received ]
>  Message received from server:BBC News    [ published on newsTopic. should not have received ]



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)