| java.lang.Object org.jgroups.tests.RpcDispatcherStressTest
RpcDispatcherStressTest | public class RpcDispatcherStressTest implements MembershipListener(Code) | | Example for RpcDispatcher (see also MessageDispatcher). Multiple threads will invoke print() on
all members and wait indefinitely for all responses (excluding of course crashed members). Run this
on 2 nodes for an extended period of time to see whether GroupRequest.doExecute() hangs.
author: Bela Ban |
Inner Class :class Publisher extends Thread | |
threads | Publisher[] threads(Code) | | |
block | public void block()(Code) | | |
start | public void start(String props, int num_threads, long interval, boolean discard_local) throws Exception(Code) | | |
viewAccepted | public void viewAccepted(View new_view)(Code) | | |
|
|