How to make 2 node communiate using TCP cluster config
hari1234 Jul 24, 2010 8:00 AMHi,
I have got 2 servers in cluster by using cluster config of Jbosscaching. I am using TreeCacheMBean and filling the cache through a quartz schedular. I stopped the schedular on one of the node and wanted to test whether the cache from other server would replicated to this one. but I get following error message in second server log while trying to restart the first server. My intension for doing this was, I was doing the put() methods to fill the cache through schedular which as being called at the first server start up. I was expecting that this would me the replicater called and the cache would get replicated on to second server.
[2010-07-24 06:56:58,101 ERROR [STDERR] at org.jgroups.protocols.TP$IncomingMessageHandler.run(TP.java:1343)
2010-07-24 06:56:58,101 ERROR [STDERR] at java.lang.Thread.run(Thread.java:619)
2010-07-24 06:56:58,101 INFO [org.jboss.cache.marshall.VersionAwareMarshaller] Caught exception unmarshalling stream with specific versioned marshaller class org.jboss.cache.marshall.TreeCacheMarshaller140. Attempting to try again with legacy marshaller class org.jboss.cache.marshall.LegacyTreeCacheMarshaller
2010-07-24 06:56:58,101 DEBUG [org.jboss.cache.marshall.VersionAwareMarshaller] Retry with legacy marshaller failed as well; throwing original exception
java.io.StreamCorruptedException: invalid stream header: 6A627331
at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:783)
at java.io.ObjectInputStream.<init>(ObjectInputStream.java:280)
at org.jboss.invocation.MarshalledValueInputStream.<init>(MarshalledValueInputStream.java:74)
at org.jboss.cache.marshall.VersionAwareMarshaller.objectFromByteBuffer(VersionAwareMarshaller.java:186)
at org.jgroups.blocks.RpcDispatcher.handle(RpcDispatcher.java:254)
at org.jgroups.blocks.RequestCorrelator.handleRequest(RequestCorrelator.java:654)
at org.jgroups.blocks.RequestCorrelator.receiveMessage(RequestCorrelator.java:544)
at org.jgroups.blocks.RequestCorrelator.receive(RequestCorrelator.java:367)
at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:779)
at org.jgroups.JChannel.up(JChannel.java:1090)
at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:382)
at org.jgroups.stack.ProtocolStack.receiveUpEvent(ProtocolStack.java:398)
at org.jgroups.stack.Protocol.passUp(Protocol.java:520)
at org.jgroups.protocols.pbcast.STATE_TRANSFER.up(STATE_TRANSFER.java:158)
at org.jgroups.stack.Protocol.receiveUpEvent(Protocol.java:470)
at org.jgroups.stack.Protocol.passUp(Protocol.java:520)
at org.jgroups.protocols.pbcast.GMS.up(GMS.java:763)
at org.jgroups.stack.Protocol.receiveUpEvent(Protocol.java:470)
at org.jgroups.protocols.pbcast.GMS.receiveUpEvent(GMS.java:783)
at org.jgroups.stack.Protocol.passUp(Protocol.java:520)
at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:262)
at org.jgroups.stack.Protocol.receiveUpEvent(Protocol.java:470)
at org.jgroups.stack.Protocol.passUp(Protocol.java:520)
at org.jgroups.protocols.pbcast.NAKACK.handleMessage(NAKACK.java:685)
at org.jgroups.protocols.pbcast.NAKACK.up(NAKACK.java:517)
at org.jgroups.stack.Protocol.receiveUpEvent(Protocol.java:470)
at org.jgroups.stack.Protocol.passUp(Protocol.java:520)
at org.jgroups.protocols.VERIFY_SUSPECT.up(VERIFY_SUSPECT.java:170)
at org.jgroups.stack.Protocol.receiveUpEvent(Protocol.java:470)
at org.jgroups.stack.Protocol.passUp(Protocol.java:520)
at org.jgroups.protocols.FD.up(FD.java:300)
at org.jgroups.stack.Protocol.receiveUpEvent(Protocol.java:470)
at org.jgroups.stack.Protocol.passUp(Protocol.java:520)
at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:305)
at org.jgroups.stack.Protocol.receiveUpEvent(Protocol.java:470)
Type :quit<Enter> to exit Vim 11384,2-9 99%