Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<ByteArrayDataOutputStream> |
buf_pool |
protected int |
initial_buf_size |
protected Log |
log |
protected int |
pool_size |
protected TP |
transport |
Constructor and Description |
---|
NoBundler() |
Modifier and Type | Method and Description |
---|---|
void |
init(TP transport)
Called after creation of the bundler
|
int |
initialBufSize() |
NoBundler |
initialBufSize(int s) |
int |
poolSize() |
NoBundler |
poolSize(int s) |
void |
send(Message msg) |
protected void |
sendSingleMessage(Message msg,
ByteArrayDataOutputStream output) |
int |
size()
The number of unsent messages in the bundler
|
void |
start()
Called after
Bundler.init(TP) |
void |
stop() |
void |
viewChange(View view) |
protected TP transport
protected Log log
protected int pool_size
protected BlockingQueue<ByteArrayDataOutputStream> buf_pool
protected int initial_buf_size
public NoBundler poolSize(int s)
public int size()
Bundler
public int initialBufSize()
public NoBundler initialBufSize(int s)
public int poolSize()
public void viewChange(View view)
viewChange
in interface Bundler
public void init(TP transport)
Bundler
public void start()
Bundler
Bundler.init(TP)
protected void sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.