akka.event.Logging.getLogger()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(5.0k)|赞(0)|评价(0)|浏览(147)

本文整理了Java中akka.event.Logging.getLogger()方法的一些代码示例,展示了Logging.getLogger()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logging.getLogger()方法的具体详情如下:
包路径:akka.event.Logging
类名称:Logging
方法名:getLogger

Logging.getLogger介绍

暂无

代码示例

代码示例来源:origin: zhihuili/flower

  1. public ServiceRoutes(ActorSystem system, ActorRef serviceRegistryActor) {
  2. this.system = system;
  3. this.serviceRegistryActor = serviceRegistryActor;
  4. log = Logging.getLogger(system, this);
  5. }

代码示例来源:origin: org.eclipse.ditto/ditto-services-things-persistence

  1. public ThingPersistenceActorMessageQueue(final int capacity, final ActorSystem actorSystem) {
  2. log = Logging.getLogger(actorSystem, ThingPersistenceActorMessageQueue.class);
  3. this.capacity = capacity;
  4. }

代码示例来源:origin: org.eclipse.ditto/ditto-services-thingsearch-updater-actors

  1. /**
  2. * Constructor.
  3. *
  4. * @param capacity the capacity of the queue
  5. * @param actorSystem the actor system
  6. */
  7. public ThingUpdaterMessageQueue(final int capacity, final ActorSystem actorSystem) {
  8. log = Logging.getLogger(actorSystem, ThingUpdaterMessageQueue.class);
  9. this.capacity = capacity;
  10. }

代码示例来源:origin: org.eclipse.ditto/ditto-services-policies-persistence

  1. PolicyPersistenceActorMessageQueue(final int capacity, final ActorSystem actorSystem) {
  2. log = Logging.getLogger(actorSystem, PolicyPersistenceActorMessageQueue.class);
  3. this.capacity = capacity;
  4. }

代码示例来源:origin: eclipse/ditto

  1. public ThingPersistenceActorMessageQueue(final int capacity, final ActorSystem actorSystem) {
  2. log = Logging.getLogger(actorSystem, ThingPersistenceActorMessageQueue.class);
  3. this.capacity = capacity;
  4. }

代码示例来源:origin: eclipse/ditto

  1. /**
  2. * Constructor.
  3. *
  4. * @param capacity the capacity of the queue
  5. * @param actorSystem the actor system
  6. */
  7. public ThingUpdaterMessageQueue(final int capacity, final ActorSystem actorSystem) {
  8. log = Logging.getLogger(actorSystem, ThingUpdaterMessageQueue.class);
  9. this.capacity = capacity;
  10. }

代码示例来源:origin: eclipse/ditto

  1. PolicyPersistenceActorMessageQueue(final int capacity, final ActorSystem actorSystem) {
  2. log = Logging.getLogger(actorSystem, PolicyPersistenceActorMessageQueue.class);
  3. this.capacity = capacity;
  4. }

代码示例来源:origin: com.github.davidmoten/xuml-model-compiler-runtime

  1. public EntityActor() {
  2. log = Logging.getLogger(getContext().system(), this);
  3. }

代码示例来源:origin: com.github.davidmoten/xuml-model-compiler-runtime

  1. public RootActor() {
  2. log = Logging.getLogger(getContext().system(), this);
  3. }

代码示例来源:origin: krudolph/akkaflow

  1. final LoggingAdapter log = Logging.getLogger(system, "Application");

代码示例来源:origin: at.researchstudio.sat/won-matcher-service

  1. /**
  2. * Actor system singleton for this application.
  3. */
  4. @Bean
  5. public ActorSystem actorSystem() {
  6. // load the Akka configuration
  7. String seedNodes = "[";
  8. for (String seed : clusterConfig.getSeedNodes()) {
  9. seedNodes += "\"akka.tcp://" + clusterConfig.getName() + "@" + seed.trim() + "\",";
  10. }
  11. seedNodes += "]";
  12. final Config applicationConf = ConfigFactory.load();
  13. final Config config = ConfigFactory.parseString("akka.cluster.seed-nodes=" + seedNodes).
  14. withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.bind-port=" + clusterConfig.getLocalPort())).
  15. withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.hostname=" + clusterConfig.getNodeHost())).
  16. withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.port=" + clusterConfig.getLocalPort())).
  17. withFallback(ConfigFactory.parseString("akka.cluster.roles=[core]")).
  18. withFallback(ConfigFactory.load(applicationConf));
  19. ActorSystem system = ActorSystem.create(clusterConfig.getName(), config);
  20. LoggingAdapter log = Logging.getLogger(system, this);
  21. log.info("Using Akka system settings: " + system.settings().toString());
  22. // initialize the application context in the Akka Spring Extension
  23. SpringExtension.SpringExtProvider.get(system).initialize(applicationContext);
  24. return system;
  25. }

代码示例来源:origin: org.eclipse.ditto/ditto-services-thingsearch-persistence

  1. /**
  2. * Initializes the things search persistence with a passed in {@code persistence}.
  3. *
  4. * @param clientWrapper the mongoDB persistence wrapper.
  5. * @param actorSystem the Akka ActorSystem.
  6. */
  7. public MongoThingsSearchPersistence(final MongoClientWrapper clientWrapper, final ActorSystem actorSystem) {
  8. collection = clientWrapper.getDatabase().getCollection(PersistenceConstants.THINGS_COLLECTION_NAME);
  9. log = Logging.getLogger(actorSystem, getClass());
  10. materializer = ActorMaterializer.create(actorSystem);
  11. indexInitializer = IndexInitializer.of(clientWrapper.getDatabase(), materializer);
  12. maxQueryTime = MongoConfig.getMaxQueryTime(actorSystem.settings().config());
  13. }

代码示例来源:origin: eclipse/ditto

  1. /**
  2. * Initializes the things search persistence with a passed in {@code persistence}.
  3. *
  4. * @param clientWrapper the mongoDB persistence wrapper.
  5. * @param actorSystem the Akka ActorSystem.
  6. */
  7. public MongoThingsSearchPersistence(final MongoClientWrapper clientWrapper, final ActorSystem actorSystem) {
  8. collection = clientWrapper.getDatabase().getCollection(PersistenceConstants.THINGS_COLLECTION_NAME);
  9. log = Logging.getLogger(actorSystem, getClass());
  10. materializer = ActorMaterializer.create(actorSystem);
  11. indexInitializer = IndexInitializer.of(clientWrapper.getDatabase(), materializer);
  12. maxQueryTime = MongoConfig.getMaxQueryTime(actorSystem.settings().config());
  13. }

相关文章