activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: message store
Date Mon, 08 Feb 2010 11:43:03 GMT
You may need to tune the maxBrowsePage size destination policy option. This
is a limit on the amount of messages that the broker will bring into memory
for a jms browser. Typically the broker will page in 200 messages at a time
and 2*200 for a browser. The intention is to limit the impact of browsing on
regular consumers w.r.t to memory usage.
My guess is that you are hitting this limit, assuming that the web console
is using a queue browser under the hood. I did not check that btw.

On 5 February 2010 15:40, marcin80 <mtroscia@gmail.com> wrote:

>
> Hi,
>
> I'm using ActiveMQ 5.2 (FuseESB 4).
> I have durable queue whitch contains about 3000 messages (via jconsole).
> But
> when I try to browse queue using activemq web console I can see only 600
> messages.
>
> My broker's configuration is:
>
>  <broker xmlns="http://activemq.apache.org/schema/core"
> brokerName="default"
> dataDirectory="${servicemix.base}/data/activemq/default"
> useShutdownHook="false">
>
>        <!-- Destination specific policies using destination names or
> wildcards -->
>        <destinationPolicy>
>            <policyMap>
>                <policyEntries>
>                    <policyEntry queue=">" memoryLimit="40mb"/>
>                    <policyEntry topic=">" memoryLimit="40mb">
>                        <subscriptionRecoveryPolicy>
>                            <lastImageSubscriptionRecoveryPolicy/>
>                        </subscriptionRecoveryPolicy>
>                    </policyEntry>
>                </policyEntries>
>            </policyMap>
>        </destinationPolicy>
>
>        <!-- Use the following to configure how ActiveMQ is exposed in JMX
> -->
>        <managementContext>
>            <managementContext createConnector="false"/>
>        </managementContext>
>
>        <!-- The store and forward broker networks ActiveMQ will listen to
> -->
>        <networkConnectors>
>            <!-- by default just auto discover the other brokers -->
>            <!--
>            <networkConnector name="default-nc"
> uri="multicast://default?group=uom"/>
>            -->
>            <!-- Example of a static configuration:
>            <networkConnector name="host1 and host2"
> uri="static://(tcp://host1:61616,tcp://host2:61616)"/>
>            -->
>        </networkConnectors>
>
>        <persistenceAdapter>
>            <amqPersistenceAdapter syncOnWrite="false"
> directory="${servicemix.base}/data/activemq/default" maxFileLength="40
> mb"/>
>        </persistenceAdapter>
>
>        <!-- Use the following if you wish to configure the journal with
> JDBC -->
>        <!--
>        <persistenceAdapter>
>            <journaledJDBC dataDirectory="${activemq.base}/data"
> dataSource="#postgres-ds"/>
>        </persistenceAdapter>
>        -->
>
>        <!-- Or if you want to use pure JDBC without a journal -->
>        <!--
>        <persistenceAdapter>
>            <jdbcPersistenceAdapter dataSource="#postgres-ds"/>
>        </persistenceAdapter>
>        -->
>
>        <!--  The maximum about of space the broker will use before slowing
> down producers -->
>        <systemUsage>
>            <systemUsage>
>                <memoryUsage>
>                    <memoryUsage limit="40 mb"/>
>                </memoryUsage>
>                <storeUsage>
>                    <storeUsage limit="1 gb" name="foo"/>
>                </storeUsage>
>                <tempUsage>
>                    <tempUsage limit="100 mb"/>
>                </tempUsage>
>            </systemUsage>
>        </systemUsage>
>
>
>        <!-- The transport connectors ActiveMQ will listen to -->
>        <transportConnectors>
>            <transportConnector name="openwire"
> uri="tcp://localhost:61616"/>
> <!--discoveryUri="multicast://default?group=uom"/>-->
>            <transportConnector name="stomp" uri="stomp://localhost:61613"/>
>        </transportConnectors>
>
>    </broker>
>
>    <bean id="activemqConnectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory">
>        <property name="brokerURL" value="tcp://localhost:61616" />
>    </bean>
>
>    <bean id="pooledConnectionFactory"
> class="org.apache.activemq.pool.PooledConnectionFactoryBean">
>        <property name="maxConnections" value="8" />
>        <property name="maximumActive" value="500" />
>        <property name="transactionManager" ref="transactionManager" />
>        <property name="connectionFactory" ref="activemqConnectionFactory"
> />
>        <property name="resourceName" value="activemq.default" />
>    </bean>
>
>    <bean id="resourceManager"
> class="org.apache.activemq.pool.ActiveMQResourceManager"
> init-method="recoverResource">
>          <property name="transactionManager" ref="transactionManager" />
>          <property name="connectionFactory" ref="activemqConnectionFactory"
> />
>          <property name="resourceName" value="activemq.default" />
>    </bean>
>
>    <osgi:reference id="transactionManager"
> interface="javax.transaction.TransactionManager" />
>
>    <osgi:service ref="pooledConnectionFactory">
>        <osgi:interfaces>
>            <value>javax.jms.ConnectionFactory</value>
>        </osgi:interfaces>
>        <osgi:service-properties>
>            <entry key="name" value="default"/>
>        </osgi:service-properties>
>    </osgi:service>
>
>
> How can I resolve this problem?
>
> Cheers,
> Marcin
> --
> View this message in context:
> http://old.nabble.com/message-store-tp27469568p27469568.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>


-- 
http://blog.garytully.com

Open Source Integration
http://fusesource.com

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