Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 19:34
    IgorFedchenko synchronize #3973
  • 17:53
    Aaronontheweb closed #3972
  • 17:53
    Aaronontheweb commented #3972
  • 17:53
    Aaronontheweb closed #3976
  • 17:53
    Aaronontheweb commented #3976
  • 17:40

    Aaronontheweb on dev

    cleaned up some samples to use … (compare)

  • 17:40
    Aaronontheweb closed #3975
  • 16:33
    IgorFedchenko synchronize #3973
  • 16:31
    IgorFedchenko synchronize #3973
  • 14:04
    wsvdyk opened #3976
  • Oct 14 21:02
    Aaronontheweb synchronize #3975
  • Oct 14 21:02
    Aaronontheweb opened #3975
  • Oct 14 20:11
    IgorFedchenko commented #3973
  • Oct 14 20:10
    IgorFedchenko synchronize #3973
  • Oct 14 20:06
    IgorFedchenko synchronize #3973
  • Oct 14 20:06
    IgorFedchenko synchronize #3973
  • Oct 14 19:42
    IgorFedchenko edited #3973
  • Oct 14 18:08
    Aaronontheweb commented #3937
  • Oct 14 17:27
    Aaronontheweb commented #90
  • Oct 14 17:26
    Aaronontheweb commented #90
Roman Golenok
@shersh
don't pay attention to syntax mistakes) I just tried to clean up code from other experiments
Shamsul Amry
@ShamsulAmry

I'm trying to have a RunnableGraph.FromGraph(GraphDsl.Create(...)) which will return a materialized value of an IActorRef. In that graph dsl I have a Source.ActorRef, and I want to materialize that IActorRef.

I managed to do that if I'm not using the GraphDsl. Tried various stuff, but still can't manage to wrap my head on how to do this the GraphDsl way.

Some hint please?

Bartosz Sypytkowski
@Horusiath
@joshgarnett regarding MDC - each actor has a method called bool AroundReceive(Receive handler, object message) that is invoked for each message. You can use it as a sort of aspect programming in your actors.
Shamsul Amry
@ShamsulAmry
Finally figured out that the shape that you want to use its materialized value from must be passed as a parameter to GraphDsl.Create. Answer from https://stackoverflow.com/a/35700445/321360
Bartosz Sypytkowski
@Horusiath
@shersh my guess would be that you're materializing your graph with runnable.Run(materializer) and then you're disposing materializer immediatelly after
Bartosz Sypytkowski
@Horusiath

Guys, any examples of using Framing.LengthField(x) method in Tcp.Streaming?

@shersh this essentially tells: get first X bytes of the stream, convert them to the int - this is the length of the next frame. Make sure that the next ByteString passed will be of provided length before pushing it to the next stage. Then repeat the process for the next frame

