activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Marcos A. Reynoso" <marc...@epidataconsulting.com>
Subject Re: Re: Can't delete an offline durable subscription when there's a virtual topic configured in the broker
Date Fri, 25 Jan 2013 15:32:05 GMT
I tried with ActiveMQ 5.4.3, 5.7 and now I'm testing a snapshot of 5.8 and all
have the same behavior. The storage is Kahadb

On Fri, Jan 25, 2013 at 12:16 PM, SuoNayi <suonayi2006@163.com> wrote:

> Hi, what store(kahadb or database) and version are you using?
>
> At 2013-01-24 21:15:21,"Marcos A. Reynoso" <marcosr@epidataconsulting.com>
> wrote:
> >I understand it, but the subscriber I can't delete is a offline
> >durable subscriber for a topic when there's a virtual topic configured
> >in the broker.
> >
> >Here's the scenario:
> >
> >MyDurableTopic (topic)
> >----------------------------------------------------> Durable
> >Subscriber(offline)
> >         |
> >VirtualTopicConsumers.ClusterA.MyDurableTopic(Queue)
> >-------->(ClusterA queue consumers)
> >
> >
> >Without the virtual topic configuration, I can delete the offline
> >durable subscriber without problems.
> >
> >I hope you understand, I don't understand if it's a problem of my
> >settings, or normal operation.
> >
> >Thanks
> >Marcos
> >
> >
> >
> >On Wed, Jan 23, 2013 at 11:36 PM, SuoNayi <suonayi2006@163.com> wrote:
> >> Where can you find the durable subscribers of the virtual topic?Virtual
> topic is not a real topic and it's transformed into queues by demand in
> runtime.So you can think it as a combination of queues.You can see the
> subscribers of the Virtual topic in Queue view  page in web console.
> >>
> >> At 2013-01-24 00:36:51,"Marcos A. Reynoso" <
> marcosr@epidataconsulting.com> wrote:
> >>>Hi everyone,
> >>>
> >>>I'm having a problem deleting offline durable subscribers (both from
> >>>the activeMQ web console or unsubscribing) causing the storage to get
> >>>filled.
> >>>
> >>>Then, in the ActiveMQ web console I press delete on the offline
> >>>subscriber and it disappears, but the topic does not reduce the Number
> >>>Of Consumers. When restarting the broker, the offline subscriber
> >>>appears again.
> >>>
> >>>I found that this happens when I use virtual topics.
> >>>
> >>>If someone knows what might be happening I will be very grateful
> >>>
> >>>Thanks
> >>>Marcos
> >>>
> >>>---------------------
> >>>This is my setup:
> >>>
> >>>java version "1.6.0_31"
> >>>ActiveMQ 5.7(standalone)
> >>>OS: Red Hat Enterprise Linux Server release 5.8 (Tikanga) (kernel
> >>>2.6.18-308.el5)
> >>>
> >>>My activemq.xml:
> >>>
> >>><beans
> >>>  xmlns="http://www.springframework.org/schema/beans"
> >>>  xmlns:amq="http://activemq.apache.org/schema/core"
> >>>  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> >>>  xsi:schemaLocation="http://www.springframework.org/schema/beans
> >>>http://www.springframework.org/schema/beans/spring-beans.xsd
> >>>  http://activemq.apache.org/schema/core
> >>>http://activemq.apache.org/schema/core/activemq-core.xsd
> >>>  http://activemq.apache.org/camel/schema/spring
> >>>http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
> >>>
> >>>    <!-- Allows us to use system properties as variables in this
> >>>configuration file -->
> >>>    <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
> >>>
> >>>    <broker xmlns="http://activemq.apache.org/schema/core"
> >>>brokerName="static-broker1" dataDirectory="${activemq.data}">
> >>>
> >>><!-- Destination specific policies using destination names or wildcards
> -->
> >>>        <destinationPolicy>
> >>>            <policyMap>
> >>>                <policyEntries>
> >>>                    <policyEntry queue=">" producerFlowControl="true"
> >>>memoryLimit="20mb">
> >>>                        <deadLetterStrategy>
> >>>                          <individualDeadLetterStrategy
> >>>queuePrefix="DLQ." useQueueForQueueMessages="true" />
> >>>                        </deadLetterStrategy>
> >>>                    </policyEntry>
> >>>                    <policyEntry topic=">" producerFlowControl="true"
> >>>memoryLimit="20mb">
> >>>                    </policyEntry>
> >>>                </policyEntries>
> >>>            </policyMap>
> >>>        </destinationPolicy>
> >>>
> >>>        <!-- Use the following to configure how ActiveMQ is exposed in
> JMX -->
> >>>        <managementContext>
> >>>            <managementContext createConnector="true"/>
> >>>        </managementContext>
> >>>
> >>>        <networkConnectors>
> >>>        </networkConnectors>
> >>>
> >>>        <persistenceAdapter>
> >>>            <kahaDB directory="${activemq.data}/static-broker1/kahadb"
> />
> >>>        </persistenceAdapter>
> >>>
> >>>        <!--  The maximum amount of space the broker will use before
> >>>slowing down producers -->
> >>>        <systemUsage>
> >>>            <systemUsage>
> >>>                <memoryUsage>
> >>>                    <memoryUsage limit="20 mb"/>
> >>>                </memoryUsage>
> >>>                <storeUsage>
> >>>                    <storeUsage limit="1 gb" name="foo"/>
> >>>                </storeUsage>
> >>>                <tempUsage>
> >>>                    <tempUsage limit="100 mb"/>
> >>>                </tempUsage>
> >>>            </systemUsage>
> >>>        </systemUsage>
> >>>
> >>>        <destinationInterceptors>
> >>>              <virtualDestinationInterceptor>
> >>>                <virtualDestinations>
> >>>                      <virtualTopic name=">"
> >>>prefix="VirtualTopicConsumers.*." />
> >>>                </virtualDestinations>
> >>>              </virtualDestinationInterceptor>
> >>>        </destinationInterceptors>
> >>>
> >>>        <transportConnectors>
> >>>            <transportConnector name="openwire" uri="tcp://
> 0.0.0.0:61616"/>
> >>>        </transportConnectors>
> >>>
> >>>    </broker>
> >>><import resource="jetty.xml"/>
> >>>
> >>></beans>
> >
> >
> >
> >--
> >Epidata Consulting | Deploying Ideas
> >Marcos A. Reynoso | Consultor
> >marcosr@epidataconsulting.com | Cel: (54911) 6425 4669
>
> >----------------------------------------------------------------------------------------------------------------------------
> >Argentina: MaipĂș 521 Piso 1 Of. A | Buenos Aires | Of: (5411) 5031 0060
> >Chile: Apoquindo 3600 Piso 7 y 9 | Las Condes - Santiago | Of: (+56) 2
> 495 8450
>
> >---------------------------------------------------------------------------------------------------------------------------
> >www.epidataconsulting.com
> >Linkedin | Facebook | Twitter
>



-- 
*Epidata Consulting | Deploying Ideas
Marcos A. Reynoso | Consultor
marcosr@epidataconsulting.com <mail@epidataconsulting.com> | Cel: (54911)
6425 4669
----------------------------------------------------------------------------------------------------------------------------
Argentina: MaipĂș 521 Piso 1 Of. A | Buenos Aires | Of: (5411) 5031 0060
Chile: Apoquindo 3600 Piso 7 y 9 | Las Condes - Santiago | Of: (+56) 2 495
8450
---------------------------------------------------------------------------------------------------------------------------
 www.epidataconsulting.com
 Linkedin <http://bit.ly/epidatalinkedin> |
Facebook<http://www.facebook.com/epidata.consulting>
 | Twitter <http://twitter.com/epidata>
*

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message