CloseableBuffer (AxonServer Connector 2026.0.0 API)

Type Parameters:

T - the type of messages in this buffer

All Superinterfaces:

CloseableReadonlyBuffer<T>

All Known Implementing Classes:

BlockingCloseableBuffer
```
public interface CloseableBuffer<T>
extends CloseableReadonlyBuffer<T>
```
A buffer that can be closed by the producing side.

Since:

4.6.0

Author:

Milan Savic, Stefan Dragisic, Allard Buijze

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`close()`	Closes this buffer from the producing side.
`void`	`closeExceptionally(ErrorMessage errorMessage)`	Closes this buffer exceptionally from the producing side.
`void`	`put(T message)`	Puts a message in this buffer.

Methods inherited from interface io.axoniq.axonserver.connector.impl.CloseableReadonlyBuffer
capacity, closed, error, isEmpty, onAvailable, poll

- Method Detail
  - put
```
void put(T message)
```
    Puts a message in this buffer.
    
    Parameters:
    
    message - the message to be put in this buffer
  - close
```
void close()
```
    Closes this buffer from the producing side.
  - closeExceptionally
```
void closeExceptionally(ErrorMessage errorMessage)
```
    Closes this buffer exceptionally from the producing side.
    
    Parameters:
    
    errorMessage - an error indicating why this buffer is closed