public class RoundTrip extends ReceiverAdapter
RpcDispatcherSpeedTest
for
RPCsModifier and Type | Class and Description |
---|---|
protected class |
RoundTrip.Sender |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
channel |
protected boolean |
details |
protected boolean |
dont_bundle |
protected int |
num_msgs |
protected int |
num_senders |
protected boolean |
oob |
protected static byte |
REQ |
protected static byte |
RSP |
protected RoundTrip.Sender[] |
senders |
Constructor and Description |
---|
RoundTrip() |
Modifier and Type | Method and Description |
---|---|
protected void |
loop() |
static void |
main(String[] args) |
protected static String |
print(AverageMinMax avg) |
void |
receive(Message msg)
On the server: receive a request, send a response.
|
protected void |
sendRequests() |
protected void |
start(String props,
String name) |
void |
viewAccepted(View view)
Called when a change in membership has occurred.
|
protected JChannel channel
protected int num_msgs
protected int num_senders
protected boolean oob
protected boolean dont_bundle
protected boolean details
protected static final byte REQ
protected static final byte RSP
protected RoundTrip.Sender[] senders
public void receive(Message msg)
receive
in interface MessageListener
receive
in class ReceiverAdapter
msg
- public void viewAccepted(View view)
ReceiverAdapter
Channel.connect(String)
returns.viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
protected void loop()
protected static String print(AverageMinMax avg)
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.