Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 12:20
    IgorFedchenko commented #3973
  • 12:17
    IgorFedchenko commented #3973
  • 11:58
    IgorFedchenko synchronize #3973
  • 11:33
    IgorFedchenko commented #3973
  • 11:25
    IgorFedchenko synchronize #3973
  • 07:04
    dependabot-preview[bot] labeled #3996
  • 07:04
    dependabot-preview[bot] opened #3996
  • 07:04

    dependabot-preview[bot] on nuget

    Bump Microsoft.NET.Test.Sdk fro… (compare)

  • 07:04
    dependabot-preview[bot] labeled #3995
  • 07:04

    dependabot-preview[bot] on nuget

    Bump BenchmarkDotNet from 0.10.… (compare)

  • 07:04
    dependabot-preview[bot] opened #3995
  • Oct 17 22:42
    Aaronontheweb commented #3944
  • Oct 17 22:41
    Aaronontheweb commented #3973
  • Oct 17 21:17
    IgorFedchenko commented #3973
  • Oct 17 21:08
    IgorFedchenko commented #3973
  • Oct 17 19:59
    IgorFedchenko synchronize #3973
  • Oct 17 19:34
    IgorFedchenko synchronize #3973
  • Oct 17 16:12
    Aaronontheweb commented #3993
  • Oct 17 15:51
    dependabot-preview[bot] synchronize #3991
  • Oct 17 15:51

    dependabot-preview[bot] on nuget

    Bump Microsoft.Extensions.Depen… (compare)

Aaron Stannard
@Aaronontheweb
would be another one
Joshua Garnett
@joshgarnett
You running into a lot of lambda fans lately?
Aaron Stannard
@Aaronontheweb
Azure Functions
Joshua Garnett
@joshgarnett
Same diff :P
Aaron Stannard
@Aaronontheweb
but yeah
"The Anything is Possible with JavaScript if we all Believe Hard Enough" guy
Joshua Garnett
@joshgarnett
It has some interesting properties and has some valid use cases, but I’m pretty happy with the flexibility Kubernetes or something similar gives me
Aaron Stannard
@Aaronontheweb
I just don't write much software that would benefit from it
most of my stuff is real-time stream processing
Joshua Garnett
@joshgarnett
haha, I troll Node.JS fans all the time at my company. “When I want to ensure a prototype doesn’t make it into production, I write it in a horrible language, like Node.JS"
Aaron Stannard
@Aaronontheweb
so it's perpetually executing and accumulating state
yeah, definitely enough material to do a second one of those
Roman Golenok
@shersh

Hi guys.
I'm trying to understand how streams works)
And I found interesting Sink.ActorRef<T>(IActorRef)which (if I understand right) should send each elemnt from source to Actor.
But he doesn't.
Here is gist:
https://gist.github.com/shersh/2dd43ac70ff95e20ed4c1e4b2f87b38c

Where I am wrong?

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