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: AMQ 5.5 non-persistent messages not processed, counted as in-flight
Date Fri, 02 Sep 2011 16:08:21 GMT
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 <jrichartz@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

Mime
View raw message