org.masukomi.aspirin.core.delivery

Class GenericPoolableDeliveryThreadFactory

java.lang.Object

org.apache.commons.pool.BasePoolableObjectFactory

org.masukomi.aspirin.core.delivery.GenericPoolableDeliveryThreadFactory

All Implemented Interfaces:

org.apache.commons.pool.PoolableObjectFactory

public class GenericPoolableDeliveryThreadFactory
extends org.apache.commons.pool.BasePoolableObjectFactory

This object handles the DeliveryThread thread objects in the ObjectPool.

Author:

Laszlo Solova

Field Summary

Fields

Modifier and Type	Field and Description
private Configuration	configuration
private DeliveryManager	deliveryManager
private ThreadGroup	deliveryThreadGroup This is the ThreadGroup of DeliveryThread objects.
private static org.slf4j.Logger	log
private org.apache.commons.pool.ObjectPool	myParentPool
private Integer	rdCount This is the counter of created DeliveryThread thread objects.
private Object	rdLock

Constructor Summary

Constructors

Constructor and Description
GenericPoolableDeliveryThreadFactory(DeliveryManager deliveryManager, Configuration configuration)

Method Summary

Methods

Modifier and Type	Method and Description
void	destroyObject(Object obj)
void	init(ThreadGroup deliveryThreadGroup, org.apache.commons.pool.ObjectPool pool) Initialization of this Factory.
Object	makeObject()
boolean	validateObject(Object obj)

Methods inherited from class org.apache.commons.pool.BasePoolableObjectFactory

activateObject, passivateObject

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

deliveryThreadGroup

private ThreadGroup deliveryThreadGroup

This is the ThreadGroup of DeliveryThread objects. On shutdown it is easier to close all DeliveryThread threads with usage of this group.

myParentPool

private org.apache.commons.pool.ObjectPool myParentPool

rdCount

private Integer rdCount

This is the counter of created DeliveryThread thread objects.

rdLock

private Object rdLock

deliveryManager

private final DeliveryManager deliveryManager

configuration

private final Configuration configuration

Constructor Detail

GenericPoolableDeliveryThreadFactory

public GenericPoolableDeliveryThreadFactory(DeliveryManager deliveryManager,
                                    Configuration configuration)

Method Detail

init

public void init(ThreadGroup deliveryThreadGroup,
        org.apache.commons.pool.ObjectPool pool)

Initialization of this Factory. Prerequisite of right working.

Parameters:

deliveryThreadGroup - The threadgroup which contains the DeliveryThread threads.

pool - The pool which use this factory to create and handle objects.

makeObject

public Object makeObject()
                  throws Exception

Specified by:

makeObject in interface org.apache.commons.pool.PoolableObjectFactory

Specified by:

makeObject in class org.apache.commons.pool.BasePoolableObjectFactory

Throws:

Exception

destroyObject

public void destroyObject(Object obj)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool.PoolableObjectFactory

Overrides:

destroyObject in class org.apache.commons.pool.BasePoolableObjectFactory

Throws:

Exception

validateObject

public boolean validateObject(Object obj)

Specified by:

validateObject in interface org.apache.commons.pool.PoolableObjectFactory

Overrides:

validateObject in class org.apache.commons.pool.BasePoolableObjectFactory