org.cg.eventbus

Class EventBusManager

java.lang.Object

org.cg.eventbus.EventBusManager

public class EventBusManager
extends Object

Author:

yanlinwang

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	EventBusManager.Connection

Constructor Summary

Constructors

Constructor and Description
EventBusManager(String zkServer)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	createTopic(String topic, int replicationFactor, int numPartitions)
boolean	deleteTopic(String topic)
Map<String,Integer>	getAllPartitions()
List<String>	getAllTopics()
Map<Integer,EventBusManager.Connection>	getEventBusInfo()
int	getEventBusSize()
int	getPartitionByTopic(String topic)
boolean	hasTopic(String topic)
boolean	increasePartitionByTopic(String topic, int numPartitions)
boolean	isBrokerUp(int id)
boolean	isEventBusUp()
static boolean	pingServer(String zkServer)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusManager

public EventBusManager(String zkServer)

Method Detail

isEventBusUp

public boolean isEventBusUp()

getEventBusSize

public int getEventBusSize()

getEventBusInfo

public Map<Integer,EventBusManager.Connection> getEventBusInfo()

isBrokerUp

public boolean isBrokerUp(int id)

getAllTopics

public List<String> getAllTopics()
                          throws Exception

Throws:

Exception

hasTopic

public boolean hasTopic(String topic)
                 throws Exception

Throws:

Exception

getPartitionByTopic

public int getPartitionByTopic(String topic)

createTopic

public boolean createTopic(String topic,
                  int replicationFactor,
                  int numPartitions)
                    throws Exception

Throws:

Exception

increasePartitionByTopic

public boolean increasePartitionByTopic(String topic,
                               int numPartitions)

getAllPartitions

public Map<String,Integer> getAllPartitions()

deleteTopic

public boolean deleteTopic(String topic)
                    throws Exception

Throws:

Exception

pingServer

public static boolean pingServer(String zkServer)

shutdown

public void shutdown()