akkadotnet/akka.net

Port of Akka actors for .NET

Daniel D'Agostino

@dandago2_twitter

that's not what I mean :)

so, we have Actor A again

Actor A at some point creates a consistent hashing router

when it receives a message, it sends a message (based on whatever logic) to the router

required: to ensure that that message got sent out right

Marc Piechura

@marcpiechura

router is a child of the A?

Daniel D'Agostino

@dandago2_twitter

yeah I think we can make that assumption here

Marc Piechura

@marcpiechura

and what happens then? where do the messages go from the routees of the router? maybe we call them b ;)

Daniel D'Agostino

@dandago2_twitter

we don't care :) we just want to make sure A has sent the message

Marc Piechura

@marcpiechura

then why test it anyway ? ^^

Daniel D'Agostino

@dandago2_twitter

hmmm

haha actually you're right, it becomes just another Tell() test

not sure what the problem was this morning then, I'll refresh my memory when I see the code again

thanks guys for your time :)

Marc Piechura

@marcpiechura

Arjen Smits

@Danthar

Daniel D'Agostino

@dandago2_twitter

much appreciated

Damian Reeves

@DamianReeves

Are there any recommendations or a roadmap concerning Akka.Persistence.SqlServer and SQL Server 2016's JSON type. The current column is VARBINARY which would seem to exlude us from getting any of the benefits of the JSON type. You could of course use the Manifest field it seems for potentially indexable JSON data.

Bartosz Sypytkowski

@Horusiath

@DamianReeves postgres plugin has json/jsonb support (I don't know if it's released already) - we probably could add it to sql server too, but as it will break binary compatibility, it probably won't happen before v1.5

Andrey Leskov

@andreyleskov

@DamianReeves you can store data as json string serialized in Unicode format with custom serializer. After json can be retrievied by sql CAST \ CONVERT

I'm using this approach now, just created view for Journal table

Damian Reeves

@DamianReeves

Guess I can give that a shot

Really want to do things like index Correlation and MessageIds so wondering if Manifest is another viable option

Andrey Leskov

@andreyleskov

Manifest is used to store only Type information, serializers will try to get a type from it. I did not find any possibility to embend custom information into Manifest

Damian Reeves

@DamianReeves

oh ok. I forgot about that

in my mind I kept reading Manifest as Metadata

Andrey Leskov

@andreyleskov

Yes, had same feeling ) May be tags column will fit ?

Damian Reeves

@DamianReeves

Have you actually indexed the columns in your view? is it schemabound?

Andrey Leskov

@andreyleskov

No, I prefer to keep original indexes and using view only for diagnostics \ debug in production. May be will pass json events to BI in future.

Damian Reeves

@DamianReeves

Ok, I see

Andrey Leskov

@andreyleskov

are you interested in passing events from journal to Projection ?
https://github.com/evendotnet/Even#projections

Damian Reeves

@DamianReeves

funny... I'm a contributor to that project

I was starting to be afraid Even is solving a problem that streams and persistence query solves, but in practice I see it solves an actual need

Andrey Leskov

@andreyleskov

From my point of view right now akka persistent journals really need possibility to subscribe to all persisted events as stream : akkadotnet/akka.net#2321

it will help a lot

Damian Reeves

@DamianReeves

Yeah I'm really interested in the projection story of persistent journals... Even gives us this but its not mature, I'm starting to wonder if we just need to add Reactive Streams support to even, but honestly though I get Rx I haven't quite grokked Reactive Streams yet

I think this convo is inspiring me to do a spike on Even (that and I've found myself re-implementing functionality I know Even has in an Akka based CQRS service we are building)

Andrey Leskov

@andreyleskov

I'm using simplified approach for projection - just pub\sub via EventBus \ DistributedPubSub and will gladly look at more convinient approaches

Nicola Atorino

@NicolaAtorino

Good day everyone! I started working on akka a little time ago, and I'm here for a question regarding snapshot and serialization.
I am working with the AtLeastOnceDeliveryReceiveActor, and i need to serialize my own state object toghether with the AtLeastOnceDeliverySnapshot. The documentation of the object itself says that this is possible by wrapping the object itself in another one containing my custom state, and that the AtLeastOnceDeliverySnapshot should be serialized as a blob and stored in the state object for later retrieval. The problem is that the AtLeastOnceDeliverySnapshot is not marked as serializable so I cannot use the .net binaryformatter. Any Idea how to overcome this ?

Vagif Abilov

@object

TWIMC: Had to lock Akka.Persistence.Sql.Common version to 1.1.1, the newest one (1.1.2) wasn't compatible with Akka.Persistence.SqlServer that is not yet updated to 1.1.2.

Andrew Buttigieg

@andrewbuttigieg

Hi all, bit of a question regarding TestKit. I have written a number of unit tests against several of actors in a project. Now all of these tests have ExpectNoMsg(); with everything set to default. This means that the tests are run sequentially and take 3 seconds each. With five tests, the test runner is taking 20 seconds, is there a way to parallelise the execution of these tests?

Bartosz Sypytkowski

@Horusiath

@NicolaAtorino the best option is not to use binary formatter - it's one of the slowest serializers you can imagine on .net

@object afaik akka.persistence.sqlserver PR for upgrade to v1.1.2 is merged to /dev, just not released yet

@andrewbuttigieg this depends on the test runner you're using. Xunit v2+ should have parallel builds by default

Andrew Young

@ayoung

does anyone know how to setup a broadcast group to send messages to actors that have a remote actor path? the path is like akka://clooster/remote/akka.tcp/clooster@127.0.0.1:6766/user/deployer/consistenthashrouter/c2

Andrew Buttigieg

@andrewbuttigieg

@Horusiath I am using NUnit 2x.

So maybe a setting from NUnit itself?

Bartosz Sypytkowski

@Horusiath

@andrewbuttigieg I haven't used NUnit for a while. Nonetheless it's more matter of test runner than akka testkit itself

Andrew Young

@ayoung

@Horusiath know anything about my remote path question above?

Andrey Leskov

@andreyleskov

@Horusiath does it mean that Akka.Persistence.SqlServer 1.1.2 is availalbe in nighly builds ?

Where communities thrive

People

Repo info

Activity