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

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

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

Logging.getLogger介绍

暂无

代码示例

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

public ServiceRoutes(ActorSystem system, ActorRef serviceRegistryActor) {
  this.system = system;
  this.serviceRegistryActor = serviceRegistryActor;
  log = Logging.getLogger(system, this);
}

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

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

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

/**
 * Constructor.
 *
 * @param capacity the capacity of the queue
 * @param actorSystem the actor system
 */
public ThingUpdaterMessageQueue(final int capacity, final ActorSystem actorSystem) {
  log = Logging.getLogger(actorSystem, ThingUpdaterMessageQueue.class);
  this.capacity = capacity;
}

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

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

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

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

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

/**
 * Constructor.
 *
 * @param capacity the capacity of the queue
 * @param actorSystem the actor system
 */
public ThingUpdaterMessageQueue(final int capacity, final ActorSystem actorSystem) {
  log = Logging.getLogger(actorSystem, ThingUpdaterMessageQueue.class);
  this.capacity = capacity;
}

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

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

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

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

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

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

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

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

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

/**
 * Actor system singleton for this application.
 */
@Bean
public ActorSystem actorSystem() {
 // load the Akka configuration
 String seedNodes = "[";
 for (String seed : clusterConfig.getSeedNodes()) {
  seedNodes += "\"akka.tcp://" + clusterConfig.getName() + "@" + seed.trim() + "\",";
 }
 seedNodes += "]";
 final Config applicationConf = ConfigFactory.load();
 final Config config = ConfigFactory.parseString("akka.cluster.seed-nodes=" + seedNodes).
  withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.bind-port=" + clusterConfig.getLocalPort())).
  withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.hostname=" + clusterConfig.getNodeHost())).
  withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.port=" + clusterConfig.getLocalPort())).
                    withFallback(ConfigFactory.parseString("akka.cluster.roles=[core]")).
  withFallback(ConfigFactory.load(applicationConf));
 ActorSystem system = ActorSystem.create(clusterConfig.getName(), config);
 LoggingAdapter log = Logging.getLogger(system, this);
 log.info("Using Akka system settings: " + system.settings().toString());
 // initialize the application context in the Akka Spring Extension
 SpringExtension.SpringExtProvider.get(system).initialize(applicationContext);
 return system;
}

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

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

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

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

相关文章