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.
