[jira] [Created] (AMQ-5466) Lost persistent message sent to detached consumer before keepAliveInterval exceed

["Nikolay Pakudin (JIRA)" <ji...@apache.org>]

Nikolay Pakudin created AMQ-5466:
------------------------------------

             Summary: Lost persistent message sent to detached consumer before keepAliveInterval exceed
                 Key: AMQ-5466
                 URL: https://issues.apache.org/jira/browse/AMQ-5466
             Project: ActiveMQ
          Issue Type: Bug
         Environment: Maс OS X 10.9.5
apache-activemq-5.10.0
java version "1.6.0_65" Java(TM) SE Runtime Environment (build 1.6.0_65-b14-462-11M4609) Java HotSpot(TM) 64-Bit Server VM (build 20.65-b04-462, mixed mode)
            Reporter: Nikolay Pakudin


What I do

- There is a MQTT client - Android application. It connects to server and creates topic.
- Sent there message with all default settings and payload {"name":"1st message"} by ActiveMQ console. Message is successfully delivered. If open Active Subscribers, enqueued = 1, and dequeued = 1
- Turn on Airplane mode at Android, so there is no connection really, but ActiveMQ still shows it in Active Subscribers.
- Send message WITH checkbox Persistent delivery and payload {"name":"persistent"} If open Active Subscribers, enqueued = 2, and dequeued = 2
- Send message WITHOUT checkbox Persistent delivery and payload {"name":"not persistent"} If open Active Subscribers, enqueued = 3, and dequeued = 2
- Turn off Airplane mode at Android, connection appears and only one message is delivered - not persistent.


What I tried

- Restart ActiveMQ.
- Send a few persistent and a few not persistent messages - not persistent are delivered, persistent aren't
- Delete ActiveMQ and extract again.
- Rebuild Android application and clean all data at phone.

Messages, sent after keepAliveInterval exceed are delivered successfully.

I reproduced it at least 20 times.
I found http://activemq.2283324.n4.nabble.com/Random-persistent-messages-lost-tt3826331.html , but it seems, that I have the other problem.

Configuration

conf/activemq.xml - default, with change 1 line (twice added "+nio")

<transportConnector name="mqtt+nio" uri="mqtt+nio://0.0.0.0:1883maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)