com.fr.third.jgroups.protocols

类 TP.BaseBundler

java.lang.Object

com.fr.third.jgroups.protocols.TP.BaseBundler

所有已实现的接口:

TP.Bundler

直接已知子类:

TP.SenderSendsBundler, TP.SenderSendsWithTimerBundler, TP.TransferQueueBundler

封闭类:

TP

protected class TP.BaseBundler
extends java.lang.Object
implements TP.Bundler

构造器概要

构造器

限定符	构造器和说明
protected	TP.BaseBundler()

方法概要

方法

限定符和类型	方法和说明
protected void	addMessage(Message msg, long size)
protected void	checkLength(long len)
protected int	numMessages(java.util.Map<SingletonAddress,java.util.List<Message>> msgs)
void	send(Message msg)
protected void	sendBundledMessages(java.util.Map<SingletonAddress,java.util.List<Message>> msgs, ByteArrayDataOutputStream out) Sends all messages in the map.
protected void	sendMessageList(Address dest, Address src, byte[] cluster_name, java.util.List<Message> list, boolean reset, ByteArrayDataOutputStream out)
protected void	sendSingleMessage(Message msg, boolean reset, ByteArrayDataOutputStream out)
void	start()
void	stop()

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

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

构造器详细资料

TP.BaseBundler

protected TP.BaseBundler()

方法详细资料

start

public void start()

指定者:

start 在接口中 TP.Bundler

stop

public void stop()

指定者:

stop 在接口中 TP.Bundler

send

public void send(Message msg)
          throws java.lang.Exception

指定者:

send 在接口中 TP.Bundler

抛出:

java.lang.Exception

sendBundledMessages

protected void sendBundledMessages(java.util.Map<SingletonAddress,java.util.List<Message>> msgs,
                       ByteArrayDataOutputStream out)

Sends all messages in the map. Messages for the same destination are bundled into a message list. The map will be cleared when done

numMessages

protected int numMessages(java.util.Map<SingletonAddress,java.util.List<Message>> msgs)

sendSingleMessage

protected void sendSingleMessage(Message msg,
                     boolean reset,
                     ByteArrayDataOutputStream out)

sendMessageList

protected void sendMessageList(Address dest,
                   Address src,
                   byte[] cluster_name,
                   java.util.List<Message> list,
                   boolean reset,
                   ByteArrayDataOutputStream out)

addMessage

protected void addMessage(Message msg,
              long size)

checkLength

protected void checkLength(long len)
                    throws java.lang.Exception

抛出:

java.lang.Exception