org.noear.solon.logging.persistent

类 PackagingQueueTaskImpl<Event>

java.lang.Object

org.noear.solon.logging.persistent.PackagingQueueTaskImpl<Event>

所有已实现的接口:

java.io.Closeable, java.lang.AutoCloseable, PackagingQueueTask<Event>

public class PackagingQueueTaskImpl<Event>
extends java.lang.Object
implements PackagingQueueTask<Event>, java.io.Closeable

打包队列（一个个添加；打包后批量处理） 提交时，每次提交100条；消费完后暂停0.1秒

从以下版本开始:

2.2

构造器概要

构造器

构造器和说明
PackagingQueueTaskImpl()

方法概要

限定符和类型	方法和说明
void	add(Event event) 添加
void	addAll(java.util.Collection<Event> events) 添加一批
void	close()
long	getInterval() 空闲休息时间
void	setIdleInterval(long interval) 设置空闲休息时间
void	setPacketSize(int packetSize) 设置包装合大小
void	setWorkHandler(PackagingWorkHandler<Event> workHandler) 设置工作处理

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

PackagingQueueTaskImpl

public PackagingQueueTaskImpl()

方法详细资料

setWorkHandler

public void setWorkHandler(PackagingWorkHandler<Event> workHandler)

从接口复制的说明: PackagingQueueTask

设置工作处理

指定者:

setWorkHandler 在接口中 PackagingQueueTask<Event>

add

public void add(Event event)

从接口复制的说明: PackagingQueueTask

添加

指定者:

add 在接口中 PackagingQueueTask<Event>

addAll

public void addAll(java.util.Collection<Event> events)

从接口复制的说明: PackagingQueueTask

添加一批

指定者:

addAll 在接口中 PackagingQueueTask<Event>

getInterval

public long getInterval()

空闲休息时间

setIdleInterval

public void setIdleInterval(long interval)

设置空闲休息时间

指定者:

setIdleInterval 在接口中 PackagingQueueTask<Event>

setPacketSize

public void setPacketSize(int packetSize)

设置包装合大小

指定者:

setPacketSize 在接口中 PackagingQueueTask<Event>

close

public void close()
           throws java.io.IOException

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

抛出:

java.io.IOException