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 KafkaBrokerImpl

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.basic.SoftwareProcessImpl
              brooklyn.entity.messaging.kafka.KafkaBrokerImpl
All Implemented Interfaces:
KafkaBroker, MessageBroker
public class KafkaBrokerImpl
extends SoftwareProcessImpl

An Entity that represents a single Kafka broker instance.

Field Summary
 
Fields inherited from class SoftwareProcessImpl
sensorRegistry
 
Fields inherited from class AbstractEntity
LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, attributesInternal, configsInternal, managementSupport, tempWorkings
 
Constructor Summary
KafkaBrokerImpl()

KafkaBrokerImpl(java.util.Map properties)

KafkaBrokerImpl(Entity parent)

KafkaBrokerImpl(java.util.Map properties, Entity parent)

 
Method Summary
protected void connectSensors()

KafkaTopic createTopic(java.util.Map properties)

void disconnectSensors()

java.lang.Integer getBrokerId()

java.lang.Class getDriverInterface()

java.lang.Integer getKafkaPort()

Zookeeper getZookeeper()

void init()

void setBrokerUrl()

Use the zookeeper details if available, otherwise use our own host and port.
protected ToStringHelper toStringHelper()

void waitForServiceUp(long duration, java.util.concurrent.TimeUnit units)

 
Methods inherited from class SoftwareProcessImpl
callRebindHooks, callStartHooks, checkModifiable, connectSensors, connectServiceUpIsRunning, disconnectSensors, disconnectServiceUpIsRunning, doInitDriver, getDriver, getLocalHostname, getMachineOrNull, getProvisioningFlags, getProvisioningLocation, getRequiredOpenPorts, newDriver, obtainProvisioningFlags, onManagementStarted, onManagementStarting, postDriverRestart, postDriverStart, postRebind, postRestart, postStart, preStart, preStop, rebind, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, startInLocation, stop, stopInLocation, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addOwnedChild, addPolicy, assertNotYetOwned, clearOwner, clearParent, configure, configure, configure, configure, configure, createManagementSupport, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getChildrenReference, getConfig, getConfig, getConfig, getConfig, getConfigMap, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getOwnedChildren, getOwnedChildrenReference, getOwner, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hasEverBeenManaged, hashCode, init, invalidateReferences, invoke, invoke, invokeFromJava, invokeMethod, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, refreshInheritedConfig, refreshInheritedConfigOfChildren, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removeOwnedChild, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setBeingManaged, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setOwner, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toString, toStringFieldsToInclude, toStringHelper, unsubscribe, unsubscribe
 
Methods inherited from class groovy.lang.GroovyObjectSupport
groovy.lang.GroovyObjectSupport#setProperty(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#getProperty(java.lang.String), groovy.lang.GroovyObjectSupport#getMetaClass(), groovy.lang.GroovyObjectSupport#setMetaClass(groovy.lang.MetaClass), groovy.lang.GroovyObjectSupport#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#wait(), groovy.lang.GroovyObjectSupport#wait(long), groovy.lang.GroovyObjectSupport#wait(long, int), groovy.lang.GroovyObjectSupport#equals(java.lang.Object), groovy.lang.GroovyObjectSupport#toString(), groovy.lang.GroovyObjectSupport#hashCode(), groovy.lang.GroovyObjectSupport#getClass(), groovy.lang.GroovyObjectSupport#notify(), groovy.lang.GroovyObjectSupport#notifyAll()
 

Constructor Detail

KafkaBrokerImpl

public KafkaBrokerImpl()

KafkaBrokerImpl

public KafkaBrokerImpl(java.util.Map properties)

KafkaBrokerImpl

public KafkaBrokerImpl(Entity parent)

KafkaBrokerImpl

public KafkaBrokerImpl(java.util.Map properties, Entity parent)

 
Method Detail

connectSensors

@Override
protected void connectSensors()

createTopic

public KafkaTopic createTopic(java.util.Map properties)

disconnectSensors

@Override
public void disconnectSensors()

getBrokerId

@Override
public java.lang.Integer getBrokerId()

getDriverInterface

@Override
public java.lang.Class getDriverInterface()

getKafkaPort

@Override
public java.lang.Integer getKafkaPort()

getZookeeper

@Override
public Zookeeper getZookeeper()

init

@Override
public void init()

setBrokerUrl

@Override
public void setBrokerUrl()
Use the zookeeper details if available, otherwise use our own host and port.

toStringHelper

@Override
protected ToStringHelper toStringHelper()

waitForServiceUp

@Override
public void waitForServiceUp(long duration, java.util.concurrent.TimeUnit units)

 

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