give a full path name in dataDirectory="amq-data" to a directory that you know to exist that is accessible by the userid that this context runs under. The temp store will be created on demand and it looks like the NPE is occurring due to some file access problems, using an explicit directory should help in this case.
On 2 September 2011 16:59, nrichards <jricha...@arrisi.com> wrote: > 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. > -- http://fusesource.com http://blog.garytully.com
