Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 21:02
    Aaronontheweb synchronize #3975
  • 21:02
    Aaronontheweb opened #3975
  • 20:11
    IgorFedchenko commented #3973
  • 20:10
    IgorFedchenko synchronize #3973
  • 20:06
    IgorFedchenko synchronize #3973
  • 20:06
    IgorFedchenko synchronize #3973
  • 19:42
    IgorFedchenko edited #3973
  • 18:08
    Aaronontheweb commented #3937
  • 17:27
    Aaronontheweb commented #90
  • 17:26
    Aaronontheweb commented #90
  • 17:25
    Aaronontheweb assigned #90
  • 17:16

    Aaronontheweb on dev

    Provide static GetRoutees.Insta… (compare)

  • 17:16
    Aaronontheweb closed #3974
  • 17:16
    Aaronontheweb milestoned #3974
  • 16:05
    jackowild opened #90
  • 15:08
    Aaronontheweb commented #3974
  • 15:08
    Aaronontheweb commented #3974
  • Oct 13 14:40
    cptjazz synchronize #3974
  • Oct 13 14:07
    cptjazz opened #3974
  • Oct 13 08:30
    ismaelhamed commented #3937
Marc Piechura
@marcpiechura
If you want to read more about the underling protocol you can take a look at the reactive streams repository https://github.com/reactive-streams/reactive-streams-dotnet
Erik Lagerholm
@stabface
Does anyone have a code example of a decorator pattern implementation for an Akka Actor?
Ralf
@Ralf1108
@Silv3rcircl3 and if the stream doesn't get back the ack in specified time the stream will could be consideres as failed. Because of network issues there is no other possibility? if this happens in production the stream will be blocked and wont get cleaned up ?
sounds bad :-(
Ricky Blankenaufulland
@ZoolWay
@Ralf1108 I know that but was hoping to be able to use the automatic naming somehow. If you name them by my own, I will always need some kind of actor-spaning counter and that's it for concurrency...
Marc Piechura
@marcpiechura
Correct, if the stream doesn't get the ack it will not process any more elements
It will also fail if the remote watcher sends a terminated message for the destination actor
but that's not guaranteed because afaik the remote watcher has something like a timeout and if the network failure only occurs for a short time period the actor maybe isn't seen as dead and therefore no terminated message will be send to the stream but the ack is still lost and you have your deadlock
Arsene T. Gandote
@Tochemey
Hello I am having some problems logging fromm within my actor using Nlog.
This is my config
  <akka>
    <hocon>
      <![CDATA[
          akka 
          {
            loggers = ["Akka.Logger.NLog.NLogLogger, Akka.Logger.NLog"]
            # here we are configuring log levels
            stdout-loglevel = DEBUG
            loglevel = DEBUG
            log-config-on-start = on        
            actor 
            {                
                debug 
                {  
                      receive = on 
                      autoreceive = on
                      lifecycle = on
                      event-stream = on
                      unhandled = on
                }
            }
          }
      ]]>
    </hocon>
  </akka>
The only thing I see are the ActorSystem log.
Ricky Blankenaufulland
@ZoolWay
How do you obtain loggers inside your actors and what do you expect to see?
Arsene T. Gandote
@Tochemey
Like this
protected readonly ILoggingAdapter Logging = Context.GetLogger();
Ricky Blankenaufulland
@ZoolWay
And do you see log message you product with this.Logging.Info("Test"); ?
Arsene T. Gandote
@Tochemey
Nope
Ricky Blankenaufulland
@ZoolWay
And when you do a regular nlog logging outside of the actor system it works?
Arsene T. Gandote
@Tochemey
Yes
Arsene T. Gandote
@Tochemey
Anu idea of what is going on?
Can it be because I am using the TestKit?
Arjen Smits
@Danthar
that could be, the testkit loads its own config
you can append/override with a custom constructor in your test class
Arsene T. Gandote
@Tochemey
How do I go about it?
Jared Lobberecht
@Jared314
is the Akka.Persistence.SqlServer nuget package going to be updated for 1.1?
The source has been updated, but the nuget package isn't there
Arjen Smits
@Danthar
@Tochemey there are multiple constructors you can override
 public MyTestClass(string config) : base(config)
        {
                //load your string here? or use the constructor that takes a Config class instead of a string
        }
Kris Schepers
@schepersk
@Jared314 For now, we're just using the 1.0.8-beta versions SQL common and SQL server packages. Seems to be working just fine :-)
Jared Lobberecht
@Jared314
@schepersk I am also using 1.0.8, but I also need to start using the query api to build out some historical reporting and file export features
Alex Valuyskiy
@alexvaluyskiy
@Jared314 @schepersk we are planning to release it today
Ralf
@Ralf1108
@ZoolWay why not use a guid instead of a counter?
@Silv3rcircl3 so it's still an unresolved problem?
Marc Piechura
@marcpiechura
@Ralf1108 yes, you shouldn't use Akka.Streams with remote actors
Noel
@nanderto
@ @alexvaluyskiy do you mean a separate repository under my account? I don't imagine that I have access under Akka.net
Alex Valuyskiy
@alexvaluyskiy
Yes, under your account
Noel
@nanderto
ok no problem I will get it done today
Ralf
@Ralf1108
@Silv3rcircl3 sad to hear that. Thought that was the point in "Akka Streams".... to distribute stream processing over many machines. WIthout that it is only a Streams implementation with local actors.
Marc Piechura
@marcpiechura
@alexvaluyskiy btw I'm done with the adapter for azure if you want to take a look
William Austin
@wyldebill
i want to use akka.net actors in a simple domain as such - you find interesting places and submit their lat/long to the system. the system catalogs it and makes it available for others to search/query. would each place be a separate actor?
Vagif Abilov
@object
@wyldebill do these places need to perform actions by responding to messages? Do they have state? If so, they are good candidates for actors.
Erik Lagerholm
@stabface
Does anyone have a code example of a decorator pattern implementation to use with Akka actors?
Noel
@nanderto
Marc Piechura
@marcpiechura
@nanderto why haven't you forked the existing repository ? https://github.com/akkadotnet/Akka.Persistence.ServiceFabric
Noel
@nanderto
@Silv3rcircl3 the implementation is different from the previous one at that location and when I asked on this gitter if there was interest in my alternative, @alexvaluyskiy suggested that I create a new repository for it under my account.
Daniel Söderberg
@raskolnikoov
Hello! I would like some help with my akka cluster. I wont get it to work when I try to call an actor in the cluster. Dead letters all the time. Im swedish so If you want to help me in swedish you can do that.
Alex Valuyskiy
@alexvaluyskiy
@nanderto why are you using Wire for serialization? Wire is designed for ... wire. For remoting and clustering. But not for persistent. You should choose the closest serializer to your storage. In many cases it is JSON. You also could use serializers like Protobuf in this cases. Maybe @rogeralsing is not agree with me
Noel
@nanderto
@alexvaluyskiy I thought I would try it out, the standard Service Fabric way of serializing does not work at least, and it seemed like a good alternative for Akka, I am not sure I understand your objection, but I assumed that at some point it would be configurable, and users could choose there own.
Peter Bergman
@peter-bannerflow
@raskolnikoov I'm swedish so you can PM me in swedish if u want to and I'll see if I can help
Arsene T. Gandote
@Tochemey

Hello How long does it take ActorSystem to properly shutdown? because I got this in my log and I have not received any successful shutdown confirmation.

[DEBUG][16:08:02 09:15:45][ActorSystemImpl] System shutdown initiated

However I am running it inside Owin.

Arjen Smits
@Danthar
@Tochemey normally its pretty quick, since there is no real way to block system shutdown.
It does need to spin down all your actors, so if you have alot, it might take abit longer, but even then it should be a few seconds at most