dependabot-preview[bot] on nuget
Bump NUnit from 3.7.1 to 3.13.1… (compare)
dependabot-preview[bot] on nuget
Bump System.Configuration.Confi… (compare)
Aaronontheweb on dev
HeartbeatNodeRing performance (… (compare)
1<Hyperion.Surrogate>, System.Collections.Generic.IEnumerable
1<Hyperion.SerializerFactories.ValueSerializerFactory>, System.Collections.Generic.IEnumerable`1<System.Type>)'.
public class ClassName : ReceiveActor, IWithUnboundedStash
{
public IStash Stash { get; set; }
public ClassName()
{
ReceiveAny(_ => Stash.Stash());
}
void BecomeLoaded()
{
Stash.UnstashAll();
}
}
Cannot find serializer with id [7]. The most probable reason is that the configuration entry 'akka.actor.serializers' is not in sync between the two systems.
public class AmqpPortalCoordinator : ReceiveActor
{
private readonly IActorRef chatserver;
private readonly ActorMaterializer mat;
const string inboundQueue = "InboundWeChatServer";
private readonly AmqpConnectionDetails connectionSettings;
private Task incomingTask;
public AmqpPortalCoordinator(IActorRef chatserver)
{
this.chatserver = chatserver;
mat = ActorMaterializer.Create(Context);
connectionSettings = AmqpConnectionDetails.Create("localhost", 5672)
.WithAutomaticRecoveryEnabled(true)
.WithNetworkRecoveryInterval(TimeSpan.FromSeconds(1));
var queueDeclaration = QueueDeclaration
.Create(inboundQueue)
.WithDurable(true)
.WithAutoDelete(false);
var queueSource = NamedQueueSourceSettings.Create(connectionSettings, inboundQueue).WithDeclarations(queueDeclaration);
var amqpSource = AmqpSource.CommittableSource(queueSource, 1000);
var messageSource = amqpSource.Select(m =>
{
var bytes = m.Message.Bytes;
m.Ack();
return MessagePackSerializer.Typeless.Deserialize(bytes.ToArray());
});
incomingTask = messageSource.RunForeach(msg => chatserver.Tell(msg), mat);
}
}