程序包 gu.sql2java

类 QueueProducerAction.SimpleQueueProducerAction<B extends gu.sql2java.BaseBean>

java.lang.Object

gu.sql2java.QueueProducerAction<B,B>

gu.sql2java.QueueProducerAction.SimpleQueueProducerAction<B>

类型参数:

B - 从数据库读取的原始记录对象类型

所有已实现的接口:

gu.sql2java.TableManager.Action<B>

封闭类:

QueueProducerAction<B extends gu.sql2java.BaseBean,T>

public static class QueueProducerAction.SimpleQueueProducerAction<B extends gu.sql2java.BaseBean>
extends QueueProducerAction<B,B>

QueueProducerAction的简化版本,队列类型为数据库原始记录类型

从以下版本开始:

3.15.4

作者:

guyadong

嵌套类概要

从类继承的嵌套类/接口 gu.sql2java.QueueProducerAction

QueueProducerAction.SimpleQueueProducerAction<B extends gu.sql2java.BaseBean>

构造器概要

构造器

构造器	说明
SimpleQueueProducerAction()	默认构造方法 队列容量和插入队列超时时间使用默认值
SimpleQueueProducerAction(int queueCapaticy, int queueTimeout)	构造方法
SimpleQueueProducerAction(BlockingQueue<B> queue, int queueTimeout)	构造方法

方法概要

从类继承的方法 gu.sql2java.QueueProducerAction

call, getQueue

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

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

构造器详细资料

SimpleQueueProducerAction

public SimpleQueueProducerAction(BlockingQueue<B> queue,
 int queueTimeout)

构造方法

参数:

queue - 阻塞队列

queueTimeout - 插入队列超时时间(秒), 队列满后超过这个时间不能插入新记录即视消费端中止,并中止插入, 小于等于0使用默认值QueueProducerAction.DEFAULT_QUEUE_TIMEOUT

SimpleQueueProducerAction

public SimpleQueueProducerAction(int queueCapaticy,
 int queueTimeout)

构造方法

参数:

queueCapaticy - 队列容量,小于等于0使用默认值QueueProducerAction.DEFAULT_QUEUE_CAPACITY

queueTimeout - 插入队列超时时间(秒), 队列满后超过这个时间不能插入新记录即视消费端中止,并中止插入, 小于等于0使用默认值QueueProducerAction.DEFAULT_QUEUE_TIMEOUT

SimpleQueueProducerAction

public SimpleQueueProducerAction()

默认构造方法
队列容量和插入队列超时时间使用默认值