public interface AckReader
| Modifier and Type | Interface and Description | 
|---|---|
static class  | 
AckReader.AckReaderState  | 
| Modifier and Type | Method and Description | 
|---|---|
AckProcessor | 
getAckProcessor()
getAckProcessor 
 | 
String | 
getName()
getName 
 | 
AckReader.AckReaderState | 
getState()
getState 
 | 
void | 
pause()
pause 
 | 
void | 
resume(ScheduledThreadPoolExecutor executor)
resume 
 | 
void | 
setAckProcessor(AckProcessor ackProcessor)
setAckProcessor 
 | 
void | 
setName(String name)
setName 
 | 
void | 
start(ScheduledThreadPoolExecutor executor,
     ReaderSchedule schedule,
     boolean reloadConfig)
start 
 | 
void | 
stop()
stop 
 | 
void start(ScheduledThreadPoolExecutor executor, ReaderSchedule schedule, boolean reloadConfig)
start
executor - a ScheduledThreadPoolExecutor object.schedule - a ReaderSchedule object.reloadConfig - a boolean.void pause()
pause
void resume(ScheduledThreadPoolExecutor executor)
resume
executor - a ScheduledThreadPoolExecutor object.void stop()
stop
void setAckProcessor(AckProcessor ackProcessor)
setAckProcessor
ackProcessor - a AckProcessor object.AckProcessor getAckProcessor()
getAckProcessor
AckProcessor object.AckReader.AckReaderState getState()
getState
AckReader.AckReaderState object.Copyright © 2020. All rights reserved.