org.cg.eventbus.consumer

Interface IConsumer<K,V>

All Superinterfaces:

IEventBus

All Known Implementing Classes:

SymmetricDispatcher

public interface IConsumer<K,V>
extends IEventBus

Author:

yanlinwang

Field Summary

Fields

Modifier and Type	Field and Description
static String	COMMIT_INTERVAL
static String	CONSUMER_LISTENERS
static String	CONSUMER_STREAMS
static String	CONSUMER_THREAD_POOL_SIZE
static String	CONSUMER_TOPICS
static String	DEFAULT_COMMIT_INTERVAL
static String	DEFAULT_CONNECTION_TIMEOUT
static String	DEFAULT_GROUP_ID
static String	DEFAULT_SINGLE_TOPIC
static String	DEFAULT_STREAM_THREADS
static String	DEFAULT_SUB_ZK_CONNECT
static String	DEFAULT_THREAD_POOL_SIZE
static int	DEFAULT_ZKCLIENT_CONNECTION_TIMEOUT
static String	DEFAULT_ZKCLIENT_SERVER
static int	DEFAULT_ZKCLIENT_SESSION_TIMEOUT
static String	GROUP_ID
static String	KEY_DECODER
static int	NO_SUCH_BROKER
static int	NO_SUCH_TOPIC
static String	SINGLE_TOPIC
static String	VALUE_DECODER
static String	ZKCONNECTION_TIMEOUT

Fields inherited from interface org.cg.eventbus.IEventBus

AUTO_CREATE, DEFAULT_PRO_ZK_CONNECT, ZK_CONNECT

Field Detail

DEFAULT_SUB_ZK_CONNECT

static final String DEFAULT_SUB_ZK_CONNECT

See Also:

Constant Field Values

GROUP_ID

static final String GROUP_ID

See Also:

Constant Field Values

DEFAULT_GROUP_ID

static final String DEFAULT_GROUP_ID

See Also:

Constant Field Values

COMMIT_INTERVAL

static final String COMMIT_INTERVAL

See Also:

Constant Field Values

DEFAULT_COMMIT_INTERVAL

static final String DEFAULT_COMMIT_INTERVAL

See Also:

Constant Field Values

KEY_DECODER

static final String KEY_DECODER

See Also:

Constant Field Values

VALUE_DECODER

static final String VALUE_DECODER

See Also:

Constant Field Values

CONSUMER_TOPICS

static final String CONSUMER_TOPICS

See Also:

Constant Field Values

CONSUMER_STREAMS

static final String CONSUMER_STREAMS

See Also:

Constant Field Values

CONSUMER_LISTENERS

static final String CONSUMER_LISTENERS

See Also:

Constant Field Values

DEFAULT_STREAM_THREADS

static final String DEFAULT_STREAM_THREADS

See Also:

Constant Field Values

CONSUMER_THREAD_POOL_SIZE

static final String CONSUMER_THREAD_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_THREAD_POOL_SIZE

static final String DEFAULT_THREAD_POOL_SIZE

See Also:

Constant Field Values

SINGLE_TOPIC

static final String SINGLE_TOPIC

See Also:

Constant Field Values

DEFAULT_SINGLE_TOPIC

static final String DEFAULT_SINGLE_TOPIC

See Also:

Constant Field Values

NO_SUCH_TOPIC

static final int NO_SUCH_TOPIC

See Also:

Constant Field Values

NO_SUCH_BROKER

static final int NO_SUCH_BROKER

See Also:

Constant Field Values

ZKCONNECTION_TIMEOUT

static final String ZKCONNECTION_TIMEOUT

See Also:

Constant Field Values

DEFAULT_CONNECTION_TIMEOUT

static final String DEFAULT_CONNECTION_TIMEOUT

See Also:

Constant Field Values

DEFAULT_ZKCLIENT_SERVER

static final String DEFAULT_ZKCLIENT_SERVER

See Also:

Constant Field Values

DEFAULT_ZKCLIENT_SESSION_TIMEOUT

static final int DEFAULT_ZKCLIENT_SESSION_TIMEOUT

See Also:

Constant Field Values

DEFAULT_ZKCLIENT_CONNECTION_TIMEOUT

static final int DEFAULT_ZKCLIENT_CONNECTION_TIMEOUT

See Also:

Constant Field Values