jefking / king.service.servicebus Goto Github PK

View Code? Open in Web Editor NEW

9.0 6.0 3.0 1.08 MB

Task scheduling for .NET: Azure Service Bus

Home Page: https://www.nuget.org/packages/King.Service.ServiceBus

License: MIT License

C# 100.00%

azure service-bus service-bus-topic service-bus-queue scheduler dequeue c-sharp task-scheduler

king.service.servicebus's Introduction

Task scheduling for .NET: Service Bus.

Initialize: Queues, Topics
Enqueue and dequeue
Enqueue for dequeue at specific time
Dequeue batches
Recieve events
Time sensitive events
Plugs into King.Service

Wiki

View the wiki to learn how to use this.]

NuGet

PM> Install-Package King.Service.ServiceBus

Demo Container

Create Azure Service Bus

Pull

docker pull jefking/king.service.servicebus.demo

Run

docker run -it jefking/king.service.servicebus.demo <YOUR CONNECTION STRING>

CI

king.service.servicebus's People

Stargazers

Watchers

Forkers

modulexcite smartfire lulzzz

king.service.servicebus's Issues

Server Wait Time

Server wait time should reflect frequency of dequeue process; to ensure that not too many calls get stacked up.

Topic Recievers

Topic sending is now in place; have to build out topic recievers.

Community Ask (documentation)

It would be great if you could add some more info on use cases in wiki and demo code when someone ought to use polling, scaling, event, buffered event, batch and dynamicqueue..

More Info

Log the name of the class, and the processor:

EventName="MessageEvent" Message="System.InvalidOperationException: Message not processed

Server stack trace:
at King.Service.ServiceBus.BusEvents1.MessageArrived(Object body) at System.Threading.Tasks.Task.Execute() --- End of stack trace from previous location where exception was thrown --- at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) at King.Service.ServiceBus.BusEvents1.d__1.MoveNext()

Exception rethrown at [0]:
at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result)
at Microsoft.ServiceBus.Messaging.MessageReceivePump.EndTaskCallback(IAsyncResult asyncResult)
at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.StepCallback(IAsyncResult result)" TraceSource="WaWorkerHost.exe"

Buffered Timing breaks down

Under load the buffered timing seems to break down (quickly) testing and validation of design needed.

Unable to recieve messages

King.Service.ServiceBus.Demo Error: 0 : Failed to start King.Service.ServiceBus.Demo.Tasks.CompanyDequeuer: System.InvalidOperationException: A message handler has already been registered.
   at Microsoft.Azure.ServiceBus.Core.MessageReceiver.OnMessageHandler(MessageHandlerOptions registerHandlerOptions, Func`3 callback) in C:\source\azure-service-bus-dotnet\src\Microsoft.Azure.ServiceBus\Core\MessageReceiver.cs:line 1273
   at King.Service.ServiceBus.Wrappers.BusQueueClient.OnMessage(Func`3 callback, MessageHandlerOptions options) in /home/jbdking/github/King.Service.ServiceBus/King.Service.ServiceBus/Wrappers/BusQueueClient.cs:line 95
   at King.Service.ServiceBus.BusEvents`1.Run() in /home/jbdking/github/King.Service.ServiceBus/King.Service.ServiceBus/BusEvents.cs:line 88
   at King.Service.InitializeTask.Start()
   at King.Service.RoleTaskManager`1.<>c__DisplayClass10_0.<Run>b__0(Object index)