[jgroups-dev] ReplicatedHashMap with ForkChannel
Brought to you by:
belaban
|
From: Development i. <jav...@li...> - 2019-04-25 13:38:06
|
Hello,
I am using ReplicatedHashMap with ForkChannel. PFA configuration file
(*config.xml*).
ForkChannel forkChannel = new ForkChannel(channel, "myForkStack",
"myForkChannel");
forkChannel.connect(CLUSTER_NAME);
logger.info("ViewAsString :: " + forkChannel.getViewAsString());
wordCounter = new ReplicatedHashMap<>(forkChannel);
wordCounter.start(10_000);
Here, I am using Fork channel to make private communication between main
channel and Fork channel. Now, my JGroup Cluster initialized properly on
Main channel and Fork Channel. The values in ReplicatedHashMap are visible
to all running nodes, but as soon as I start new node in cluster, the
ReplicatedHashMap initialized again and the existing values in
ReplicatedHashMap are not visible to newly started Node.
PFA sample test program.
Note : Before I was using two channels with "Shared Transport" (<UDP
singleton_name="tp_one"), but Upgrading JGROUP to 3.6.16 gives warning to
use Fork Channel instead of Shared Transport.
Regards,
Tarana Desai
|