NoBundler

java.lang.Object
- org.jgroups.protocols.NoBundler

All Implemented Interfaces:

Bundler
```
public class NoBundler
extends java.lang.Object
implements Bundler
```
Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g. at runtime)

Since:

3.6.10

Author:

Bela Ban

Field Summary

Fields
Modifier and Type	Field and Description
`protected java.util.concurrent.BlockingQueue<ByteArrayDataOutputStream>`	`buf_pool`
`protected int`	`initial_buf_size`
`protected Log`	`log`
`protected int`	`pool_size`
`protected TP`	`transport`

Constructor Summary

Constructors
Constructor and Description

NoBundler()

Constructors
Constructor and Description
`NoBundler()`

Method Summary

All Methods Instance Methods Concrete Methods
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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - transport
```
protected TP transport
```
  - log
```
protected Log log
```
  - pool_size
```
protected int pool_size
```
  - buf_pool
```
protected java.util.concurrent.BlockingQueue<ByteArrayDataOutputStream> buf_pool
```
  - initial_buf_size
```
protected int initial_buf_size
```
- Constructor Detail
  - NoBundler
```
public NoBundler()
```
- Method Detail
  - poolSize
```
public NoBundler poolSize(int s)
```
  - size
```
public int size()
```
    Description copied from interface: Bundler
    
    The number of unsent messages in the bundler
    
    Specified by:
    
    size in interface Bundler
  - initialBufSize
```
public int initialBufSize()
```
  - initialBufSize
```
public NoBundler initialBufSize(int s)
```
  - poolSize
```
public int poolSize()
```
  - viewChange
```
public void viewChange(View view)
```
    Specified by:
    
    viewChange in interface Bundler
  - init
```
public void init(TP transport)
```
    Description copied from interface: Bundler
    
    Called after creation of the bundler
    
    Specified by:
    
    init in interface Bundler
    
    Parameters:
    
    transport - the transport, for further reference
  - start
```
public void start()
```
    Description copied from interface: Bundler
    
    Called after Bundler.init(TP)
    
    Specified by:
    
    start in interface Bundler
  - stop
```
public void stop()
```
    Specified by:
    
    stop in interface Bundler
  - send
```
public void send(Message msg)
          throws java.lang.Exception
```
    Specified by:
    
    send in interface Bundler
    
    Throws:
    
    java.lang.Exception
  - sendSingleMessage
```
protected void sendSingleMessage(Message msg,
                                 ByteArrayDataOutputStream output)
```

Class NoBundler

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

transport

log

pool_size

buf_pool

initial_buf_size

Constructor Detail

NoBundler

Method Detail

poolSize

size

initialBufSize

initialBufSize

poolSize

viewChange

init

start

stop

send

sendSingleMessage