Package io.micronaut.jms.pool

Class SessionPool

java.lang.Object

io.micronaut.jms.pool.AbstractPool<PooledObject<jakarta.jms.Session>>

io.micronaut.jms.pool.SessionPool

public class SessionPool
extends AbstractPool<PooledObject<jakarta.jms.Session>>

Pool for ensuring maximum reuse of Sessions within an application.

Since:

1.0.0

Author:

Elliott Pope

See Also:

• SessionPoolFactory
• PooledConnection

Field Summary

Fields inherited from class io.micronaut.jms.pool.AbstractPool

initialSize, maxSize, pool

Constructor Summary

Constructors

Constructor	Description
SessionPool(int initialSize, int maxSize, jakarta.jms.Connection connection, MessageProducerPoolFactory producerPoolFactory)

Method Summary

Modifier and Type	Method	Description
protected PooledObject<jakarta.jms.Session>	create(Object... args)	Create an object for the pool.
protected void	reset(PooledObject<jakarta.jms.Session> pooledObject)	Reset the provided object so it can be returned to the pool for reuse.
String	toString()

Methods inherited from class io.micronaut.jms.pool.AbstractPool

release, request

Methods inherited from class java.lang.Object

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

Constructor Details

SessionPool

public SessionPool(int initialSize,
 int maxSize,
 jakarta.jms.Connection connection,
 MessageProducerPoolFactory producerPoolFactory)

Method Details

toString

public String toString()

Overrides:

toString in class Object

create

protected PooledObject<jakarta.jms.Session> create(Object... args)

Description copied from class: AbstractPool

Create an object for the pool.

Specified by:

create in class AbstractPool<PooledObject<jakarta.jms.Session>>

Parameters:

args - the arguments to be provided to the create method.

Returns:

a new object of type <T> for the pool.

reset

protected void reset(PooledObject<jakarta.jms.Session> pooledObject)

Description copied from class: AbstractPool

Reset the provided object so it can be returned to the pool for reuse.

Specified by:

reset in class AbstractPool<PooledObject<jakarta.jms.Session>>

Parameters:

pooledObject - the object