本文整理了Java中akka.event.Logging.getLogger()
方法的一些代码示例,展示了Logging.getLogger()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logging.getLogger()
方法的具体详情如下:
包路径:akka.event.Logging
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!