Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

brooklyn.entity.messaging.kafka
[Java] Class KafkaClusterImpl

java.lang.Object
  brooklyn.entity.basic.AbstractEntity
      brooklyn.entity.messaging.kafka.KafkaClusterImpl
All Implemented Interfaces:
KafkaCluster
public class KafkaClusterImpl
extends AbstractEntity

Implementation of a Kafka cluster containing a KafkaZookeeper node and a group of KafkaBrokers.

Field Summary
static Logger log

 
Fields inherited from class AbstractEntity
EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, managementSupport, tempWorkings
 
Constructor Summary
KafkaClusterImpl()

 
Method Summary
boolean addMember(Entity member)

{@inheritDoc}
DynamicCluster getCluster()

java.lang.Integer getCurrentSize()

{@inheritDoc}
java.util.Collection getMembers()

{@inheritDoc}
Zookeeper getZookeeper()

boolean hasMember(Entity member)

{@inheritDoc}
void init()

boolean removeMember(Entity member)

{@inheritDoc}
java.lang.Integer resize(java.lang.Integer desiredSize)

void restart()

void start(java.util.Collection locations)

void stop()

 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addPolicy, clearLocations, clearParent, configure, configure, configure, configure, configure, configure, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getIconUrl, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hashCode, init, invalidateReferences, invoke, invoke, invoke, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, toStringHelper, unsubscribe, unsubscribe
 

Field Detail

log

public static final Logger log

 
Constructor Detail

KafkaClusterImpl

public KafkaClusterImpl()

 
Method Detail

addMember

public boolean addMember(Entity member)
{@inheritDoc}

getCluster

return getAttribute(CLUSTER);
public DynamicCluster getCluster()

getCurrentSize

}
public java.lang.Integer getCurrentSize()
{@inheritDoc}

getMembers

public java.util.Collection getMembers()
{@inheritDoc}

getZookeeper

return getAttribute(ZOOKEEPER);
public Zookeeper getZookeeper()

hasMember

public boolean hasMember(Entity member)
{@inheritDoc}

init

@Override
public void init()

removeMember

public boolean removeMember(Entity member)
{@inheritDoc}

resize

public java.lang.Integer resize(java.lang.Integer desiredSize)

restart

stop();
public void restart()

start

if (isLegacyConstruction()) {
public void start(java.util.Collection locations)

stop

getZookeeper().stop();
public void stop()

 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.