< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package base
  Definition Classes
    manager
-  package cluster
  Definition Classes
    base
- BaseClusterActor
- BaseClusterCommandActor
- BaseClusterQueryActor
- BaseClusterQueryCommandActor

c

kafka.manager.base.cluster

# BaseClusterCommandActor 

###

#### abstract class BaseClusterCommandActor extends BaseCommandActor with BaseClusterActor

Linear Supertypes
BaseClusterActor, BaseCommandActor, BaseActor, ActorLogging, Actor, AnyRef, Any
Known Subclasses
KafkaCommandActor
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. BaseClusterCommandActor
2. BaseClusterActor
3. BaseCommandActor
4. BaseActor
5. ActorLogging
6. Actor
7. AnyRef
8. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new BaseClusterCommandActor()

### Type Members

1.  type Receive = PartialFunction[Any, Unit]
   Definition Classes
     Actor

### Abstract Value Members

1.  implicit abstract def clusterContext: ClusterContext
   Attributes
     protected
   Definition Classes
     BaseClusterActor
2.  abstract def processActorResponse(response: ActorResponse): Unit
   Definition Classes
     BaseActor
3.  abstract def processCommandRequest(request: CommandRequest): Unit
   Definition Classes
     BaseCommandActor

### Concrete Value Members

1.  final def !=(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
2.  final def ##(): Int
   Definition Classes
     AnyRef → Any
3.  final def ==(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
4.  def aroundPostRestart(reason: Throwable): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
5.  def aroundPostStop(): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
6.  def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
7.  def aroundPreStart(): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
8.  def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
9.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
10.  def clone(): AnyRef
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
11.  implicit lazy val clusterConfig: ClusterConfig
    Attributes
      protected
    Definition Classes
      BaseClusterActor
12.  implicit lazy val clusterFeatures: ClusterFeatures
    Attributes
      protected
    Definition Classes
      BaseClusterActor
13.  implicit val context: ActorContext
    Definition Classes
      Actor
14.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
15.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
16.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
17.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
18.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
19.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
20.  def log: LoggingAdapter
    Definition Classes
      ActorLogging
21.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
22.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
23.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
24.  def postRestart(reason: Throwable): Unit
    Definition Classes
      Actor
    Annotations
      @throws( classOf[java.lang.Exception] )
25.  def postStop(): Unit
    Definition Classes
      BaseCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
26.  def preRestart(reason: Throwable, message: Option[Any]): Unit
    Definition Classes
      BaseCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
27.  def preStart(): Unit
    Definition Classes
      BaseCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
28.  final def processActorRequest(request: ActorRequest): Unit
    Definition Classes
      BaseCommandActor → BaseActor
29.  final def receive: Receive
    Definition Classes
      BaseActor → Actor
30.  implicit final val self: ActorRef
    Definition Classes
      Actor
31.  final def sender(): ActorRef
    Definition Classes
      Actor
32.  var shutdown: Boolean
    Definition Classes
      BaseActor
33.  def supervisorStrategy: SupervisorStrategy
    Definition Classes
      Actor
34.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
35.  def toString(): String
    Definition Classes
      AnyRef → Any
36.  def unhandled(message: Any): Unit
    Definition Classes
      Actor
37.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
38.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
39.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from BaseClusterActor

### Inherited from BaseCommandActor

### Inherited from BaseActor

### Inherited from ActorLogging

### Inherited from Actor

### Inherited from AnyRef

### Inherited from Any

### Ungrouped