Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- eventHubClient = EventHubClient.CreateFromConnectionString(connectionStringBuilder.ToString());
- await eventHubClient.SendAsync(newEventData(Encoding.UTF8.GetBytes("i'm a pageview")));
- var endpointUri = ServiceBusEnvironment.CreateServiceUri("sb", eventHubNamespace, string.Empty);
- MessagingFactory factory = MessagingFactory.Create(endpointUri, new MessagingFactorySettings
- {
- TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider(sasToken),
- TransportType = TransportType.Amqp
- });
- factory.RetryPolicy = new RetryExponential(TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(30), 3);
Add Comment
Please, Sign In to add comment