Class MaxOneThreadPerSender.Entry

java.lang.Object

org.jgroups.util.MaxOneThreadPerSender.Entry

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

MaxOneThreadPerSender

protected class MaxOneThreadPerSender.Entry
extends Object
implements Closeable

Since:

4.0

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected final MessageBatch	batch
protected final AsciiString	cluster_name
protected final Address	dest
protected final boolean	loopback
protected final BlockingQueue<Message>	mq
protected final Runner	mq_handler
protected final LongAdder	queued_msgs
protected final Address	sender

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Entry(Address sender, Address dest, AsciiString cluster_name)

Method Summary

Modifier and Type	Method	Description
void	close()
protected boolean	process(Message msg)
protected boolean	process(MessageBatch batch)
MaxOneThreadPerSender.Entry	reset()
protected void	run()
MaxOneThreadPerSender.Entry	start()
void	stop()
String	toString()
MaxOneThreadPerSender.Entry	trimToInitialCapacity()

Methods inherited from class Object

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

Field Details

batch

protected final MessageBatch batch

mq

protected final BlockingQueue<Message> mq

mq_handler

protected final Runner mq_handler

dest

protected final Address dest

sender

protected final Address sender

cluster_name

protected final AsciiString cluster_name

queued_msgs

protected final LongAdder queued_msgs

loopback

protected final boolean loopback

Constructor Details

Entry

protected Entry(Address sender,
 Address dest,
 AsciiString cluster_name)

Method Details

reset

public MaxOneThreadPerSender.Entry reset()

start

public MaxOneThreadPerSender.Entry start()

stop

public void stop()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

trimToInitialCapacity

public MaxOneThreadPerSender.Entry trimToInitialCapacity()

process

protected boolean process(Message msg)

process

protected boolean process(MessageBatch batch)

run

protected void run()

toString

public String toString()

Overrides:

toString in class Object