Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Corrected ReadyForWork queue type in Starbucks.

  • Loading branch information...
commit d17d5b6a031eecd7ed219334fa49d47c07109958 1 parent f8815e4
@jberezanski jberezanski authored CoreyKaylor committed
View
2  Samples/Starbucks.Tests/IntegrationTest.cs
@@ -21,7 +21,7 @@ public class IntegrationTest : IDisposable
public IntegrationTest()
{
PrepareQueues.Prepare("msmq://localhost/starbucks.barista.balancer", QueueType.LoadBalancer);
- PrepareQueues.Prepare("msmq://localhost/starbucks.barista.balancer.acceptingwork", QueueType.LoadBalancer);
+ PrepareQueues.Prepare("msmq://localhost/starbucks.barista.balancer.acceptingwork", QueueType.Raw);
PrepareQueues.Prepare("msmq://localhost/starbucks.barista", QueueType.Standard);
PrepareQueues.Prepare("msmq://localhost/starbucks.cashier", QueueType.Standard);
PrepareQueues.Prepare("msmq://localhost/starbucks.customer", QueueType.Standard);
View
3  Samples/Starbucks/PrepareQueues.cs
@@ -49,6 +49,9 @@ private static void PurgeSubqueues(string queuePath, QueueType queueType)
PurgeSubqueue(queuePath, "endpoints");
PurgeSubqueue(queuePath, "workers");
break;
+ case QueueType.Raw:
+ // no subqueues here
+ break;
default:
throw new ArgumentOutOfRangeException("queueType", "Can't handle queue type: " + queueType);
}
View
2  Samples/Starbucks/Program.cs
@@ -15,7 +15,7 @@ public class Program
public static void Main()
{
PrepareQueues.Prepare("msmq://localhost/starbucks.barista.balancer", QueueType.LoadBalancer);
- PrepareQueues.Prepare("msmq://localhost/starbucks.barista.balancer.acceptingwork", QueueType.LoadBalancer);
+ PrepareQueues.Prepare("msmq://localhost/starbucks.barista.balancer.acceptingwork", QueueType.Raw);
PrepareQueues.Prepare("msmq://localhost/starbucks.barista", QueueType.Standard);
PrepareQueues.Prepare("msmq://localhost/starbucks.cashier", QueueType.Standard);
PrepareQueues.Prepare("msmq://localhost/starbucks.customer", QueueType.Standard);
Please sign in to comment.
Something went wrong with that request. Please try again.