Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
    Dennis Vriend
    @dnvriend
    Hi releases
    I just released v1.3.0 with support for async query api
    Vladimir Pavkin
    @vpavkin
    @dnvriend hi!
    Do you plan to wireup event adapters to read journal?
    For example, akka-persistence-cassandra runs events through event adapter for persistent queries.
    If you don’t mind adding this, I can submit a PR
    Dennis Vriend
    @dnvriend
    @vpavkin I haven't thought about it, albeit for the inmemory journal it would be a nice thing to have. I've looked in to it how the Cassandra and LevelDB journal does it for the query side, but it seems a little bit too hacky. I'd rather have seen that the query specs supported the event adapters, but it does not. If you would like to submit a PR for event adapters for the inmemory journal I woulnd't mind and it would create a better community plugin.
    Vladimir Pavkin
    @vpavkin
    Thanks. Reasonable point about the spec. My own motivation is only that I use Cassandra and in memory plugin in one project, and would like to see similar behaviour.
    Actually, I got away with a simple wrapper by now. And waiting for an official spec is better then rush, I guess.
    Dennis Vriend
    @dnvriend
    I understand.. thanks
    Harmeet Singh(Taara)
    @harmeetsingh0013
    hey team,
    i am trying to use akka-persistence-inmemory for testing purpose
    but i am not figure out, how we can use this for testing
    ?
    Harmeet Singh(Taara)
    @harmeetsingh0013
    you have any example for this ?
    idanna
    @idanna

    Hey people,
    I want to test the scenario where my journal fails (i.e connection problems), any chance there’s a way to mimick this behaviour ?
    I was digging the API, didn’t see an call to “close” the journal or something like this.

    Will be glad to add support for this behaviour if needed.

    lteqgt
    @sebastianharko
    What's the lifetime of the in-memory journal ? Is it one per JVM or one per actor system ?
    Dennis Vriend
    @dnvriend
    @sebastianharko The lifetime of the in-memory journal is one per actor-system, so if you launch multiple actor systems than you have multiple in-memory-journals running
    Ernesto Periñán
    @eperinan

    Hey chaps,

    I am triyin to use this plugin for testing purpose but I am getting an error and I don´t know what is happening

    If I don´t enable the plugin in the application.conf in the test directory, my tests work fine
    Seems something related with .... [akka://MySpec/system/inmemory-snapshot-store] pre-creation serialization check failed at [akka://MySpec/user/JournalStorage]
    akka.actor.ActorInitializationException: akka://MySpec/system/inmemory-snapshot-store: exception during creation
    Could someone explain what is happening ?
    Heiko Seeberger
    @hseeberger
    Hi there! Is akka-persistence-inmemory "cluster-aware"?
    Dennis Vriend
    @dnvriend
    Hi Heiko, it depends what you mean with 'cluster-aware' :)
    The plugin is basically just an actor, that manages a Map instance, and is launched by akka-persistence, and handles its messages.
    The plugin was created with one simple use case; I wanted to learn akka-cluster, and wanted to learn it by means of unit testing, and the plugins at the moment (some time ago) didn't have snapshot in-memory support, and as you know, akka-cluster uses snapshotting, and cleaning up the directory with snapshots what the solution at the time.
    Alas, there is no implementation to synchronise multiple instances of the map using a consensus protocol like eg. raft. I'm open for a PR for such a feature !!
    Heiko Seeberger
    @hseeberger
    Thanks for the quick answer!
    An alternative approach could be a simple cluster singleton. Or maybe sharding. WDYT?
    Dennis Vriend
    @dnvriend
    Interesting idea, why would we need a 'cluster' feature? Just thinking out loud, akka-persistence-inmemory was created for testing projects that use akka-persistence and features of akka that uses akka-persistence as a backing store like akka-cluster.
    What would a 'cluster'-aware version of akka-persistence-inmemory mean?
    In the 'non-cluster' version, there is only a single Map, that is made available by a single actorsystem, and accessed by a single actor system.
    Dennis Vriend
    @dnvriend
    In a 'cluster' version, there could be multiple actor systems accessing the same Map eg. as a cluster singleton, of course, in a testing setting starting/stopping the clustert can slow testing down considerably, something to take note on.
    wdyt?
    Heiko Seeberger
    @hseeberger
    I envision the cluster version mainly for demos.
    Vlad Filip
    @codingvlad
    Hello everybody. I used this plugin and now I get persistence rejection messages. Is this plugin using a different serializer then java? I only need it for testing and so I do not care if it is java. Or is it the journal write that is rejecting? Thank you
    Heiko Seeberger
    @hseeberger
    Java serialization should work.
    Beat Sager
    @BeatSager
    @dnvriend what do you think about dnvriend/akka-persistence-inmemory#39 ? Would you like to have more input?
    Artsiom Miklushou
    @mikla
    Hi there, for some reason version 2.5.1.2 is not in Bintray's repo.
    Artsiom Miklushou
    @mikla
    Added this to resolvers: "dnvriend" at "https://dl.bintray.com/dnvriend/maven"
    Artsiom Miklushou
    @mikla
    @dnvriend please, have a look dnvriend/akka-persistence-jounal-writer#2
    Beat Sager
    @BeatSager
    @dnvriend As discussed the new pull request for a pluggable persistence extension dnvriend/akka-persistence-inmemory#59
    Artsiom Miklushou
    @mikla
    Hi there,
    what about this project? akka-persistence-journal-writer
    Is it abandoned? I’ve made small PR regarding dependencies updates...