activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mhemple <mhem...@gmail.com>
Subject Re: Standalone ActiveMQ address settings
Date Tue, 09 Feb 2016 17:34:19 GMT
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.

Mime
View raw message