eventhubclientsample.cs

var factory = MessagingFactory.Create(ServiceBusEnvironment.CreateServiceUri("sb", "test", ""), new MessagingFactorySettings()
{
    TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider(SasKeyName, SasKey),
    TransportType = TransportType.Amqp
});
var eventHubClient = factory.CreateEventHubClient(EventHubName);
var group = eventHubClient.GetDefaultConsumerGroup();
var reciver = group.CreateReceiver(state.ToString());
while (true)
{
    var m = reciver.Receive();
    if (m == null) continue;
    var bytes = m.GetBytes();
    if (!bytes.Any())
    {
        Console.WriteLine("partition: " + state + ":\t(empty data)");
        continue;
    }
    if (bytes[0] == 0xA1 || bytes[0] == 0xA0)
    {
        var msg = bytes.Skip(2).Take(bytes[1]).ToArray();
        Console.WriteLine("partition: " + state + ":partition key: " + m.PartitionKey + ":0xA1/A0: " + Encoding.UTF8.GetString(msg));
    }
    else
    {
        var msg = Encoding.UTF8.GetString(bytes);
        Console.WriteLine("partition: " + state + " :partition key: " + m.PartitionKey + ": " + msg);
    }
}