org.cg.eventbus

Interface IProducer<K,V>

All Superinterfaces:

IEventBus

All Known Subinterfaces:

IManager<K,V>

All Known Implementing Classes:

AbstractEventProducer

public interface IProducer<K,V>
extends IEventBus

interface to further simplify the pub sub api

Author:

yanlinwang, liang.li

Field Summary

Fields

Modifier and Type	Field and Description
static String	BROKER_LIST
static String	BYTE_SERIALIZER_CLASS
static String	DEFAULT_KEY
static String	KEY_SERIALIZER_CLASS
static String	PARTITION_CLASS
static String	PRO_TYPE
static String	PRODUCER_TOPIC
static String	RECOVERY_FILE_PATH
static String	REQUEST_REQUIRED_ACKS
static String	STRING_SERIALIZER_CLASS
static String	TOPIC_PARTITION_NUM
static String	TOPIC_REPLICATION_FACTOR
static String	VALUE_SERIALIZER_CLASS

Fields inherited from interface org.cg.eventbus.IEventBus

AUTO_CREATE, DEFAULT_PRO_ZK_CONNECT, ZK_CONNECT

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
K	getKey(V msg)
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)

Field Detail

BROKER_LIST

static final String BROKER_LIST

See Also:

Constant Field Values

PRODUCER_TOPIC

static final String PRODUCER_TOPIC

See Also:

Constant Field Values

PRO_TYPE

static final String PRO_TYPE

See Also:

Constant Field Values

REQUEST_REQUIRED_ACKS

static final String REQUEST_REQUIRED_ACKS

See Also:

Constant Field Values

KEY_SERIALIZER_CLASS

static final String KEY_SERIALIZER_CLASS

See Also:

Constant Field Values

VALUE_SERIALIZER_CLASS

static final String VALUE_SERIALIZER_CLASS

See Also:

Constant Field Values

BYTE_SERIALIZER_CLASS

static final String BYTE_SERIALIZER_CLASS

See Also:

Constant Field Values

STRING_SERIALIZER_CLASS

static final String STRING_SERIALIZER_CLASS

See Also:

Constant Field Values

PARTITION_CLASS

static final String PARTITION_CLASS

See Also:

Constant Field Values

DEFAULT_KEY

static final String DEFAULT_KEY

See Also:

Constant Field Values

TOPIC_PARTITION_NUM

static final String TOPIC_PARTITION_NUM

See Also:

Constant Field Values

TOPIC_REPLICATION_FACTOR

static final String TOPIC_REPLICATION_FACTOR

See Also:

Constant Field Values

RECOVERY_FILE_PATH

static final String RECOVERY_FILE_PATH

See Also:

Constant Field Values

Method Detail

getKey

K getKey(V msg)

send

void send(V msg,
        ICallback callback)

send

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

send

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

send

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

close

void close()