dependabot-preview[bot] on nuget
Bump Google.Protobuf from 3.15.… (compare)
dependabot-preview[bot] on nuget
Bump NUnit from 3.7.1 to 3.13.1… (compare)
dependabot-preview[bot] on nuget
Bump Microsoft.NET.Test.Sdk fro… (compare)
dependabot-preview[bot] on nuget
Bump System.Configuration.Confi… (compare)
Hi Guys, I have a question regardig FlowOps.GroupedWithin()
A small timing Diagram:
==> Time-Axis
| e e e e e e e .e e e e e e
|--------t-----|--------t.-------|--------t--------|
# . # x #
# . # x #
# |-------#t-x|--------t----#---|
# # x #
1 2 x 3
x
4
GroupedWihin emits when the amount of grouped elements reaches the defined limit, or the time since the last emitted group exceeds the defined timeout.
In my example GroupedWithin(6, t) this will emit a complete group at time 1, another partially filled group (4 elements) at time 2 and another parially filled group (2 elements) at time 3.
I need a behaviour, that emits when the amount of grouped element reaches the defined limit, or the time since the first received element of the current group exceeds the defined timeout... That would emit the first group at time 1, and the next completely filled group at time 4.
Is there such a Grouping behaviour ?
I've just tried using Akka.Quartz.Actor.QuartzActor
using Akka.System.ActorOf(Props.Create(() => new QuartzActor()), "scheduler");
in a .net core 2.1 app and got a:
[akka://System/user/scheduler#154807920]: Akka.Actor.ActorInitializationException: Exception during creation ---> System.TypeLoadException: Error while creating actor instance of type Akka.Quartz.Actor.QuartzActor with 0 args: () ---> System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. ---> System.IO.FileNotFoundException: Could not load file or assembly 'System.Configuration.ConfigurationManager, Version=0.0.0.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51'. The system cannot find the file specified.
at Quartz.Impl.StdSchedulerFactory.Initialize()
at Quartz.Impl.StdSchedulerFactory.GetScheduler() in c:\projects\quartznet\src\Quartz\Impl\StdSchedulerFactory.cs:line 1102
at Akka.Quartz.Actor.QuartzActor..ctor()
--- End of inner exception stack trace ---
at System.RuntimeTypeHandle.CreateInstance(RuntimeType type, Boolean publicOnly, Boolean wrapExceptions, Boolean& canBeCached, RuntimeMethodHandleInternal& ctor)
at System.RuntimeType.CreateInstanceSlow(Boolean publicOnly, Boolean wrapExceptions, Boolean skipCheckThis, Boolean fillCache)
at System.Activator.CreateInstance(Type type, Boolean nonPublic, Boolean wrapExceptions)
at System.RuntimeType.CreateInstanceImpl(BindingFlags bindingAttr, Binder binder, Object[] args, CultureInfo culture, Object[] activationAttributes)
at Akka.Actor.Props.ActivatorProducer.Produce()
at Akka.Actor.Props.NewActor()
--- End of inner exception stack trace ---
at Akka.Actor.Props.NewActor()
at Akka.Actor.ActorCell.CreateNewActorInstance()
at Akka.Actor.ActorCell.<>c__DisplayClass109_0.<NewActor>b__0()
at Akka.Actor.ActorCell.UseThreadContext(Action action)
at Akka.Actor.ActorCell.NewActor()
at Akka.Actor.ActorCell.Create(Exception failure)
--- End of inner exception stack trace ---
at Akka.Actor.ActorCell.Create(Exception failure)
at Akka.Actor.ActorCell.SysMsgInvokeAll(EarliestFirstSystemMessageList messages, Int32 currentState)
any suggestions how to get rid of this? I take it, this extension is not under active development? From the initial looks of it, it seems to be targeting .NET 4.5.2 ?
Is there any gotcha's when using Cluster Discovery Consul + Routing?
Here is my deployment config:
/other {
router = broadcast-group
routees.paths = ["/user/api"]
virtual-nodes-factor = 8
cluster {
enabled = on
max-nr-of-instances-per-node = 2
allow-local-routees = off
use-role = "other"
}
}
I have the other console application running with an actor ready for messages at /user/api
Here is the cluster config:
cluster {
roles = ["other"]
}
Logs are showing that the nodes are up and running with the correct roles.
But the when telling /user/other
a message it keeps deadlettering. Anyway to debug what's going on?
NewtonSoftJsonSerializer