public final class AmqpTransferTagGenerator extends Object
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_TAG_POOL_SIZE |
Constructor and Description |
---|
AmqpTransferTagGenerator() |
AmqpTransferTagGenerator(boolean pool) |
Modifier and Type | Method and Description |
---|---|
int |
getMaxPoolSize()
Gets the current max pool size value.
|
byte[] |
getNextTag()
Retrieves the next available tag.
|
void |
returnTag(byte[] data)
When used as a pooled cache of tags the unused tags should always be returned once
the transfer has been settled.
|
void |
setMaxPoolSize(int maxPoolSize)
Sets the max tag pool size.
|
public static final int DEFAULT_TAG_POOL_SIZE
public AmqpTransferTagGenerator()
public AmqpTransferTagGenerator(boolean pool)
public byte[] getNextTag()
public void returnTag(byte[] data)
data
- a previously borrowed tag that is no longer in use.public int getMaxPoolSize()
public void setMaxPoolSize(int maxPoolSize)
maxPoolSize
- the maximum number of tags to hold in the pool.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.