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.
