TerminationContext

java.lang.Object
- cz.o2.proxima.direct.core.batch.TerminationContext

All Implemented Interfaces:

ObserveHandle, java.lang.AutoCloseable
```
@Internal
public class TerminationContext
extends java.lang.Object
implements ObserveHandle
```
A context that guards correct termination of batch observation process.

Constructor Summary

Constructors
Constructor Description

TerminationContext(BatchLogObserver observer)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancel()`	Force cancellation of `BatchLogReader.observe(java.util.List<cz.o2.proxima.core.storage.Partition>, java.util.List<cz.o2.proxima.core.repository.AttributeDescriptor<?>>, cz.o2.proxima.direct.core.batch.BatchLogObserver)`.
`void`	`close()`	Stop the consumption.
`void`	`finished()`
`void`	`handleErrorCaught(java.lang.Throwable err, java.lang.Runnable retry)`

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

Methods inherited from interface cz.o2.proxima.direct.core.batch.ObserveHandle
disableRateLimiting, isReadyForProcessing

- Constructor Detail
  - TerminationContext
```
public TerminationContext(BatchLogObserver observer)
```
- Method Detail
  - cancel
```
public void cancel()
```
    Force cancellation of BatchLogReader.observe(java.util.List<cz.o2.proxima.core.storage.Partition>, java.util.List<cz.o2.proxima.core.repository.AttributeDescriptor<?>>, cz.o2.proxima.direct.core.batch.BatchLogObserver).
  - finished
```
public void finished()
```
  - handleErrorCaught
```
public void handleErrorCaught(java.lang.Throwable err,
                              java.lang.Runnable retry)
```
  - close
```
public void close()
```
    Description copied from interface: ObserveHandle
    
    Stop the consumption.
    
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface ObserveHandle