FlowProcess

IShutDown

doShutdown()

Executor

queue:BlockingQueueBatch

addTask(Batch): boolean

FailedMailDao

1:*

Service

startJob()preShutdown()afterShutdown()

readQueue: BlockingQueue

接口

ProcessManager

Batch

mailType:MailTypeactionType:ActionTypelist: List

add(T)addAll(List)

IDataSource

Process

process(List):List

addBatch(S)onSuccess(Batch)onFailure(Batch)