org.cg.eventbus.producer

Class AbstractEventProducer<K,V>

java.lang.Object

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

All Implemented Interfaces:

IEventBus, IProducer<K,V>

public abstract class AbstractEventProducer<K,V>
extends Object
implements IProducer<K,V>

Producer using string key to partition

Author:

yanlinwang,liang.li

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_BROKER_LIST
static String	DEFAULT_PARTITION
static String	LEADER_ACK
static String	NO_ACK
static String	PRO_TYPE_ASYNC
static String	QUIT_ON_ERROR
static String	REPLICAS_ACK

Fields inherited from interface org.cg.eventbus.IProducer

BROKER_LIST, BYTE_SERIALIZER_CLASS, DEFAULT_KEY, KEY_SERIALIZER_CLASS, PARTITION_CLASS, PRO_TYPE, PRODUCER_TOPIC, RECOVERY_FILE_PATH, REQUEST_REQUIRED_ACKS, STRING_SERIALIZER_CLASS, TOPIC_PARTITION_NUM, TOPIC_REPLICATION_FACTOR, VALUE_SERIALIZER_CLASS

Fields inherited from interface org.cg.eventbus.IEventBus

AUTO_CREATE, DEFAULT_PRO_ZK_CONNECT, ZK_CONNECT

Constructor Summary

Constructors

Constructor and Description
AbstractEventProducer(org.apache.commons.configuration.Configuration config)
AbstractEventProducer(org.apache.commons.configuration.Configuration config, String prefix)
AbstractEventProducer(String cfgPath)
AbstractEventProducer(String cfgPath, String prefix)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.commons.configuration.Configuration	getConfig()
org.apache.log4j.Logger	getLogger()
protected void	initialize(org.apache.commons.configuration.Configuration config)
void	send(K key, V msg, ICallback callback)
void	send(List<K> keys, List<V> msgs, ICallback callback)
void	send(List<V> msgs, ICallback callback)
void	send(V msg, ICallback callback)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.cg.eventbus.IProducer

getKey

Field Detail

DEFAULT_BROKER_LIST

public static final String DEFAULT_BROKER_LIST

See Also:

Constant Field Values

PRO_TYPE_ASYNC

public static final String PRO_TYPE_ASYNC

See Also:

Constant Field Values

QUIT_ON_ERROR

public static final String QUIT_ON_ERROR

See Also:

Constant Field Values

NO_ACK

public static final String NO_ACK

See Also:

Constant Field Values

LEADER_ACK

public static final String LEADER_ACK

See Also:

Constant Field Values

REPLICAS_ACK

public static final String REPLICAS_ACK

See Also:

Constant Field Values

DEFAULT_PARTITION

public static final String DEFAULT_PARTITION

See Also:

Constant Field Values

Constructor Detail

AbstractEventProducer

public AbstractEventProducer(String cfgPath)
                      throws Exception

Throws:

Exception

AbstractEventProducer

public AbstractEventProducer(String cfgPath,
                     String prefix)
                      throws Exception

Throws:

Exception

AbstractEventProducer

public AbstractEventProducer(org.apache.commons.configuration.Configuration config,
                     String prefix)
                      throws Exception

Throws:

Exception

AbstractEventProducer

public AbstractEventProducer(org.apache.commons.configuration.Configuration config)
                      throws Exception

Throws:

Exception

Method Detail

initialize

protected void initialize(org.apache.commons.configuration.Configuration config)
                   throws Exception

Throws:

Exception

getConfig

public org.apache.commons.configuration.Configuration getConfig()

Returns:

the config

send

public void send(V msg,
        ICallback callback)

Specified by:

send in interface IProducer<K,V>

send

public void send(List<V> msgs,
        ICallback callback)

Specified by:

send in interface IProducer<K,V>

send

public void send(K key,
        V msg,
        ICallback callback)

Specified by:

send in interface IProducer<K,V>

getLogger

public org.apache.log4j.Logger getLogger()

Returns:

the logger

send

public void send(List<K> keys,
        List<V> msgs,
        ICallback callback)

Specified by:

send in interface IProducer<K,V>

close

public void close()

Specified by:

close in interface IProducer<K,V>