RE: [Tomcat-jg-development] Re: [javagroups-users] Problem using JG within Tomcat or Weblogic

[Filip H. <ma...@fi...>]

where do you put the javagroups.jar?

Filip

~
Namaste - I bow to the divine in you
~
Filip Hanik
Software Architect
www.filip.net

>-----Original Message-----
>From: tom...@li...
>[mailto:tom...@li...]On Behalf Of
>Bela Ban
>Sent: Wednesday, November 06, 2002 2:47 PM
>To: Vincent Shek
>Cc: jav...@li...; Filip Hanik; Jules Gosnell;
>tomcat-jg-development
>Subject: [Tomcat-jg-development] Re: [javagroups-users] Problem using JG
>within Tomcat or Weblogic
>
>
>Could this be a classloader problem ? E.g. the first member is run by a
>different classloader than the second member, so serialization will fail ?
>
>Any servlet container experts ?
>
>I suggest you enable full tracing for JavaGroups, to see eventual error
>messages.
>
>
>Vincent Shek wrote:
>
>> Hi all,
>>
>> I was able to use Javagroup sucessfully when I ran 2 processes on my
>> Windows
>> 2000 console. In my example below, when I started Test1 and started Test2
>> later on, the two processes were able to see each other and Test1
>> would see
>> the Hashtable insert(s) performed by Test2.
>>
>> However, if I leave Test1 running and run my Test2 program as a
>jsp inside
>> Tomcat or Weblogic, the Hashtable insert performed within Tomcat would
>> never
>> show up in my Test1 process running on the console.
>>
>> Any help on this is much appreciated! I was trying to use Javagroup as a
>> distributed caching mechanism within Tomcat and Weblogic server.
>>
>>
>> Vincent Shek
>>
>> ////////////////////////////// process 1 ///////////////////////////
>>
>> import org.javagroups.*;
>> import org.javagroups.blocks.*;
>> import org.javagroups.log.Trace;
>>
>>
>> public class Test1 extends Thread implements
>> DistributedHashtable.Notification {
>>
>> DistributedHashtable h;
>>
>> private final String groupname="testgroup";
>>
>> public static void main(String args[]) {
>>
>> String props="UDP(mcast_addr=228.8.8.8;mcast_port=45566;" +
>> "ucast_send_buf_size=32000;ucast_recv_buf_size=64000;" +
>> "mcast_send_buf_size=32000;mcast_recv_buf_size=64000;" +
>> "use_packet_handler=false;loopback=true;ip_ttl=32):" +
>> "PING(timeout=2000;num_initial_members=3):" +
>> "MERGE2(min_interval=5000;max_interval=10000):" +
>> "FD_SOCK:" +
>> "VERIFY_SUSPECT(timeout=1500):" +
>> "pbcast.STABLE(desired_avg_gossip=20000):" +
>>
>>
>"pbcast.NAKACK(gc_lag=50;retransmit_timeout=300,600,1200,2400,4800;
>max_xmit_
>> size=5192):" +
>> "UNICAST(timeout=5000):" +
>> "FRAG(frag_size=8192;down_thread=false;up_thread=false):" +
>> "pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;" +
>> "shun=false;print_local_addr=true):" +
>> "pbcast.STATE_TRANSFER";
>>
>> ChannelFactory factory=new JChannelFactory();
>>
>> Test1 t = new Test1(factory, props);
>> t.start();
>>
>> }
>>
>> public Test1 (ChannelFactory factory, String props) {
>> h=new DistributedHashtable(groupname, factory, props, 0);
>> h.addNotifier(this);
>> }
>>
>> public void run() {
>> while (true) {
>> try {
>> sleep(10000);
>> Collection a = h.values();
>> Iterator i = a.iterator();
>> while (i.hasNext()) {
>> System.out.println(i.next());
>> }
>> } catch (InterruptedException e) {}
>> }
>> }
>>
>>
>> public void viewChange(Vector joined, Vector left) {
>> System.out.println("New members: " + joined + ", left members: "
>> + left);
>> }
>>
>> public void entrySet(Object key, Object value) {
>> System.out.println("Key: " + Key + ", value: " + value);
>> }
>>
>> public void entryRemoved(Object key) {
>> }
>> }
>>
>> ////////////////////////////// process 2 ///////////////////////////
>> import org.javagroups.*;
>> import org.javagroups.blocks.*;
>> import org.javagroups.log.Trace;
>>
>>
>> public class Test2 {
>>
>> DistributedHashtable h;
>> private final String groupname="testgroup";
>>
>> public static void main(String args[]) {
>>
>> String props="UDP(mcast_addr=228.8.8.8;mcast_port=45566;" +
>> "ucast_send_buf_size=32000;ucast_recv_buf_size=64000;" +
>> "mcast_send_buf_size=32000;mcast_recv_buf_size=64000;" +
>> "use_packet_handler=false;loopback=true;ip_ttl=32):" +
>> "PING(timeout=2000;num_initial_members=3):" +
>> "MERGE2(min_interval=5000;max_interval=10000):" +
>> "FD_SOCK:" +
>> "VERIFY_SUSPECT(timeout=1500):" +
>> "pbcast.STABLE(desired_avg_gossip=20000):" +
>>
>>
>"pbcast.NAKACK(gc_lag=50;retransmit_timeout=300,600,1200,2400,4800;
>max_xmit_
>> size=5192):" +
>> "UNICAST(timeout=5000):" +
>> "FRAG(frag_size=8192;down_thread=false;up_thread=false):" +
>> "pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;" +
>> "shun=false;print_local_addr=true):" +
>> "pbcast.STATE_TRANSFER";
>>
>> ChannelFactory factory=new JChannelFactory();
>>
>> Test2 t = new Test2(factory, props);
>> }
>>
>> public Test2 (ChannelFactory factory, String props) {
>>
>> h=new DistributedHashtable(groupname, factory, props, 0);
>> h.put("test1", "test1");
>> }
>> }
>>
>
>
>--
>Bela Ban
>http://www.javagroups.com
>Cell: (408) 316-4459
>
>
>
>-------------------------------------------------------
>This sf.net email is sponsored by: See the NEW Palm
>Tungsten T handheld. Power & Color in a compact size!
>http://ads.sourceforge.net/cgi-bin/redirect.pl?palm0001en
>_______________________________________________
>Tomcat-jg-development mailing list
>Tom...@li...
>https://lists.sourceforge.net/lists/listinfo/tomcat-jg-development
>