I have tested apache-activemq-5.5.1-fuse-01-06 and
apache-activemq-5.5.1-fuse-01-11 and they don't work as well.
I'm depressed so much after lots of tests.
My configuration files are the following:
------------------------------------------------------------------------------------------------------------------------------------------------------------------------
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
<broker xmlns="http://activemq.apache.org/schema/core";
brokerName="mybroker1" dataDirectory="${activemq.base}/data">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" producerFlowControl="false"
memoryLimit="512mb">
<networkBridgeFilterFactory>
<conditionalNetworkBridgeFilterFactory
replayWhenNoConsumers="true" />
</networkBridgeFilterFactory>
</policyEntry>
<policyEntry topic=">" producerFlowControl="true"
memoryLimit="20mb">
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="true"/>
</managementContext>
<networkConnectors>
<networkConnector uri="multicast://default?group=knet"
name="nc1"
duplex="true"
networkTTL="6"
dynamicOnly="true"
prefetchSize="1"
conduitSubscriptions="true"
suppressDuplicateQueueSubscriptions="true"
suppressDuplicateTopicSubscriptions="true"
decreaseNetworkConsumerPriority="true" />
</networkConnectors>
<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"
enableJournalDiskSyncs="false" indexWriteBatchSize="10000"
indexCacheSize="1000"/>
</persistenceAdapter>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="1 gb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="10 gb" name="foo"/>
</storeUsage>
<tempUsage>
<tempUsage limit="1 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616"
discoveryUri="multicast://default?group=knet" />
</transportConnectors>
</broker>
<import resource="jetty.xml"/>
</beans>
------------------------------------------------------------------------------------------------------------------------------------------------------
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
<broker xmlns="http://activemq.apache.org/schema/core";
brokerName="mybroker2" dataDirectory="${activemq.base}/data">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" producerFlowControl="false"
memoryLimit="512mb">
<networkBridgeFilterFactory>
<conditionalNetworkBridgeFilterFactory
replayWhenNoConsumers="true" />
</networkBridgeFilterFactory>
</policyEntry>
<policyEntry topic=">" producerFlowControl="true"
memoryLimit="20mb">
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="false"/>
</managementContext>
<networkConnectors>
<networkConnector uri="multicast://default?group=knet"
name="nc2"
duplex="true"
networkTTL="6"
dynamicOnly="true"
prefetchSize="1"
conduitSubscriptions="true"
suppressDuplicateQueueSubscriptions="true"
suppressDuplicateTopicSubscriptions="true"
decreaseNetworkConsumerPriority="true" />
</networkConnectors>
<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"
enableJournalDiskSyncs="false" indexWriteBatchSize="10000"
indexCacheSize="1000"/>
</persistenceAdapter>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="1 gb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="10 gb" name="foo"/>
</storeUsage>
<tempUsage>
<tempUsage limit="1 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616"
discoveryUri="multicast://default?group=knet" />
</transportConnectors>
</broker>
<import resource="jetty.xml"/>
</beans>
---------------------------------------------------------------------------------------------------------------------------------------------------------
At 2011-12-07 00:05:42,"Torsten Mielke" <[email protected]> wrote:
>Yep, the latest release version.
>I have already seen a customer using it.
>
>
>
>On Dec 6, 2011, at 5:02 PM, SuoNayi wrote:
>
>> Thanks Torsten,It's the release version not snapshot version,right?
>>
>> http://repo.fusesource.com/nexus/content/repositories/releases/org/apache/activemq/apache-activemq/5.5.1-fuse-01-06/
>>
>>
>>
>>
>> At 2011-12-06 23:44:49,"Torsten Mielke" <[email protected]> wrote:
>>> The latest 5.5 release from FuseSource should already have this feature
>>> implemented, AFAIK.
>>>
>>>
>>> On Dec 6, 2011, at 3:43 PM, SuoNayi wrote:
>>>
>>>> Yes, it's a feature of AMQ 5.6 which is not released yet.
>>>> The trunk is a snapshot version but I want a release version for my
>>>> product enviroment.
>>>> So I want to modify some to solve this issue.
>>>>
>>>>
>>>>
>>>>
>>>> At 2011-12-06 19:44:36,"Torsten Mielke" <[email protected]> wrote:
>>>>> Hi,
>>>>>
>>>>> Is it the replayWhenNoConsumers feature that you're looking for?
>>>>>
>>>>> <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true" />
>>>>>
>>>>> See http://activemq.apache.org/networks-of-brokers.html, part "Stuck
>>>>> messages".
>>>>>
>>>>>
>>>>> Torsten Mielke
>>>>> [email protected]
>>>>> [email protected]
>>>>>
>>>>>
>>>>>
>>>>> On Dec 6, 2011, at 6:54 AM, SuoNayi wrote:
>>>>>
>>>>>> Hi all and professionals at fusesource, is there a simple way to solve
>>>>>> the issuse of stuck messages when network?
>>>>>> Could I modify some source code ,for example the matchesForwardingFilter
>>>>>> method in the class NetworkBridgeFilter ?
>>>>>> I want to annotate the line code which checks a message passes through
>>>>>> the target broker or not,
>>>>>> but this maybe cause other potential and unknown problem.
>>>>>> So could anyone give me a advice or some tips?Thanks a lot!
>>>>>
>>>>>
>>>>>
>>>
>>> Torsten Mielke
>>> [email protected]
>>> [email protected]
>
--
Wangyin
[email protected]
