activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Devlin <rbasmaj...@ofiglobal.com>
Subject Re: Virtual topics, custom prefix limitations
Date Fri, 14 Oct 2016 00:26:27 GMT
Hi Tim,

We managed to get working virtual topics in a 2 broker network, but only for
cases where producer and consumers are using the same broker; consumers
connected to the broker where the producer is not present did not receive
messages. We confirmed the network functions as expected for standard
topics/queues, but not for virtual topics.

I found this in the docs, looks interesting, not sure if it would help, but
regardless, it's for 5.13, we're on 5.11.
 <broker name="remoteBroker" useVirtualDestSubs="true"
useVirtualDestSubsOnCreation="true">  
     .....
  </broker>

Here's our config:
       <destinationInterceptors>
            <virtualDestinationInterceptor>
                <virtualDestinations>
                    <virtualTopic name="*.*.*._vtopic.>" 
prefix="*.*.*._vsub.*."  selectorAware="true"/>
                </virtualDestinations>
            </virtualDestinationInterceptor>
        </destinationInterceptors>

        <transportConnectors>
           <transportConnector
                name="owire"
                uri="tcp://0.0.0.0:61616"
                updateClusterClients="true"
                updateClusterClientsOnRemove="true"/>
        </transportConnectors>

        <networkConnectors>
            <networkConnector
                name="queueNetwork"
                userName="${auth.user}"
                password="${auth.password}"                       
                uri="${network.uri.1}?${network.options}"
                consumerTTL="1"
                messageTTL="100"
                conduitSubscriptions="false"
                decreaseNetworkConsumerPriority="true"
                suppressDuplicateQueueSubscriptions="true">
                <dynamicallyIncludedDestinations>
                    <queue physicalName=">"/>
                </dynamicallyIncludedDestinations>
                <excludedDestinations>
                    <queue physicalName="*.*.*._vsub.>"/>
                </excludedDestinations>
            </networkConnector>           
            <networkConnector
                name="topicNetwork"
                userName="${auth.user}"
                password="${auth.password}"                       
                uri="${network.uri.1}?${network.options}"
                consumerTTL="1"
                messageTTL="100"                
                decreaseNetworkConsumerPriority="true">
                <dynamicallyIncludedDestinations>
                    <topic physicalName=">"/>
                </dynamicallyIncludedDestinations>
            </networkConnector> 
        </networkConnectors>

        <destinationPolicy>
          <policyMap>
            <policyEntries>
              <policyEntry
                  topic=">"
                  producerFlowControl="true"
                  gcInactiveDestinations="true"
                  inactiveTimoutBeforeGC="600000">
                <pendingMessageLimitStrategy>
                  <constantPendingMessageLimitStrategy
                      limit="5000"/>
                </pendingMessageLimitStrategy>
              </policyEntry>
              <policyEntry
                  queue=">"
                  producerFlowControl="true"
                  memoryLimit="20mb"
                  enableAudit="false"
                  gcInactiveDestinations="true"
                  inactiveTimoutBeforeGC="600000">
                  <networkBridgeFilterFactory>
                    <conditionalNetworkBridgeFilterFactory 
                      replayWhenNoConsumers="true"
                      replayDelay="1000" />
                  </networkBridgeFilterFactory>
              </policyEntry>
            </policyEntries>
          </policyMap>
        </destinationPolicy>





--
View this message in context: http://activemq.2283324.n4.nabble.com/Virtual-topics-custom-prefix-limitations-tp4717481p4717887.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message