It does not work while subscribe one topic the second time after reconnected

[GoogleCodeExporter]

org.dna.mqtt.moquette.messaging.spi.impl.subscriptions.TreeNode line 151 should 
be:

child.activate(clientID);

not:

child.deactivate(clientID);

Original issue reported on code.google.com by shimon.xin@gmail.com on 15 Nov 2013 at 7:42

[GoogleCodeExporter]

Hi Shimon,
please could you describe better the use case?

As I understood you have 
1) a client named A that connects to the broker, 
2) subscribe to one topic, for example /forecasts
3) disconnects
4) the same client reconnects to the broker 

What's the expected behaviour? That you receive the published messages to the 
topic where the client was previously subscribed?

Original comment by selva.an...@gmail.com on 18 Nov 2013 at 10:36

[GoogleCodeExporter]

Hi Selva,
My client configuration are: cleanSession=false,QoS=1, and the expected output 
is :
Topic: /topic, payload: Hello world MQTT!!5
Topic: /topic, payload: Hello world MQTT!!6
Topic: /topic, payload: Hello world MQTT!!7
Topic: /topic, payload: Hello world MQTT!!8
Topic: /topic, payload: Hello world MQTT!!9
Topic: /topic, payload: Hello world MQTT!!10
Topic: /topic, payload: Hello world MQTT!!11
Topic: /topic, payload: Hello world MQTT!!12
Topic: /topic, payload: Hello world MQTT!!13

but the output now is 
Topic: /topic, payload: Hello world MQTT!!5
Topic: /topic, payload: Hello world MQTT!!6
Topic: /topic, payload: Hello world MQTT!!7

and never recieve any messages !

Original comment by shimon.xin@gmail.com on 25 Nov 2013 at 7:01

Attachments:

• Sender.java
• Reciever.java

[GoogleCodeExporter]

after I changed "child.activate(clientID)" the output is :
Topic: /topic, payload: Hello world MQTT!!5
Topic: /topic, payload: Hello world MQTT!!6
Topic: /topic, payload: Hello world MQTT!!7
Topic: /topic, payload: Hello world MQTT!!11
Topic: /topic, payload: Hello world MQTT!!12
Topic: /topic, payload: Hello world MQTT!!13

So there may be a bug in QoS1 processing

Original comment by shimon.xin@gmail.com on 25 Nov 2013 at 7:08

[GoogleCodeExporter]

This issue was closed by revision f649ebff2488.

Original comment by selva.an...@gmail.com on 25 Nov 2013 at 5:56

• Changed state: Fixed