[jira] [Commented] (APLO-367) Missing messages for MQTT subscribers if same topic subscribed

["Chunyu Hu (JIRA)" <ji...@apache.org>]

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

Chunyu Hu commented on APLO-367:
--------------------------------

$cat apollo.xml

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<!--
  Licensed to the Apache Software Foundation (ASF) under one or more
  contributor license agreements. See the NOTICE file distributed with
  this work for additional information regarding copyright ownership.
  The ASF licenses this file to You under the Apache License, Version
  2.0 (the "License"); you may not use this file except in compliance
  with the License. You may obtain a copy of the License at
  http://www.apache.org/licenses/LICENSE-2.0 Unless required by
  applicable law or agreed to in writing, software distributed under
  the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES
  OR CONDITIONS OF ANY KIND, either express or implied. See the
  License for the specific language governing permissions and
  limitations under the License.
-->

<!--
  For more information on how configure this file please
  reference:

  http://activemq.apache.org/apollo/versions/1.7/website/documentation/user-manual.html
  -->
<broker xmlns="http://activemq.apache.org/schema/activemq/apollo">

  <notes>
    The default configuration with tls/ssl enabled.
  </notes>

  <log_category console="console" security="security" connection="connection" audit="audit"/>


  <authentication domain="apollo"/>
  <!-- Give admins full access -->
  <access_rule allow="admins" action="*"/>
  <access_rule allow="*" action="connect" kind="connector"/>


  <virtual_host id="mybroker">
    <!--
      You should add all the host names that this virtual host is known as
      to properly support the STOMP 1.1 virtual host feature.
      -->
    <host_name>mybroker</host_name>
    <host_name>localhost</host_name>
    <host_name>127.0.0.1</host_name>

    <!-- Uncomment to disable security for the virtual host -->
    <!-- <authentication enabled="false"/> -->

    <!-- Uncomment to disable security for the virtual host -->
    <!-- <authentication enabled="false"/> -->
    <access_rule allow="users" action="connect create destroy send receive consume"/>


    <!-- You can delete this element if you want to disable persistence for this virtual host -->
    <leveldb_store directory="${apollo.base}/data"/>


  </virtual_host>

  <web_admin bind="http://0.0.0.0:61680"/>
  <web_admin bind="https://0.0.0.0:61681"/>

  <connector id="tcp" bind="tcp://0.0.0.0:1883" connection_limit="100000" protocol="mqtt">
   <mqtt  queue_prefix="/"/>
  </connector>

  <!--
  <connector id="tls" bind="tls://0.0.0.0:8883" connection_limit="100000" protocol="mqtt">
   <mqtt  queue_prefix="/"/>
  </connector>
  -->

  <!--
  <connector id="ws"  bind="ws://0.0.0.0:61623"  connection_limit="2000"/>
  <connector id="wss" bind="wss://0.0.0.0:61624" connection_limit="2000"/>
  -->

  <key_storage file="${apollo.base}/etc/keystore" password="password" key_password="password"/>

</broker>

> Missing messages for MQTT subscribers if  same topic subscribed
> ---------------------------------------------------------------
>
>                 Key: APLO-367
>                 URL: https://issues.apache.org/jira/browse/APLO-367
>             Project: ActiveMQ Apollo
>          Issue Type: Bug
>          Components: apollo-mqtt
>    Affects Versions: 1.7
>         Environment: ]# uname -a
> Linux 10-4-11-11 2.6.32-431.3.1.el6.centos.plus.x86_64 #1 SMP Fri Jan 3 19:15:22 UTC 2014 x86_64 x86_64 x86_64 GNU/Linux
> # cat /etc/redhat-release
> CentOS release 6.5 (Final)
>            Reporter: Chunyu Hu
>
> Suppose we have 3 terminal sessions A, B, C.
> In session A, we run publish commands.
> $mosquitto_pub -m "hello world" -t '/hello' -u 'admin' -P 'password'
> In session B and C, we run subscribe commands.
> $mosquitto_sub -m "hello world" -t '/hello' -u 'admin' -P 'password'
> Only one subscriber will receive the published messages from A. The sequence is like this.
> A pub a message
> B receive , but C dose not receive the message. 
> A pub another message,then
> C receive, but B dose not receive the message. 
> ... 



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