Apache.Qpid.Proton.Engine.AmqpPerformativeEnvelopePool< T > Class Template Reference

Public Member Functions
	AmqpPerformativeEnvelopePool (Func< AmqpPerformativeEnvelopePool< T >, T > envelopeBuilder)
	Create a new envelope pool using the default pool size.
	AmqpPerformativeEnvelopePool (Func< AmqpPerformativeEnvelopePool< T >, T > envelopeBuilder, int maxPoolSize)
	Create a new envelope pool using the given pool size.
T	Take (IPerformative body, ushort channel, IProtonBuffer payload)
	Request to borrow a pooled object or create a new non-pooled instance if no pooled values are available.

Static Public Member Functions
static AmqpPerformativeEnvelopePool< IncomingAmqpEnvelope >	IncomingEnvelopePool (int maxPoolSize)
static AmqpPerformativeEnvelopePool< IncomingAmqpEnvelope >	IncomingEnvelopePool ()
static AmqpPerformativeEnvelopePool< OutgoingAmqpEnvelope >	OutgoingEnvelopePool (int maxPoolSize)
static AmqpPerformativeEnvelopePool< OutgoingAmqpEnvelope >	OutgoingEnvelopePool ()

Static Public Attributes
static readonly int	DEFAULT_MAX_POOL_SIZE = 10
	The default maximum pool size to use if not otherwise configured.

Properties
int	MaxPoolSize [get]
	Returns the configured maximum pool size which indicates how many elements can be pooled before new non-pooled values are created when a request arrives but all the current elements are on loan.

Constructor & Destructor Documentation

AmqpPerformativeEnvelopePool() [1/2]

Apache.Qpid.Proton.Engine.AmqpPerformativeEnvelopePool< T >.AmqpPerformativeEnvelopePool ( Func< AmqpPerformativeEnvelopePool< T >, T >  envelopeBuilder )

inline

Create a new envelope pool using the default pool size.

Parameters

envelopeBuilder

A function that can build the envelopes

AmqpPerformativeEnvelopePool() [2/2]

Apache.Qpid.Proton.Engine.AmqpPerformativeEnvelopePool< T >.AmqpPerformativeEnvelopePool ( Func< AmqpPerformativeEnvelopePool< T >, T >  envelopeBuilder, int  maxPoolSize  )

inline

Create a new envelope pool using the given pool size.

Parameters

envelopeBuilder	A function that can build the envelopes
maxPoolSize	The maximum number of entries in the pool

Member Function Documentation

Take()

T Apache.Qpid.Proton.Engine.AmqpPerformativeEnvelopePool< T >.Take ( IPerformative  body, ushort  channel, IProtonBuffer  payload  )

inline

Request to borrow a pooled object or create a new non-pooled instance if no pooled values are available.

Parameters

body
channel
payload

Returns

---

The documentation for this class was generated from the following file:

• src/Proton/Engine/AmqpPerformativeEnvelopePool.cs