Package akka.actor

Examples of akka.actor.UntypedActorFactory

86
87
88
89
90
91
92
93
94
95
96
  @Override
  protected void activate(ActivationMessage message) {

    ActorRef serviceTaskInstance = this.getContext().actorOf(new Props(
        new UntypedActorFactory() {
          private static final long serialVersionUID = 1L;

          // create an instance of a (synchronous) service worker
          public UntypedActor create() {
              return new ServiceTaskInstance(getUniqueProcessId(), getUniqueFlowNodeId(),
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
   * @param context the context
   * @param eventDefinitionParameter the event definition parameter
   * @return the ActorRef of the EventDefinition
   */
  public static ActorRef createEventDefinitionActor(String uniqueFlowNodeId, UntypedActorContext context, final EventDefinitionParameter eventDefinitionParameter) {
    ActorRef eventDefinitionActor = context.actorOf(new Props(new UntypedActorFactory() {
      private static final long serialVersionUID = 1L;

      public UntypedActor create() {
          return new EventDefinitionFactory().getEventDefinition(eventDefinitionParameter);
        }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
  }
 
  @SuppressWarnings({ "unchecked" })
  public List<Object> run(final List<Object> data, List<Object> parameters, Function<?, ?> functionToApply, final int numberOfWorkers, int numberOfSecondsTimeout) {
    final ImmutableList iData = ImmutableList.builder().addAll(data).build();
    ActorRef actorLevel1 = system.actorOf(new Props(new UntypedActorFactory() {
      private static final long serialVersionUID = 1L;
      public UntypedActor create() {
        return new ActorLevel1(iData, numberOfWorkers);
      }
    }), "ActorLevel1-" + System.currentTimeMillis());
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
    shutdownCommandListener = system.actorOf(new Props(ActorLevel0_SystemShutdowner.class), "shutdownCommandListener");
  }
 
  @SuppressWarnings({ "unchecked" })
  public List<Object> run(final List<Object> data, List<Object> parameters, Function<?, ?> functionToApply, final int numberOfWorkers, int numberOfSecondsTimeout) {
    ActorRef actorLevel1 = system.actorOf(new Props(new UntypedActorFactory() {
      private static final long serialVersionUID = 1L;
      public UntypedActor create() {
        return new ActorLevel1(data, numberOfWorkers);
      }
    }), "ActorLevel1-" + System.currentTimeMillis());
View Full Code Here
TOP

Related Classes of akka.actor.UntypedActorFactory

  • akka.Pi
  • akka.transactor.test.UntypedCoordinatedIncrementTest
  • akka.transactor.test.UntypedTransactorTest
  • akka.tutorial.first.java.Pi
  • akka.weather.WeatherApp
  • akkazeromq.PublisherMain
  • akkazeromq.SubscriberMain
  • com.catify.processengine.core.nodes.eventdefinition.EventDefinitionHandling
  • com.catify.processengine.core.nodes.ServiceTaskNode
  • com.daveayan.fuzzyavenger.providers.akka.AkkaExecutionProvider
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.