activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nrichards <jricha...@arrisi.com>
Subject Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight
Date Fri, 02 Sep 2011 15:59:54 GMT
Thanks for your interest Gary, here's the broker config:

    <bean id="amqStore"
class="org.apache.activemq.store.amq.AMQPersistenceAdapter" >
        <property name="directory"              value="amq-messages" />
        <property name="maxFileLength"          value="1000000" />
        <property name="checkpointInterval"     value="5000" />
        <property name="cleanupInterval"        value="5000" />
        </bean>



    <amq:broker id="amq"  brokerName="amq"
                deleteAllMessagesOnStartup="true"
                persistent="true"
                persistenceAdapter="#amqStore"
                schedulerSupport="false"
                dataDirectory="amq-data"
                start="true"
                useJmx="true" >

        
        <amq:destinationPolicy>
            <amq:policyMap>
              <amq:policyEntries>
                <amq:policyEntry topic=">"
                                producerFlowControl="false"
                                memoryLimit="100mb">

                  <amq:pendingSubscriberPolicy>
                    <amq:fileCursor />
                  </amq:pendingSubscriberPolicy>
                </amq:policyEntry>

                <amq:policyEntry queue=">"
                                producerFlowControl="false"
                                lazyDispatch="true"
                                memoryLimit="100mb">

                  <amq:pendingQueuePolicy>
                    <amq:fileQueueCursor/>
                  </amq:pendingQueuePolicy>
                </amq:policyEntry>
              </amq:policyEntries>
            </amq:policyMap>
        </amq:destinationPolicy>

        
        
        <amq:destinations>
            <amq:queue physicalName="QueueAMQ" />
            <amq:queue physicalName="QueueReplPackageTrigger" />
            <amq:queue physicalName="QueueMAEPackageTrigger" />
            <amq:queue physicalName="QueueInterfaceProfileUpdatedTrigger" />
            <amq:queue physicalName="QueueAggregationCompletedTrigger" />
            <amq:queue physicalName="QueueCmAttributesTrigger" />
            <amq:queue physicalName="TableQueue_DEVICE_FACTS" />
            <amq:queue physicalName="TableQueue_UPSTREAM_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_DOWNSTREAM_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_IRL_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_RVLD_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_RVLD_CPU_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_MACINT_CPU_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_RVLD_QOS_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_MACINT_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_DEVICE_FACTS_UP_D30" />
            <amq:queue physicalName="TableQueue_DEVICE_FACTS_DOWN_D30" />
            <amq:queue physicalName="TableQueue_BG_HOUR_FACTS" />
            <amq:queue physicalName="TableQueue_DEVICE_FACTS_PROF_UP" />
            <amq:queue physicalName="TableQueue_DEVICE_FACTS_PROF_DOWN" />
            <amq:queue physicalName="TableQueue_DEVICE_ATTRIBUTES" />

            
        </amq:destinations>

        <amq:managementContext>
            <amq:managementContext connectorPort="61099" />
        </amq:managementContext>

        <amq:plugins>
            <amq:authorizationPlugin>
                <amq:map>
                    <amq:authorizationMap>
                        
                        <amq:authorizationEntries>
                            <amq:authorizationEntry queue="QueueAMQ"
                                read="users" write="users" admin="admin" />

                            <amq:authorizationEntry
queue="QueueReplPackageTrigger"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="QueueMAEPackageTrigger"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="QueueInterfaceProfileUpdatedTrigger"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="QueueAggregationCompletedTrigger"
                                read="users" write="users" admin="admin" />

                            <amq:authorizationEntry
queue="QueueCmAttributesTrigger"
                                read="users" write="users" admin="admin" />

                            <amq:authorizationEntry
queue="TableQueue_DEVICE_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_UPSTREAM_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_DOWNSTREAM_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_IRL_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_RVLD_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_RVLD_CPU_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_MACINT_CPU_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_RVLD_QOS_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_MACINT_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_DEVICE_FACTS_UP_D30"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_DEVICE_FACTS_DOWN_D30"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_BG_HOUR_FACTS"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_DEVICE_FACTS_PROF_UP"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_DEVICE_FACTS_PROF_DOWN"
                                read="users" write="users" admin="admin" />
                            <amq:authorizationEntry
queue="TableQueue_DEVICE_ATTRIBUTES"
                                read="users" write="users" admin="admin" />

                            <amq:authorizationEntry
topic="ActiveMQ.Advisory.>"
                                read="guests,users" write="guests,users"
admin="guests,users" />
                        </amq:authorizationEntries>
                    </amq:authorizationMap>
                </amq:map>
            </amq:authorizationPlugin>

            <amq:simpleAuthenticationPlugin>
                <amq:users>
                    <amq:authenticationUser id="amqUser" username=""
                        password="" groups="users" />
                    <amq:authenticationUser id="amqAdmin"
username="amqAdmin"
                        password="amqAdmin" groups="admin" />
                </amq:users>
            </amq:simpleAuthenticationPlugin>
        </amq:plugins>

        
        
        <amq:systemUsage>
            <amq:systemUsage sendFailIfNoSpace="true" >
                <amq:memoryUsage>
                    <amq:memoryUsage limit="$amq.limits.memory}" />
                </amq:memoryUsage>
                <amq:storeUsage>
                    <amq:storeUsage limit="$amq.limits.store}"
                                    store="#amqStore" />
                </amq:storeUsage>
                <amq:tempUsage>
                    <amq:tempUsage limit="$amq.limits.temp}" />
                </amq:tempUsage>
            </amq:systemUsage>
        </amq:systemUsage>

        <amq:transportConnectors>
            <amq:transportConnector uri="tcp://$jms.host}:61616" />
        </amq:transportConnectors>
    </amq:broker>



--
View this message in context: http://activemq.2283324.n4.nabble.com/AMQ-5-5-non-persistent-messages-not-processed-counted-as-in-flight-tp3776808p3786486.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message