Add a create method with context and namePrefix to ActorMaterializer's Java API.
This commit is contained in:
parent
ebe272212d
commit
48fe57a3f7
1 changed files with 18 additions and 0 deletions
|
|
@ -126,6 +126,24 @@ object ActorMaterializer {
|
||||||
def create(context: ActorRefFactory): ActorMaterializer =
|
def create(context: ActorRefFactory): ActorMaterializer =
|
||||||
apply()(context)
|
apply()(context)
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.
|
||||||
|
*
|
||||||
|
* The required [[akka.actor.ActorRefFactory]]
|
||||||
|
* (which can be either an [[akka.actor.ActorSystem]] or an [[akka.actor.ActorContext]])
|
||||||
|
* will be used to create these actors, therefore it is *forbidden* to pass this object
|
||||||
|
* to another actor if the factory is an ActorContext.
|
||||||
|
*
|
||||||
|
* The `namePrefix` is used as the first part of the names of the actors running
|
||||||
|
* the processing steps. The default `namePrefix` is `"flow"`. The actor names are built up of
|
||||||
|
* `namePrefix-flowNumber-flowStepNumber-stepName`.
|
||||||
|
*/
|
||||||
|
def create(context: ActorRefFactory, namePrefix: String): ActorMaterializer = {
|
||||||
|
val system = actorSystemOf(context)
|
||||||
|
val settings = ActorMaterializerSettings(system)
|
||||||
|
apply(settings, namePrefix)(context)
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.
|
* Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.
|
||||||
*
|
*
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue