程序包 top.yqingyu.common.qymsg

类 MsgHelper

java.lang.Object

top.yqingyu.common.qymsg.MsgHelper

所有已实现的接口:

Runnable

public class MsgHelper
extends Object
implements Runnable

版本:

1.0.0

作者:

YYJ

构造器概要

构造器

构造器	说明
MsgHelper(BlockingQueue<QyMsg> inQueue, BlockingQueue<QyMsg> outQueue, AtomicBoolean running, int clearTime)

方法概要

修饰符和类型	方法	说明
static String	gainMsg(QyMsg msg)
static Object	gainMsgOBJ(QyMsg msg, String key)
static String	gainMsgValue(QyMsg msg, String key)
static Object	gainObjMsg(QyMsg msg)
static void	init(BlockingQueue<QyMsg> inQueue, BlockingQueue<QyMsg> outQueue, String thName, AtomicBoolean running, int clearTime)
void	run()

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

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

构造器详细资料

MsgHelper

public MsgHelper(BlockingQueue<QyMsg> inQueue,
 BlockingQueue<QyMsg> outQueue,
 AtomicBoolean running,
 int clearTime)

方法详细资料

gainMsg

public static String gainMsg(QyMsg msg)

gainObjMsg

public static Object gainObjMsg(QyMsg msg)

gainMsgValue

public static String gainMsgValue(QyMsg msg,
 String key)

gainMsgOBJ

public static Object gainMsgOBJ(QyMsg msg,
 String key)

init

public static void init(BlockingQueue<QyMsg> inQueue,
 BlockingQueue<QyMsg> outQueue,
 String thName,
 AtomicBoolean running,
 int clearTime)

参数:

inQueue - 输入队列

outQueue - 输出队列

thName - 线程名称

running - 运行

run

public void run()

指定者:

run 在接口中 Runnable