search

adsetiawan / moquette-mqtt

Automatically exported from code.google.com/p/moquette-mqtt
Apache License 2.0
0 stars 0 forks source link

MQTTHandler.m_clientIDs concurrency and cleanup #7

Closed GoogleCodeExporter closed 8 years ago

GoogleCodeExporter commented 8 years ago 
1. m_clientIDs must be ConcurrentHashMap
2. there is no [m_clientIDs.remove] present

Original issue reported on code.google.com by denysenk...@gmail.com on 13 Nov 2012 at 7:11

GoogleCodeExporter commented 8 years ago 
m_clientdIDs is no more part of MQTTHandler, but it's in 
org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java, and the 
SimpleMessaging is execute by only one thread and is isoltaed by MINA acceptors 
by a Disruptor's RingBuffer.

Original comment by selva.an...@gmail.com on 18 Nov 2012 at 2:46