org.cg.eventbus.producer

Class PooledEventProducerFactory<K,V>

java.lang.Object

org.apache.commons.pool2.BasePooledObjectFactory<AbstractEventProducer<K,V>>

org.cg.eventbus.producer.PooledEventProducerFactory<K,V>

All Implemented Interfaces:

org.apache.commons.pool2.PooledObjectFactory<AbstractEventProducer<K,V>>

public class PooledEventProducerFactory<K,V>
extends org.apache.commons.pool2.BasePooledObjectFactory<AbstractEventProducer<K,V>>

Author:

yanlinwang, liang.li

Constructor Summary

Constructors

Constructor and Description
PooledEventProducerFactory(Class<? extends AbstractEventProducer> poolType, org.apache.commons.configuration.Configuration config)
PooledEventProducerFactory(Class<? extends AbstractEventProducer> poolType, String fileName)

Method Summary

Methods

Modifier and Type	Method and Description
AbstractEventProducer<K,V>	create()
void	destroyObject(org.apache.commons.pool2.PooledObject<AbstractEventProducer<K,V>> p)
org.apache.commons.pool2.PooledObject<AbstractEventProducer<K,V>>	wrap(AbstractEventProducer<K,V> provider)

Methods inherited from class org.apache.commons.pool2.BasePooledObjectFactory

activateObject, makeObject, passivateObject, validateObject

Methods inherited from class java.lang.Object

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

Constructor Detail

PooledEventProducerFactory

public PooledEventProducerFactory(Class<? extends AbstractEventProducer> poolType,
                          String fileName)
                           throws org.apache.commons.configuration.ConfigurationException

Throws:

org.apache.commons.configuration.ConfigurationException

PooledEventProducerFactory

public PooledEventProducerFactory(Class<? extends AbstractEventProducer> poolType,
                          org.apache.commons.configuration.Configuration config)

Method Detail

create

public AbstractEventProducer<K,V> create()
                                  throws Exception

Specified by:

create in class org.apache.commons.pool2.BasePooledObjectFactory<AbstractEventProducer<K,V>>

Throws:

Exception

wrap

public org.apache.commons.pool2.PooledObject<AbstractEventProducer<K,V>> wrap(AbstractEventProducer<K,V> provider)

Specified by:

wrap in class org.apache.commons.pool2.BasePooledObjectFactory<AbstractEventProducer<K,V>>

destroyObject

public void destroyObject(org.apache.commons.pool2.PooledObject<AbstractEventProducer<K,V>> p)

Specified by:

destroyObject in interface org.apache.commons.pool2.PooledObjectFactory<AbstractEventProducer<K,V>>

Overrides:

destroyObject in class org.apache.commons.pool2.BasePooledObjectFactory<AbstractEventProducer<K,V>>