Что происходит внутри при чтении файла akka.conf?

Я использую OpenDaylight и пытаюсь заменить распределенную базу данных по умолчанию на Apache Ignite. Я использую банку, полученную с помощью исходного кода здесь: https://github.com/Romeh/akka-persistance-ignite и развернул его в karaf-контейнере OpenDaylight.

Ниже приведен фрагмент файла akka.conf, который я использую в OpenDaylight для замены журнала LevelDB на Apache Ignite.

odl-cluster-data {
  akka {
  loglevel = DEBUG

  actor {
    provider = "akka.cluster.ClusterActorRefProvider"

    default-dispatcher {
      # Configuration for the fork join pool
       fork-join-executor {
        # Min number of threads to cap factor-based parallelism number to
        parallelism-min = 2
        # Parallelism (threads) ... ceil(available processors * factor)
        parallelism-factor = 2.0
        # Max number of threads to cap factor-based parallelism number to
        parallelism-max = 10
      }
      # Throughput defines the maximum number of messages to be
      # processed per actor before the thread jumps to the next actor.
       # Set to 1 for as fair as possible.
       throughput = 10
    }
  }

  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "10.145.59.44"
      port = 2551
   }
  }

  cluster {
     seed-nodes = [
      "akka.tcp://[email protected]:2551"
    ]
     min-nr-of-members = 1
    auto-down-unreachable-after = 30s
   }



# Disable legacy metrics in akka-cluster.
 akka.cluster.metrics.enabled=off

akka.persistence.journal.plugin = "akka.persistence.journal.ignite"
akka.persistence.snapshot-store.plugin = "akka.persistence.snapshot.ignite"


   extensions = ["akka.persistence.ignite.extension.IgniteExtensionProvider"]



   persistence {
     # Ignite journal plugin
     journal {
       ignite {
         # Class name of the plugin
         class = "akka.persistence.ignite.journal.IgniteWriteJournal"
     plugin-dispatcher = "ignite-dispatcher"
         cache-prefix = "akka-journal"
         // Should be based into the the dara grid topology
        cache-backups = 1
         // if ignite is already started in a separate standalone grid where journal cache is already created
         cachesAlreadyCreated = false
      }
    }

    # Ignite snapshot plugin
    snapshot {
      ignite {
        # Class name of the plugin
        class = "akka.persistence.ignite.snapshot.IgniteSnapshotStore"
    plugin-dispatcher = "ignite-dispatcher"
        cache-prefix = "akka-snapshot"
        // Should be based into the the dara grid topology
        cache-backups = 1
        // if ignite is already started in a separate standalone grid where snapshot cache is already created
        cachesAlreadyCreated = false
      }
    }
  }

   }


}

Однако класс IgniteWriteJournal, похоже, не загружается, что я проверил, поместив некоторые операторы печати в его конструктор следующим образом.

 public IgniteWriteJournal(Config config) throws NotSerializableException {
        System.out.println("!@#$% inside IgniteWriteJournal constructor\n");
        ActorSystem actorSystem = context().system();
         serializer = SerializationExtension.get(actorSystem).serializerFor(PersistentRepr.class);
         storage = new Store<>(actorSystem);

        JournalCaches journalCaches = journalCacheProvider.apply(config, actorSystem);
        sequenceNumberTrack = journalCaches.getSequenceCache();
        cache = journalCaches.getJournalCache();
}

Так что же именно происходит с классом, упомянутым в теге akka.persistence.journal.ignite? Вызывается ли конструктор этого класса? Что именно происходит в фоновом режиме при чтении файла akka.conf?


ignite actor akka akka-persistence opendaylight
person AksTester    schedule 27.06.2018    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Где ищите распечатки - в data/log/karaf.log? System.out.println туда не идет - используйте org.slf4j.Logger.

Как вы перестроили исходный код IgniteWriteJournal и развернули новый артефакт? Вы уверены, что ваши изменения действительно были развернуты?

person Tom Pantelis    schedule 27.06.2018
comment
Операторы печати должны были отображаться в консоли Apache Karaf. Помимо этих строк печати, в исходном коде есть несколько строк журнала, таких как - \\\\\\\\\\\ log.debug(doAsyncReplayMessages с параметрами persistenceId: '{}' :fromSequenceNr {} :toSequenceNr {} :max{ },persistenceId, fromSequenceNr, toSequenceNr, max); ////////// Эти строки журнала отсутствуют в karaf.log. Я пересобрал новый артефакт, используя сборку Maven, и развернул его в karaf. Я уверен, что эти изменения работают, потому что операторы печати в классе расширения печатаются в консоли Karaf. - person AksTester; 28.06.2018