Embedding infinispan problem...
feci Sep 5, 2010 6:38 PMHi,
I'm trying to embed infinispan to application, which already uses JGroups, how can I do that?
If I set different names of clusters, JGroups is logging warnings that it detects messages from different cluster:
2010-09-06 00:31:46.795 WARN org.jgroups.protocols.UDP - discarded message from different cluster "app" (our cluster is "appCache"). Sender was fecihoDesktop-2518
2010-09-06 00:31:46.806 WARN org.jgroups.protocols.UDP - discarded message from different cluster "app" (our cluster is "appCache"). Sender was fecihoDesktop-2750
2010-09-06 00:31:49.146 WARN org.jgroups.protocols.UDP - discarded message from different cluster "appCache" (our cluster is "app"). Sender was fecihoDesktop-3277
2010-09-06 00:31:49.153 WARN org.jgroups.protocols.UDP - discarded message from different cluster "appCache" (our cluster is "app"). Sender was fecihoDesktop-5798
2010-09-06 00:31:49.795 WARN org.jgroups.protocols.UDP - discarded message from different cluster "app" (our cluster is "appCache"). Sender was fecihoDesktop-2518
2010-09-06 00:31:49.806 WARN org.jgroups.protocols.UDP - discarded message from different cluster "app" (our cluster is "appCache"). Sender was fecihoDesktop-2750
When I set the infinispan to use same cluster name as I'm already using I have these kind of exceptions:
2010-09-06 00:21:25.835 ERROR org.cluster.jgroups.JGroupsMessageReceiver - invalid stream header: 019A0318
java.io.StreamCorruptedException: invalid stream header: 019A0318
at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:783)
at java.io.ObjectInputStream.<init>(ObjectInputStream.java:280)
at org.jgroups.util.Util.objectFromByteBuffer(Util.java:367)
at org.jgroups.util.Util.objectFromByteBuffer(Util.java:347)
at org.sors.openOEMS.pse.cluster.jgroups.JGroupsMessageReceiver.receive(JGroupsMessageReceiver.java:42)
at org.jgroups.JChannel.up(JChannel.java:1459)
at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:887)
at org.jgroups.protocols.pbcast.FLUSH.up(FLUSH.java:483)
at org.jgroups.protocols.pbcast.STREAMING_STATE_TRANSFER.up(STREAMING_STATE_TRANSFER.java:265)
at org.jgroups.protocols.FRAG2.up(FRAG2.java:188)
at org.jgroups.protocols.FC.up(FC.java:494)
at org.jgroups.protocols.pbcast.GMS.up(GMS.java:888)
at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:234)
at org.jgroups.protocols.UNICAST.up(UNICAST.java:309)
at org.jgroups.protocols.pbcast.NAKACK.handleMessage(NAKACK.java:813)
at org.jgroups.protocols.pbcast.NAKACK.up(NAKACK.java:671)
at org.jgroups.protocols.VERIFY_SUSPECT.up(VERIFY_SUSPECT.java:132)
at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:177)
at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:270)
at org.jgroups.protocols.MERGE2.up(MERGE2.java:210)
at org.jgroups.protocols.Discovery.up(Discovery.java:281)
at org.jgroups.protocols.PING.up(PING.java:67)
at org.jgroups.protocols.TP.passMessageUp(TP.java:1009)
at org.jgroups.protocols.TP.access$100(TP.java:56)
at org.jgroups.protocols.TP$IncomingPacket.handleMyMessage(TP.java:1549)
at org.jgroups.protocols.TP$IncomingPacket.run(TP.java:1531)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Setting different name to channel doesn't help either...
thanx