import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicInteger;
import java.nio.ByteBuffer;</BUG>
public class UnicastTestRpc extends ReceiverAdapter {
<BUG>private JChannel channel;
private RpcDispatcher disp;</BUG>
static final String groupname="UnicastTest-Group";
private long sleep_time=0;
<BUG>private boolean exit_on_end=false, busy_sleep=false, sync=false, oob=false;
</BUG>
private int num_threads=1;

import java.util.concurrent.atomic.AtomicLong;
public class UnicastTestRpc extends ReceiverAdapter {
private JChannel channel;
private Address local_addr;
private RpcDispatcher disp;
static final String groupname="UnicastTest-Group";
private long sleep_time=0;
private boolean exit_on_end=false, busy_sleep=false, sync=false, oob=false, anycasting=false;
