Package org.apache.qpid.protonj2.engine.impl

Class ProtonPooledTagGenerator

java.lang.Object

org.apache.qpid.protonj2.engine.impl.ProtonDeliveryTagGenerator

org.apache.qpid.protonj2.engine.impl.ProtonSequentialTagGenerator

org.apache.qpid.protonj2.engine.impl.ProtonPooledTagGenerator

All Implemented Interfaces:

DeliveryTagGenerator

public class ProtonPooledTagGenerator
extends ProtonSequentialTagGenerator

Built in Transfer DeliveryTag generator that uses a fixed size tag pool to reduce GC overhead by reusing tags that have been released from settled messages. When not using cached tags the generator creates new tags using a running tag counter of type Long that assumes that when it wraps the user has already release all tags within the lower range of the tag counter.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.protonj2.engine.impl.ProtonSequentialTagGenerator

ProtonSequentialTagGenerator.ProtonNumericDeliveryTag

Nested classes/interfaces inherited from class org.apache.qpid.protonj2.engine.impl.ProtonDeliveryTagGenerator

ProtonDeliveryTagGenerator.BUILTIN

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_NUM_POOLED_TAGS	The default number of pooled transfer tags for this generator.

Fields inherited from class org.apache.qpid.protonj2.engine.impl.ProtonSequentialTagGenerator

nextTagId

Constructor Summary

Constructors

Constructor	Description
ProtonPooledTagGenerator()	Creates a new ProtonPooledTagGenerator instance with the default pool size.
ProtonPooledTagGenerator(int poolSize)	Creates a new ProtonPooledTagGenerator instance with the given pool size.

Method Summary

Modifier and Type	Method	Description
DeliveryTag	nextTag()	Creates and returns the next DeliveryTag tag that should be used when populating an OutgoingDelivery.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MAX_NUM_POOLED_TAGS

public static final int DEFAULT_MAX_NUM_POOLED_TAGS

The default number of pooled transfer tags for this generator.

See Also:

• Constant Field Values

Constructor Details

ProtonPooledTagGenerator

public ProtonPooledTagGenerator()

Creates a new ProtonPooledTagGenerator instance with the default pool size.

ProtonPooledTagGenerator

public ProtonPooledTagGenerator(int poolSize)

Creates a new ProtonPooledTagGenerator instance with the given pool size.

Parameters:

poolSize - The size of the transfer tag pool that should be allocated for this generator.

Method Details

nextTag

public DeliveryTag nextTag()

Description copied from interface: DeliveryTagGenerator

Creates and returns the next DeliveryTag tag that should be used when populating an OutgoingDelivery.

Specified by:

nextTag in interface DeliveryTagGenerator

Overrides:

nextTag in class ProtonSequentialTagGenerator

Returns:

the next DeliveryTag to use for an OutgoingDelivery.