public class UnicastTestRpc extends ReceiverAdapter
Modifier and Type | Field and Description |
---|---|
protected AtomicInteger |
num_requests |
Constructor and Description |
---|
UnicastTestRpc() |
Modifier and Type | Method and Description |
---|---|
void |
eventLoop() |
protected static List<String> |
getSites(JChannel channel) |
void |
init(String props,
String name,
String cluster_name) |
static void |
main(String[] args) |
void |
receiveData(byte[] buffer) |
void |
viewAccepted(View new_view)
Called when a change in membership has occurred.
|
protected final AtomicInteger num_requests
public void init(String props, String name, String cluster_name) throws Exception
Exception
public void viewAccepted(View new_view)
ReceiverAdapter
Channel.connect(String)
returns.viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
public void receiveData(byte[] buffer)
public static void main(String[] args)
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.