it should be pretty useful for message serialization/deserialization, as you can prefix message with its frame length, and simply get it chunked in the correct pieces on the other side.
Roman Golenok
@shersh
@Horusiath thx for explanation.
Joshua Garnett
@joshgarnett
@Horusiath I believe that method is sealed
Scatch that, not sealed, but marked internal
Ismael Hamed
@ismaelhamed
Seems like Akka.TestKit.Xunit2 wasn't bumped up to v1.3.2, or publishing is taking too long
Stephen Newman
@goodisontoffee
@Horusiath a while back I remember you in a conversation regarding serialisers. Hyperion is fine until v1.0 but there was a better serialiser to use in real life that allows us to be more confident that different versions of messages can be deserialised - chiefly so the cluster can be upgraded in chunks rather than all at once. Trouble is I can’t remember the name of the serialiser that was being recommended. Help?
It doesn’t look like the documentation includes the internal modifier
I’m all for removing the modifier or adding some preMessage/postMessage methods
Jessie Wadman
@JessieWadman
@Aaronontheweb Hilarious read, that taxonomy :D
anthonyhawes
@anthonyhawes
Hi, I've upgraded to v1.3.x and found that persistence query EventEnvelope now has an opaque Offset property. When I update my read store projections, how can I keep track of the latest offset (previously it was stored in the database as int64)?
anthonyhawes
@anthonyhawes
Nevermind. I can cast it to a Sequence and use the Value property
Aaron Stannard
@Aaronontheweb
@ismaelhamed weird
you're right
I'll need to do a manual push of those today
and review why we didn't publish
Bartosz Sypytkowski
@Horusiath
@joshgarnett internal protected doesn't prevent you from overriding - personally I'm using this method quite often
Joshua Benjamin
@annymsMthd
Is there any way to remove/add routees to a router after its creation? I have a scenario i need to cover... I have a pool of tcp connections to a few Impala hosts. I want to use smallest mailbox to router messages to these but if one of the connections die I want to remove it from the router until it is healthy again.
Load balancing with a health check basically
Kris Schepers
@schepersk
Hi @Horusiath , where are we on the BatchingSqlServerJournal these days?
kagetoki
@kagetoki
Hi guys. As I've read, Akka serializes events as byte array with specifying .Net type. Does it mean that Akka can deserialize objects with private setters only, unlike, for example, Newtonsoft.Json?
Bartosz Sypytkowski
@Horusiath
@schepersk it should work now (see Readme) - please keep in mind that it's targetting v1.3.1 - we spotted a bug in Akka.Persistence v1.3.2 that breaks compatiblity with Akka.Persistence.SqlServer v1.3.1. It will be fixed when sql server version will catch up core.
@annymsMthd you can allways add and remove routees, all you need is to send AddRoutee or RemoveRoutee directly to router ref
Aaron Stannard
@Aaronontheweb
@ismaelhamed update on the XUnit issue on #3173
should have those packages going live shortly
looks like some of the changes to the .NET Core SDK stopped packing those two projects; no idea why
Aaron Stannard
@Aaronontheweb
@alexvaluyskiy looks like the latest DocFx changes broke our publishing step
taking a look at the build logs now
[20:42:27]    [Step 3/3] Failed to upload artifacts via FTP. Reply was: 550 The process cannot access the file because it is being used by another process. 
[20:42:28]    [Step 3/3] Step Azure Websites Upload (FTP Upload) failed
nevermind
stupid issue
not sure why that happened
I'll re-run that later on today; have to do a version bump on the dev branch anyway as a placeholder for 1.3.3
nate-dahlin
@nate-dahlin
We have persistence actors but they are short lived and aren't reused. We are using SQL-Server and our Metadata table can get very large. Our PeristenceId is <someName>-NewGuid. Is there some way to clear out the Metadata table? Upon our actors shutdown we are doing DeleteMessages(SnapshotSequenceNr) and this is cleaning up the EventJournal but we noticed the Metadata hangs around.
Bartosz Sypytkowski
@Horusiath
@nate-dahlin unfortunatelly purging metadata table is not there yet.
nate-dahlin
@nate-dahlin
Thanks. Is it in the works or should I open an issue or anything on it?
Joshua Benjamin
@annymsMthd
@Horusiath thanks. That's where i landed too.
Kris Schepers
@schepersk
@Horusiath Thanks! Any idea when the SqlServer implementation will be updated?
Bartosz Sypytkowski
@Horusiath
@schepersk PR is ready akkadotnet/Akka.Persistence.SqlServer#88 - just needs to be merged and published
jalchr
@jalchr

It is mentioned here http://bartoszsypytkowski.com/how-akka-net-persistence-works/ , the following:

... your persistent actors should be singletons - there should never be more than one instance of an actor using the same PersistentId at the time.

My question is: how does persistence actors work in a Cluster ?
For example, if I have 2 nodes, how is the behavior of "OnRecovery" ... and a lot of other questions ?

Bartosz Sypytkowski
@Horusiath
@jalchr same applies to cluster. Only one instance of an actor per logical persistenceId active at the same time. You can use i.e. Akka.Cluster.Sharding to achieve that
anthonyhawes
@anthonyhawes
@Horusiath Is the longer term plan to implement batching journals for other sql providers or is this just for SQL Server?