"Currently my DLQ and Expirery Queue are not working correctly." We can only help you fix the problem if you tell us what the problem is... On Feb 9, 2016 10:58 AM, "mhemple" <mhem...@gmail.com> wrote:
> Okay I see I was looking at an at an ActiveMQ/Artimus guide. I guess that > wont work. What I'm trying to do is set up my ActiveMQ cluster to work as > my embedded HornetQ broker has worked in the past. Currently my DLQ and > Expirery Queue are not working correctly. Here are the two configs: > > Hornet > > > <subsystem xmlns="urn:jboss:domain:messaging:2.0"> > <hornetq-server> > <persistence-enabled>false</persistence-enabled> > <jmx-management-enabled>true</jmx-management-enabled> > <shared-store>true</shared-store> > <journal-type>ASYNCIO</journal-type> > <journal-file-size>102400</journal-file-size> > <journal-min-files>2</journal-min-files> > > <connectors> > <netty-connector name="netty" > socket-binding="messaging"/> > <netty-connector name="netty-throughput" > socket-binding="messaging-throughput"> > > </netty-connector> > <in-vm-connector name="in-vm" server-id="0"/> > </connectors> > > <acceptors> > <netty-acceptor name="netty" > socket-binding="messaging"/> > <netty-acceptor name="netty-throughput" > socket-binding="messaging-throughput"> > > > </netty-acceptor> > <in-vm-acceptor name="in-vm" server-id="0"/> > </acceptors> > > <security-settings> > <security-setting match="#"> > <permission type="send" roles="guest"/> > <permission type="consume" roles="guest"/> > <permission type="createNonDurableQueue" > roles="guest"/> > <permission type="deleteNonDurableQueue" > roles="guest"/> > </security-setting> > </security-settings> > > <address-settings> > <address-setting match="#"> > > <dead-letter-address>jms.queue.DLQ</dead-letter-address> > > <expiry-address>jms.queue.ExpiryQueue</expiry-address> > <redelivery-delay>0</redelivery-delay> > <max-size-bytes>104857600</max-size-bytes> > <page-size-bytes>10485760</page-size-bytes> > <page-max-cache-size>10</page-max-cache-size> > <address-full-policy>PAGE</address-full-policy> > > <message-counter-history-day-limit>10</message-counter-history-day-limit> > </address-setting> > </address-settings> > > <jms-connection-factories> > <connection-factory name="InVmConnectionFactory"> > <connectors> > <connector-ref connector-name="in-vm"/> > </connectors> > <entries> > <entry name="java:/ConnectionFactory"/> > </entries> > </connection-factory> > <connection-factory name="RemoteConnectionFactory"> > <connectors> > <connector-ref connector-name="netty"/> > </connectors> > <entries> > <entry > name="java:jboss/exported/jms/RemoteConnectionFactory"/> > </entries> > > <client-failure-check-period>30000</client-failure-check-period> > <connection-ttl>300000</connection-ttl> > <retry-interval>2000</retry-interval> > > <retry-interval-multiplier>1</retry-interval-multiplier> > <max-retry-interval>2000</max-retry-interval> > <reconnect-attempts>100</reconnect-attempts> > </connection-factory> > </jms-connection-factories> > > <jms-destinations> > <jms-queue name="asyncActionRequestQueue"> > <entry name="queue/bpm/asyncActionRequestQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/asyncActionRequestQueue"/> > </jms-queue> > <jms-queue name="asyncActionReplyQueue"> > <entry name="queue/bpm/asyncActionReplyQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/asyncActionReplyQueue"/> > </jms-queue> > <jms-queue name="asyncServiceSignalQueue"> > <entry name="queue/bpm/asyncServiceSignalQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/asyncServiceSignalQueue"/> > </jms-queue> > <jms-queue name="asyncActionServiceLogRecordQueue"> > <entry > name="queue/bpm/asyncActionServiceLogRecordQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/asyncActionServiceLogRecordQueue"/> > </jms-queue> > <jms-queue name="deferredBpmCommandQueue"> > <entry name="queue/bpm/deferredBpmCommandQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/deferredBpmCommandQueue"/> > </jms-queue> > <jms-queue name="jbpmJobQueue"> > <entry name="queue/bpm/jbpmJobQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/jbpmJobQueue"/> > </jms-queue> > <jms-queue name="DLQ"> > <entry name="queue/DLQ"/> > <entry name="java:jboss/exported/jms/queue/DLQ"/> > </jms-queue> > <jms-queue name="ExpiryQueue"> > <entry name="queue/ExpiryQueue"/> > <entry > name="java:jboss/exported/jms/queue/ExpiryQueue"/> > </jms-queue> > <jms-queue name="periodicDerivationQueue"> > <entry name="queue/bpm/periodicDerivationQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/periodicDerivationQueue"/> > </jms-queue> > <jms-queue name="cacheUpdateReplicationQueue"> > <entry > name="queue/bpm/cacheUpdateReplicationQueue"/> > <entry > name="java:jboss/exported/jms/queue/bpm/cacheUpdateReplicationQueue"/> > </jms-queue> > <jms-topic name="asyncActionServiceStatusTopic"> > <entry > name="topic/bpm/asyncActionServiceStatusTopic"/> > <entry > name="java:jboss/exported/jms/topic/bpm/asyncActionServiceStatusTopic"/> > </jms-topic> > <jms-topic name="asyncActionServiceStatusRequestTopic"> > <entry > name="topic/bpm/asyncActionServiceStatusRequestTopic"/> > <entry > > name="java:jboss/exported/jms/topic/bpm/asyncActionServiceStatusRequestTopic"/> > </jms-topic> > <jms-topic name="asyncActionAffinityRequestTopic"> > <entry > name="topic/bpm/asyncActionAffinityRequestTopic"/> > <entry > name="java:jboss/exported/jms/topic/bpm/asyncActionAffinityRequestTopic"/> > </jms-topic> > <jms-topic name="asyncActionAffinityReplyTopic"> > <entry > name="topic/bpm/asyncActionAffinityReplyTopic"/> > <entry > name="java:jboss/exported/jms/topic/bpm/asyncActionAffinityReplyTopic"/> > </jms-topic> > <jms-topic name="processEventTopic"> > <entry name="topic/bpm/processEventTopic"/> > <entry > name="java:jboss/exported/jms/topic/bpm/processEventTopic"/> > </jms-topic> > <jms-topic name="cacheUpdateReplicationEventTopic"> > <entry > name="topic/bpm/cacheUpdateReplicationEventTopic"/> > <entry > name="java:jboss/exported/jms/topic/bpm/cacheUpdateReplicationEventTopic"/> > </jms-topic> > </jms-destinations> > </hornetq-server> > </subsystem> > > ActiveMQ > > > <subsystem xmlns="urn:jboss:domain:resource-adapters:2.0"> > <resource-adapters> > <resource-adapter id="activemq-rar.rar"> > <archive> > activemq-rar.rar > </archive> > > <transaction-support>XATransaction</transaction-support> > <config-property name="ServerUrl"> > tcp:// > 127.0.0.1:61616?jms.rmIdFromConnectionId=true > </config-property> > <config-property name="UserName"> > admin > </config-property> > <config-property name="Password"> > admin > </config-property> > <connection-definitions> > > > > <connection-definition > class-name="org.apache.activemq.ra.ActiveMQManagedConnectionFactory" > jndi-name="java:/ConnectionFactory" enabled="true" > pool-name="ConnectionFactory"> > <xa-pool> > <min-pool-size>1</min-pool-size> > <max-pool-size>20</max-pool-size> > <prefill>false</prefill> > > <is-same-rm-override>false</is-same-rm-override> > </xa-pool> > <recovery> > <recover-credential> > <user-name>admin</user-name> > <password>admin</password> > </recover-credential> > <recover-plugin > class-name="org.jboss.jca.core.recovery.ConfigurableRecoveryPlugin"> > <config-property name="EnableIsValid"> > false > </config-property> > <config-property > name="IsValidOverride"> > true > </config-property> > <config-property name="EnableClose"> > true > </config-property> > </recover-plugin> > </recovery> > </connection-definition> > </connection-definitions> > <admin-objects> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > > jndi-name="java:jboss/exported/jms/queue/bpm/deferredBpmCommandQueue" > > use-java-context="true" > > pool-name="deferredBpmCommandQueue"> > <config-property name="PhysicalName"> > deferredBpmCommandQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > jndi-name="java:jboss/exported/jms/queue/bpm/asyncActionRequestQueue" > use-java-context="true" pool-name="ActiveMQQueue.asyncActionRequestQueue"> > <config-property name="PhysicalName"> > asyncActionRequestQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > > jndi-name="java:jboss/exported/jms/queue/bpm/DLQ" > > use-java-context="true" > > pool-name="DLQ"> > <config-property name="PhysicalName"> > DLQ > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > jndi-name="java:jboss/exported/jms/queue/bpm/cacheUpdateReplicationQueue" > use-java-context="true" > pool-name="ActiveMQQueue.cacheUpdateReplicationQueue"> > <config-property name="PhysicalName"> > cacheUpdateReplicationQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > jndi-name="java:jboss/exported/jms/queue/bpm/periodicDerivationQueue" > use-java-context="true" pool-name="ActiveMQQueue.periodicDerivationQueue"> > <config-property name="PhysicalName"> > periodicDerivationQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > jndi-name="java:jboss/exported/jms/queue/bpm/asyncServiceSignalQueue" > use-java-context="true" pool-name="ActiveMQQueue.asyncServiceSignalQueue"> > <config-property name="PhysicalName"> > asyncServiceSignalQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQTopic" > jndi-name="java:jboss/exported/jms/queue/bpm/processEventTopic" > use-java-context="true" pool-name="ActiveMQTopic.processEventTopic"> > <config-property name="PhysicalName"> > processEventTopic > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > jndi-name="java:jboss/exported/jms/queue/bpm/asyncActionReplyQueue" > use-java-context="true" pool-name="ActiveMQQueue.asyncActionReplyQueue"> > <config-property name="PhysicalName"> > asyncActionReplyQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > jndi-name="java:jboss/exported/jms/queue/bpm/ExpiryQueue" > use-java-context="true" pool-name="ActiveMQQueue.ExpiryQueue"> > <config-property name="PhysicalName"> > ExpiryQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQTopic" > > jndi-name="java:jboss/exported/jms/queue/bpm/asyncActionServiceStatusRequestTopic" > use-java-context="true" > pool-name="ActiveMQTopic.asyncActionServiceStatusRequestTopic"> > <config-property name="PhysicalName"> > asyncActionServiceStatusRequestTopic > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQTopic" > > jndi-name="java:jboss/exported/jms/queue/bpm/asyncActionAffinityRequestTopic" > use-java-context="true" > pool-name="ActiveMQTopic.asyncActionAffinityRequestTopic"> > <config-property name="PhysicalName"> > asyncActionAffinityRequestTopic > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > jndi-name="java:jboss/exported/jms/queue/bpm/jbpmJobQueue" > use-java-context="true" pool-name="ActiveMQQueue.jbpmJobQueue"> > <config-property name="PhysicalName"> > jbpmJobQueue > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQTopic" > jndi-name="java:jboss/exported/jms/queue/bpm/asyncActionAffinityReplyTopic" > use-java-context="true" > pool-name="ActiveMQTopic.asyncActionAffinityReplyTopic"> > <config-property name="PhysicalName"> > asyncActionAffinityReplyTopic > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQTopic" > > jndi-name="java:jboss/exported/jms/queue/bpm/cacheUpdateReplicationEventTopic" > use-java-context="true" > pool-name="ActiveMQTopic.cacheUpdateReplicationEventTopic"> > <config-property name="PhysicalName"> > cacheUpdateReplicationEventTopic > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQTopic" > jndi-name="java:jboss/exported/jms/queue/bpm/asyncActionServiceStatusTopic" > use-java-context="true" > pool-name="ActiveMQTopic.asyncActionServiceStatusTopic"> > <config-property name="PhysicalName"> > asyncActionServiceStatusTopic > </config-property> > </admin-object> > <admin-object > class-name="org.apache.activemq.command.ActiveMQQueue" > > jndi-name="java:jboss/exported/jms/queue/bpm/asyncActionServiceLogRecordQueue" > use-java-context="true" > pool-name="ActiveMQQueue.asyncActionServiceLogRecordQueue"> > <config-property name="PhysicalName"> > asyncActionServiceLogRecordQueue > </config-property> > </admin-object> > </admin-objects> > </resource-adapter> > </resource-adapters> > </subsystem> > > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Standalone-ActiveMQ-address-settings-tp4707269p4707303.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. >
