Skip to content

Instantly share code, notes, and snippets.

View jtaubensee's full-sized avatar

John Taubensee jtaubensee

32 followers · 18 following
View GitHub Profile
@jtaubensee
jtaubensee / ServiceBus_ReceivingMessages.cs
Last active May 23, 2016 23:55
Getting Started With Queues C# - Receiving Messages
using System;
using Microsoft.ServiceBus.Messaging;
namespace GettingStartedWithQueues
{
class Program
{
static void Main(string[] args)
{
var connectionString = "";
@jtaubensee
jtaubensee / ServiceBus_SendingMessages.cs
Last active May 23, 2016 23:55
Getting Started With Queues C# - Sending Messages
using System;
using Microsoft.ServiceBus.Messaging;
namespace GettingStartedWithQueues
{
class Program
{
static void Main(string[] args)
{
var connectionString = "";
@jtaubensee
jtaubensee / ARM_EventHub_AuthRule.json
Created May 27, 2016 23:07
Same ARM template that is at https://azure.microsoft.com/en-us/documentation/articles/service-bus-resource-manager-namespace-event-hub/#comment-2695399156, but includes an auth rule
{
"$schema": "http://schema.management.azure.com/schemas/2014-04-01-preview/deploymentTemplate.json#",
"contentVersion": "1.0.0.0",
"parameters": {
"serviceBusNamespaceName": {
"type": "string",
"metadata": {
"description": "Name of the EventHub namespace"
}
},
@jtaubensee
jtaubensee / BadSqlFilter.cs
Created June 8, 2016 14:31
var message = new BrokeredMessage();
message.Properties["datetime"] = DateTime.Now;
var sqlFilter = new SqlFilter("datetime > '2016-06-06'");
@jtaubensee
jtaubensee / GoodSqlFilter.cs
Created June 8, 2016 14:32
var filter = new SqlFilter(" datetime >= @datetime");
filter.Parameters.Add("@datetime", DateTime.Parse("2016-06-06"));
@jtaubensee
jtaubensee / SqlRuleAction.cs
Created June 24, 2016 17:59
RuleAction action = ProcessRuleAction(
new SqlRuleAction("SET user.MyNewProperty = 'ABC' + Property(@propertyName)")
{
Parameters =
{
{ "@propertyName", "MyProperty" }
}
});
action.Execute(message);
@jtaubensee
jtaubensee / ScheduleMessagesSample.cs
Last active June 30, 2016 22:00
Service Bus messaging - Use AMQP to schedule and cancel messages
static async Task ScheduleMessagesSample(string serviceBusConnectionString)
{
// Set transport type to AMQP
var builder = new ServiceBusConnectionStringBuilder(serviceBusConnectionString);
builder.TransportType = TransportType.Amqp;
// Create queue
NamespaceManager namespaceManager = NamespaceManager.CreateFromConnectionString(builder.ToString());
QueueDescription queueDescription = new QueueDescription("myqueue") { EnablePartitioning = true };
namespaceManager.CreateQueue(queueDescription);
@jtaubensee
jtaubensee / PremiumMessagingQueueResults.txt
Created July 11, 2016 17:01
Send Send Send| Receive Receive| Complete Receive
Rate Latency Count| Rate Latency Latency Count| Server Other
Label (msg/s) (ms) (msg)| (m/s) (ms) (ms) (msg)| Busy Exceptions
4:49:34 PM 14,166 69.15 425,000 14,156 109.29 30.79 424,700 0 0
4:50:04 PM 13,673 71.98 410,200 13,670 114.38 31.93 410,101 0 0
4:50:34 PM 13,520 72.41 405,600 13,533 114.46 32.59 406,000 0 0
4:51:04 PM 13,010 76.21 390,300 13,010 116.74 37.61 390,300 0 0
4:51:34 PM 13,473 73.20 404,200 13,470 114.98 33.55 404,100 0 0
4:52:04 PM 12,953 76.17 388,600 12,950 119.30 35.17 388,500 0 0
4:52:34 PM 10,906 90.61 327,200 10,896 137.03 46.41 326,900 0 0
@jtaubensee
jtaubensee / PremiumMessagingTopic5SubscriptionsResults.txt
Last active July 11, 2016 22:32
Send Send Send| Receive Receive| Complete Receive
Rate Latency Count| Rate Latency Latency Count| Server Other
Label (msg/s) (ms) (msg)| (m/s) (ms) (ms) (msg)| Busy Exceptions
5:13:14 PM 4,446 220.46 133,400 15,576 483.00 143.45 467,300 0 0
5:13:44 PM 3,916 251.60 117,500 15,416 471.97 172.28 462,505 0 0
5:14:14 PM 3,676 268.68 110,300 15,430 474.30 176.67 462,900 0 0
5:14:44 PM 3,673 267.23 110,200 13,906 532.34 183.83 417,200 0 0
5:15:14 PM 4,110 250.27 119,200 16,210 446.56 176.06 470,100 0 0
5:15:44 PM 3,796 259.34 113,900 14,550 551.64 156.63 436,500 0 0
5:16:14 PM 3,930 251.93 117,900 12,300 646.88 161.35 369,000 0 0
@jtaubensee
jtaubensee / PremiumMessagingSingleTopic1SubscriptionResults.txt
Last active July 11, 2016 22:33
Send Send Send| Receive Receive| Complete Receive
Rate Latency Count| Rate Latency Latency Count| Server Other
Label (msg/s) (ms) (msg)| (m/s) (ms) (ms) (msg)| Busy Exceptions
5:01:52 PM 8,056 121.86 241,700 7,993 177.72 69.78 239,800 0 0
5:02:22 PM 8,470 117.24 254,100 8,450 170.44 66.33 253,501 0 0
5:02:52 PM 8,163 121.04 244,900 8,180 178.63 65.58 245,400 0 0
5:03:22 PM 7,330 135.17 219,900 7,266 203.31 72.16 218,000 0 0
5:03:52 PM 8,186 120.82 245,600 8,210 174.98 68.45 246,300 0 0
5:04:22 PM 8,646 114.16 259,400 8,666 171.59 59.32 260,000 0 0
5:04:52 PM 8,100 122.15 243,000 8,086 181.06 66.56 242,600 0 0