dependabot-preview[bot] on nuget
dependabot-preview[bot] on dev
Bump Microsoft.NET.Test.Sdk fro… (compare)
dependabot-preview[bot] on nuget
Bump FluentAssertions from 4.14… (compare)
dependabot-preview[bot] on nuget
Bump Microsoft.NET.Test.Sdk fro… (compare)
dependabot-preview[bot] on nuget
dependabot-preview[bot] on dev
Bump MongoDB.Driver from 2.11.6… (compare)
dependabot-preview[bot] on nuget
Bump MongoDB.Driver from 2.11.6… (compare)
[WARNING][10/11/2016 1:07:12 PM][Thread 0004][[akka://example/user/sharding/product#924346451]] Trying to register to coordinator at [], but no acknowledgement. Total [12] buffered messages.
private static void ShardingExample(ActorSystem system)
{
var sharding = ClusterSharding.Get(system);
var shardRef = sharding.Start("product", Props.Create(() => new Product()), ClusterShardingSettings.Create(system),
message =>
{
var productMessage = message as IProductMessage;
return productMessage != null ? Tuple.Create(productMessage.Id.Value, message) : null;
}, message => "0001");
shardRef.Tell(new CreateProduct(ProductId.CreateAsin("ACME001"), "Jetpack"));
shardRef.Tell(new CreateProduct(ProductId.CreateAsin("ACME002"), "Giant magnet"));
var rand = new Random();
for (int idx = 0; idx < 10; idx++)
{
var productId = ProductId.CreateAsin($"ACME00{rand.Next(1, 3)}");
shardRef.Tell(new SubmitReview(productId, rand.Next(1, 6)));
}
}
@damianReeves are you talking about adding new nodes at the same time as roles, or it is just roles to a node?
+
All Conversations
Activate or click this element to toggle the profile menu
Search
Favourites
People
akkadotnet
•
Home
•
Billing
•
Get Gitter Apps
•
Sign Out
Add a room
akka.net
101
Leave
Hide
AkkaStreams
Leave
Hide
All Rooms
dotnet-core
akkadotnet.github.com
Wire
Peter Bergman @ akkadotnet/akka.net
Cool, thx
Arjen Smits @ akkadotnet/akka.net
ah yes, if you want to know if a child exists checking for the nobody status is faster
Hi... I hope someone can help. Im currently evaluating Akka.net for suitability for an internal rewrite. Its going well so far but I am currently looking at edge cases. I have setup a Cluster with remote deployment but want to be able to resend a message on failure. Is there anyway I can detect this and retry?
I have tried to look to see if I can read messages off the DeadLetter mailbox and retry from there but didn't have much luck trying to find out how to read from that mailbox either.
AtLeastOnceDeliveryActor
http://getakka.net/docs/persistence/at-least-once-delivery