activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "wanged (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APLO-370) Durable subscriptions can not work sometimes
Date Sun, 02 Nov 2014 06:42:33 GMT

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

wanged commented on APLO-370:
-----------------------------

See dsub details, It's "Queue Size" has 5 messages, but "subscribes" waiting on producer.

> Durable subscriptions can not work sometimes
> --------------------------------------------
>
>                 Key: APLO-370
>                 URL: https://issues.apache.org/jira/browse/APLO-370
>             Project: ActiveMQ Apollo
>          Issue Type: Bug
>          Components: apollo-mqtt
>    Affects Versions: 1.7
>         Environment: centos 6.5
>            Reporter: wanged
>
> I use durable subscriptions for mqtt. when the client connected and subscripted, sometimes
receive message from dsub, sometimes not receive message(at this time dsub has messages, unless
the client disconnect and reconnect) .
> my config is:
> <broker xmlns="http://activemq.apache.org/schema/activemq/apollo" validation="strict">
>   <log_category console="console" security="security" connection="connection" audit="audit"/>
>   <authentication domain="apollo"/>
>   <access_rule allow="admins" action="*"/>
>   <access_rule allow="*" action="connect" kind="connector"/>
>   <auto_gc interval="60" />
>   <virtual_host id="yey">
>     <host_name>localhost</host_name>
>     <host_name>127.0.0.1</host_name>
>     <access_rule allow="apps" action="connect create receive consume"/>
>     <access_rule allow="mgts" action="connect create send receive consume"/>
>     <dsub tail_buffer="10k" full_policy="drop head" auto_delete_after="0" quota="102400"/>
>     <leveldb_store directory="/data/apollo/data"/>    
>   </virtual_host>
>   <web_admin bind="http://localhost:61680"/>
>   <connector id="tcp" bind="tcp://0.0.0.0:1883" protocol="mqtt">
>     <mqtt max_message_length ="10240" />
>   </connector>
>   <key_storage file="${apollo.base}/etc/keystore" password="password" key_password="password"/>
> </broker>



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

Mime
View raw message