TcpBufferedInputStream (ActiveMQ 5.17.0 API)

java.lang.Object
- java.io.InputStream
- - java.io.FilterInputStream
  - - org.apache.activemq.transport.tcp.TcpBufferedInputStream

All Implemented Interfaces:

Closeable, AutoCloseable
```
public class TcpBufferedInputStream
extends FilterInputStream
```
An optimized buffered input stream for Tcp

Field Summary

Fields
Modifier and Type Field Description

protected int count

protected byte[] internalBuffer

protected int position
- Fields inherited from class java.io.FilterInputStream
  in

Constructor Summary

Constructors
Constructor Description

TcpBufferedInputStream(InputStream in)

TcpBufferedInputStream(InputStream in, int size)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`int`	`available()`
`void`	`close()`
`protected void`	`fill()`
`boolean`	`markSupported()`
`int`	`read()`
`int`	`read(byte[] b, int off, int len)`
`long`	`skip(long n)`
`void`	`unread(byte[] array)`

Methods inherited from class java.io.FilterInputStream
mark, read, reset

Methods inherited from class java.io.InputStream
nullInputStream, readAllBytes, readNBytes, readNBytes, transferTo

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

Field Detail

internalBuffer
```
protected byte[] internalBuffer
```

count
```
protected int count
```

position
```
protected int position
```

Constructor Detail

TcpBufferedInputStream

public TcpBufferedInputStream(InputStream in)

TcpBufferedInputStream

public TcpBufferedInputStream(InputStream in,
                              int size)

Method Detail
- fill
```
protected void fill()
             throws IOException
```
  Throws:
  
  IOException
- read
```
public int read()
         throws IOException
```
  Overrides:
  
  read in class FilterInputStream
  
  Throws:
  
  IOException
- read
```
public int read(byte[] b,
                int off,
                int len)
         throws IOException
```
  Overrides:
  
  read in class FilterInputStream
  
  Throws:
  
  IOException
- skip
```
public long skip(long n)
          throws IOException
```
  Overrides:
  
  skip in class FilterInputStream
  
  Throws:
  
  IOException
- available
```
public int available()
              throws IOException
```
  Overrides:
  
  available in class FilterInputStream
  
  Throws:
  
  IOException
- markSupported
```
public boolean markSupported()
```
  Overrides:
  
  markSupported in class FilterInputStream
- close
```
public void close()
           throws IOException
```
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface Closeable
  
  Overrides:
  
  close in class FilterInputStream
  
  Throws:
  
  IOException
- unread
```
public void unread(byte[] array)
            throws IOException
```
  Parameters:
  
  array -
  
  Throws:
  
  IOException