import org.apache.catalina.tribes.group.GroupChannel;
import junit.framework.TestCase;
+import org.apache.catalina.tribes.transport.ReceiverBase;
/**
* @author Filip Hanik
super.tearDown();
try {channel.stop(channel.DEFAULT);}catch (Exception ignore){}
}
-
+
public void testDoubleFullStart() throws Exception {
int count = 0;
try {
channel.stop(channel.DEFAULT);
}
+ public void testScrap() throws Exception {
+ System.out.println(channel.getChannelReceiver().getClass());
+ ((ReceiverBase)channel.getChannelReceiver()).setMaxThreads(1);
+ }
+
+
public void testDoublePartialStart() throws Exception {
//try to double start the RX
int count = 0;
} catch ( Exception x){/*expected*/}
assertEquals(count,1);
channel.stop(channel.DEFAULT);
-
+
count = 0;
try {
channel.start(channel.SND_RX_SEQ);
assertEquals(count,1);
channel.stop(channel.DEFAULT);
}
-
+
public void testFalseOption() throws Exception {
int flag = 0xFFF0;//should get ignored by the underlying components
int count = 0;