camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Claus Ibsen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-10949) Websocket clients get message from all resources on one port
Date Tue, 07 Mar 2017 12:52:38 GMT

    [ https://issues.apache.org/jira/browse/CAMEL-10949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899380#comment-15899380
] 

Claus Ibsen commented on CAMEL-10949:
-------------------------------------

Contributions is welcome

> 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
>            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)

Mime
View raw message