activemq - Camel route "to" specific websocket endpoint -


i have camel routes mina sockets , jetty websockets. able broadcast message clients connected websocket how send message specific endpoint. how maintain list of connected clients client id reference can route specific client. possible? able mention dynamic client in uri?

or maybe thinking wrong , need create topics on active mq , have clients subscribe it. mean create topic every websocket client? , route message right topic.

am atleast on right track here, examples can point out? google not helpful.

the approach take depends on how sensitive client information is. downside of single topic selectors can subscribe topic without selector , see information - not want do.

a better scheme use message distribution mechanism (set of camel routes) act intermediary between websocket clients , system producing messages. mechanism responsible distributing messages single destination client-specitic destinations. have worked on couple of banking web front-ends used similar scheme.

in order work first generate each user distinct token/uuid; presented user when session established (usually through sort of profile query/message). it's essential uuid can worked out hash of clientid rather being stored in db, used time , want make sure worked out quickly.

the user uses information connect specific topics use uuid suffix. example 2 users subscribing orderconfirmation topic each subscribe own version of topic:

clienta -> orderconfirmation.71jqsd87162iuhw78162wd7168 clientb -> orderconfirmation.76232hdwe7r23j92irjh291e0d

to keep track of "presence", clients need periodically send heartbeat message containing clientid well-known topic distribution mechanism listens on. clients should not able subscribe topic reads (see activemq security). message distribution mechanism needs keep in memory data structure contains clientid , time heartbeat last seen.

when message received distribution mechanism, checks whether clientid received message has "live/present" session, determines uuid client, , broadcasts message on appropriate topic.

over time create large number of topics on broker don't want hanging around when user has gone away. can configure activemq delete these if have been inactive time.


Comments

Post a Comment

Popular posts from this blog

linux - xterm copying to CLIPBOARD using copy-selection causes automatic updating of CLIPBOARD upon mouse selection -

i've tried various ways coerce xterm (versions 285 , 292) copy selection clipboard clipboard whenever press ctrl-shift-c. promising way far has been, in ~/.xresources, put this: xterm*vt100.translations: #override \ ctrl shift <keypress> c: copy-selection(clipboard) \n\ ctrl shift <keypress> v: insert-selection(clipboard) ctrl-shift-v works perfectly, copying has nuance... if restart xterm, highlighting text puts things in primary clipboard; expected, proper, default behavior. if hit ctrl-shift-c, copies current selection clipboard clipboard. the bug, however, if highlight text after first time pressed ctrl-shift-c, you'll see highlighting copies both primary and clipboard. cannot figure out how stop xterm updating clipboard upon selection... , doesn't make sense me in first place. i said, @ specific point in time, copy selection clipboard... yet starts updating automatically upon selection after doing once... anyone have workaround...
Read more

c++ - qgraphicsview horizontal scrolling always has a vertical delta -

Image
i've subclassed qgraphicsview custom canvas used in cad application. i've reimplemented qgraphicsview::wheelevent check keyboard modifiers control key and, if control key pressed, zoom. i'm trying implement horizontal scroll when user holds shift , uses wheel. the problem i'm having horizontal scrolling always scrolls 0.279. not huge problem, hugely annoying , points else being wrong. so, here questions: is right way implement horizontal scrolling? if not, is? how eliminate delta of 0.279? thanks in advance. code , sample output below void myview::zoom(int delta) { double factor = pow(1.2, delta/abs(delta)); this->scale(factor, factor); } void myview::scrollhorizontal(int level) { qpointf center = maptoscene(viewport()->rect().center()); qdebug() << "center: " << center.x() << ", " << center.y(); centeron(qpointf(center.x() - level, center.y())); } void myview::wheelevent(qwheeleve...
Read more