net.sf.jqql
Class ResendTrigger<T>

java.lang.Object
  net.sf.jqql.ResendTrigger<T>

All Implemented Interfaces:

Callable<T>

public class ResendTrigger<T>
extends Object
implements Callable<T>

Constructor Summary

ResendTrigger(QQClient client)

Method Summary

void	add(OutPacket packet, String name) add a package to timeout queue æ·»åŠ ä¸€ä¸ªåŒ…åˆ°è¶…æ—¶é˜Ÿåˆ—
T	call()
void	clear() clear the queue which wanna resend 清空重发队列
OutPacket	get() get the frist package in the timeout queue and do not delete from queue å¾—åˆ°è¶…æ—¶é˜Ÿåˆ—çš„ç¬¬ä¸€ä¸ªåŒ…ï¼Œä¸æŠŠå®ƒä»Žé˜Ÿåˆ—ä¸­åˆ é™¤
OutPacket	remove() get the frist package in the timeout queue and delete it from queue å¾—åˆ°è¶…æ—¶é˜Ÿåˆ—çš„ç¬¬ä¸€ä¸ªåŒ…ï¼Œå¹¶æŠŠå®ƒä»Žé˜Ÿåˆ—ä¸­åˆ é™¤
void	remove(InPacket ack) delete the package which is mapping ack åˆ é™¤ack对应的请求包

Methods inherited from class java.lang.Object

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

Constructor Detail

ResendTrigger

public ResendTrigger(QQClient client)

Method Detail

add

public void add(OutPacket packet,
                String name)

add a package to timeout queue æ·»åŠ ä¸€ä¸ªåŒ…åˆ°è¶…æ—¶é˜Ÿåˆ—

Parameters:

packet - send package object 发送包对象

name - port name port名称

clear

public void clear()

clear the queue which wanna resend 清空重发队列

get

public OutPacket get()

get the frist package in the timeout queue and do not delete from queue å¾—åˆ°è¶…æ—¶é˜Ÿåˆ—çš„ç¬¬ä¸€ä¸ªåŒ…ï¼Œä¸æŠŠå®ƒä»Žé˜Ÿåˆ—ä¸­åˆ é™¤

Returns:

the frist package in timeout queue,if no,return null 超时队列的第一个包，如果没有，返回null

remove

public OutPacket remove()

get the frist package in the timeout queue and delete it from queue å¾—åˆ°è¶…æ—¶é˜Ÿåˆ—çš„ç¬¬ä¸€ä¸ªåŒ…ï¼Œå¹¶æŠŠå®ƒä»Žé˜Ÿåˆ—ä¸­åˆ é™¤

Returns:

the frist package in timeout queue,if no,return null 超时队列的第一个包，如果没有，返回null

remove

public void remove(InPacket ack)

delete the package which is mapping ack åˆ é™¤ack对应的请求包

Parameters:

ack -

call

public T call()
       throws Exception

Specified by:

call in interface Callable<T>

Throws:

Exception