org.cg.eventbus.producer.manager

Class BaseManager<V>

java.lang.Object

org.cg.eventbus.producer.manager.BaseManager<V>

public abstract class BaseManager<V>
extends Object

Author:

liang.li

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseManager()

Method Summary

Methods

Modifier and Type	Method and Description
abstract AbstractEventProducer	borrowProducer(String topic)
abstract void	close() Release resources manager and its producers/pools have.
static BaseManager	getInstance(org.apache.commons.configuration.Configuration config)
abstract void	returnProducer(String topic, AbstractEventProducer producer)
abstract void	send(V msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseManager

protected BaseManager()

Method Detail

getInstance

public static BaseManager getInstance(org.apache.commons.configuration.Configuration config)

borrowProducer

public abstract AbstractEventProducer borrowProducer(String topic)
                                              throws Exception

Throws:

Exception

returnProducer

public abstract void returnProducer(String topic,
                  AbstractEventProducer producer)

send

public abstract void send(V msg)
                   throws Exception

Throws:

Exception

close

public abstract void close()

Release resources manager and its producers/pools have.