public class UnicastTest extends Object
Modifier and Type | Class and Description |
---|---|
protected class |
UnicastTest.MyReceiver |
protected class |
UnicastTest.Sender |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
channel |
protected static byte |
DATA |
protected boolean |
dont_bundle |
protected int |
msg_size |
protected int |
num_msgs |
protected int |
num_threads |
protected boolean |
oob |
protected UnicastTest.MyReceiver |
receiver |
protected long |
sleep_time |
protected static byte |
START |
Constructor and Description |
---|
UnicastTest() |
Modifier and Type | Method and Description |
---|---|
protected void |
_init(JChannel ch,
long sleep_time,
String name) |
void |
eventLoop() |
protected Address |
getReceiver() |
void |
init(Protocol[] props,
long sleep_time,
String name) |
void |
init(String props,
long sleep_time,
String name) |
static void |
main(String[] args) |
protected void |
printConnections() |
protected void |
removeAllConnections() |
protected JChannel channel
protected final UnicastTest.MyReceiver receiver
protected long sleep_time
protected boolean oob
protected boolean dont_bundle
protected int num_threads
protected int num_msgs
protected int msg_size
protected static final byte START
protected static final byte DATA
public void init(Protocol[] props, long sleep_time, String name) throws Exception
Exception
public void init(String props, long sleep_time, String name) throws Exception
Exception
protected void _init(JChannel ch, long sleep_time, String name) throws Exception
Exception
protected void printConnections()
protected void removeAllConnections()
protected Address getReceiver()
public static void main(String[] args)
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.