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 © 2021. All rights reserved.