haven't done a push of this package in 18 months
byte rot
to specify source
gotta deal with this before I can answer your question
https://github.com/akkadotnet/akka.net/blob/dev/src/core/Akka.Remote.Tests/Transport/AkkaProtocolStressTest.cs#L50 - this is a good self-contained spec that demonstrates it
you enable a "transport adapter"
it's a unit that sits in front of your Akka.Remote transport
and is able to intercept messages as they're written or read
we have two built-in transport adapters we use for testing
the Gremlin, also known as the "failure injector"
which simulates packet loss
and the throttler, which simulates latency
you'd be able to setup a chaos-monkey-esque scenario using the former
it's probabilistic, FYI
you set a packet loss percentage
or you can use a
blackhole setting
which essentially forces a disconnect
that would behave the same way
cool, we shall see how this goes
Trying to debug some non-deterministic behavior, it’s been fun
I need to finish the part 3 of that series one day
it uses property and model-based testing
found tons of weird edge cases in production Akka.NET code with it
still don't know why Proto.Actor exists. Can someone comment?
@ayoung you could ask this question on proto.actor channel. IMO it result of some of the Roger's thoughts on akka's actors, that couldn't be implemented in akka itself because of legacy reasons. Personally me (and probably many people in the core team) sympathize with at least some of those ideas - we talked about them even before birth of proto.actor.
Is there something special I need to do in order to serialize an enum as part of a message? I'm using Hyperion and as soon as I add my enum to a message I send, I get an error. ERROR 2017-09-14 14:35:54,547 [25] TcpServerHandler - Error caught channel [::ffff:172.16.165.175]:9710->[::ffff:172.16.165.175]:64469
System.Net.Sockets.SocketException (0x80004005): An existing connection was forcibly closed by the remote host
at DotNetty.Transport.Channels.Sockets.SocketChannelAsyncOperation.Validate()
at DotNetty.Transport.Channels.Sockets.AbstractSocketByteChannel.SocketByteChannelUnsafe.FinishRead(SocketChannelAsyncOperation operation)
DEBUG 2017-09-14 14:35:54,551 [25] EndpointWriter - Disassociated [akka.tcp://PMTActorSystem@chipd-pc2:9710] <- akka.tcp://PMTActorSystem@chipd-pc2:9560
WARN 2017-09-14 14:35:54,552 [25] ReliableDeliverySupervisor - Association with remote system akka.tcp://PMTActorSystem@chipd-pc2:9560 has failed; address is now gated for 5000 ms. Reason is: [Akka.Remote.EndpointDisassociatedException: Disassociated
at Akka.Remote.EndpointWriter.PublishAndThrow(Exception reason, LogLevel level, Boolean needToThrow)
at Akka.Remote.EndpointWriter.Unhandled(Object message)
at Akka.Actor.ReceiveActor.ExecutePartialMessageHandler(Object message, PartialAction`1 partialAction)
at Akka.Actor.ReceiveActor.OnReceive(Object message)
System.Net.Sockets.SocketException (0x80004005): An existing connection was forcibly closed by the remote host
at DotNetty.Transport.Channels.Sockets.SocketChannelAsyncOperation.Validate()
at DotNetty.Transport.Channels.Sockets.AbstractSocketByteChannel.SocketByteChannelUnsafe.FinishRead(SocketChannelAsyncOperation operation)
DEBUG 2017-09-14 14:35:54,551 [25] EndpointWriter - Disassociated [akka.tcp://PMTActorSystem@chipd-pc2:9710] <- akka.tcp://PMTActorSystem@chipd-pc2:9560
WARN 2017-09-14 14:35:54,552 [25] ReliableDeliverySupervisor - Association with remote system akka.tcp://PMTActorSystem@chipd-pc2:9560 has failed; address is now gated for 5000 ms. Reason is: [Akka.Remote.EndpointDisassociatedException: Disassociated
at Akka.Remote.EndpointWriter.PublishAndThrow(Exception reason, LogLevel level, Boolean needToThrow)
at Akka.Remote.EndpointWriter.Unhandled(Object message)
at Akka.Actor.ReceiveActor.ExecutePartialMessageHandler(Object message, PartialAction`1 partialAction)
at Akka.Actor.ReceiveActor.OnReceive(Object message)
Hello geeks, I am having an issue after updating my Akka packages:
System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. ---> System.MissingMethodException: Method not found: 'Void Hyperion.SerializerOptions..ctor(Boolean, Boolean, System.Collections.Generic.IEnumerable`1<Hyperion.Surrogate>, System.Collections.Generic.IEnumerable`1<Hyperion.SerializerFactories.ValueSerializerFactory>, System.Collections.Generic.IEnumerable`1<System.Type>)'.
at Akka.Serialization.HyperionSerializer..ctor(ExtendedActorSystem system, HyperionSerializerSettings settings)
--- End of inner exception stack trace ---
at System.RuntimeMethodHandle.InvokeMethod(Object target, Object[] arguments, Signature sig, Boolean constructor)
at System.Reflection.RuntimeConstructorInfo.Invoke(BindingFlags invokeAttr, Binder binder, Object[] parameters, CultureInfo culture)
at System.RuntimeType.CreateInstanceImpl(BindingFlags bindingAttr, Binder binder, Object[] args, CultureInfo culture, Object[] activationAttributes, StackCrawlMark& stackMark)
at System.Activator.CreateInstance(Type type, BindingFlags bindingAttr, Binder binder, Object[] args, CultureInfo culture, Object[] activationAttributes)
at System.Activator.CreateInstance(Type type, Object[] args)
at Akka.Serialization.Serialization..ctor(ExtendedActorSystem system)
at Akka.Actor.Internal.ActorSystemImpl..ctor(String name, Config config)
at Akka.Actor.ActorSystem.Create(String name)Please assist. This is my config is the app.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 = off
actor
{
debug
{
receive = on
autoreceive = on
lifecycle = on
event-stream = on
unhandled = on
}
serializers {
hyperion = "Akka.Serialization.HyperionSerializer, Akka.Serialization.Hyperion"
}
serialization-bindings {
"System.Object" = hyperion
}
}
}
]]>
</hocon>
</akka>
I will give it a try