Peter Shrosbree pshrosbree
pshrosbree
/ FairQueueing.cs
Last active
September 20, 2018 16:57
Fair request queueing with Akka.NET
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| namespace FairQueueing | |
| { | |
| using System; | |
| using System.Collections.Generic; | |
| using System.Linq; | |
| using System.Threading.Tasks; | |
| using Akka.Actor; | |
| using Akka.Routing; | |
| public class ApplicationActor : ReceiveActor, IWithUnboundedStash |
pshrosbree
/ DeserializeAzureEventHubCapture.cs
Last active
February 14, 2023 11:06
Deserializing Azure event hub capture files from Apache Avro with C#
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| /* | |
| NuGet references: | |
| Microsoft.Hadoop.Avro2 (1.2.1 works) | |
| WindowsAzure.Storage (8.3.0 works) | |
| Namespaces: | |
| Microsoft.Hadoop.Avro.Container | |
| Microsoft.WindowsAzure.Storage | |
| */ |