4 Replies Latest reply on Jul 13, 2012 3:22 AM by galder.zamarreno

    Embedding infinispan problem...

    feci

      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

        • 1. Re: Embedding infinispan problem...
          manik

          Try different cluster name, and if possible different multicast address and port.

          • 2. Re: Embedding infinispan problem...
            feci

            I can't share the cluster layer? If I will use different multicast address and port and cluster name, it's almost the same like I choose the hazelcast for app clustering and jgroups for infinispan clustering...

             

            Ok,  I will try that, thanx...

            • 3. Re: Embedding infinispan problem...
              borisha

              This is still happening even in EAP6.

               

              So, we start EAP6 with full-ha (with Infinispan). This is what we get:

               

              16:23:17,814 WARNING [org.jgroups.protocols.UDP] (OOB-2,P768B599E9837A-46654) discarded message from different cluster "SharedMS" (our cluster is "ISPN"). Sender was fa2bdc4f-13e2-e74e-9940-d12f4102769d

               


               

              We do not want to change ip address and ports - just to use different cluster name like here:

               

              GlobalConfigurationBuilder globalConfigurationBuilder = new GlobalConfigurationBuilder();       

              globalConfigurationBuilder.transport().defaultTransport().clusterName(customClusterName);

               

              I can not find that there is JIRA issue for JGroups or JBoss for this.


               


              • 4. Re: Embedding infinispan problem...
                galder.zamarreno

                If you're having issues with EAP6, you should be asking them to our professional support team