4 Replies Latest reply on Jul 13, 2012 3:22 AM by Galder Zamarreño

    Embedding infinispan problem...

    Tomas Fecko Newbie

      Hi,

       

      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