Da ist mein kleines Projekt – eine .net-Message-Bus-Implementierung, die mit MS SQL-Warteschlangen oder MongoDB funktioniert (MongoDB-Unterstützung ist eine neue Ergänzung). Link:http://code.google.com/p/nginn-messagebus/ und http://nginn.org/blog für einige Beispiele. Ich bin mir nicht sicher, ob das das ist, wonach Sie suchen, es fehlt auch an Dokumentation und Beispielabteilungen und es entspricht nicht genau Ihren Spezifikationen (Polling statt Tailing) - aber vielleicht ist es einen Versuch wert . Dies ist ein Publish-Subscribe-Nachrichtenbus wie NServiceBus oder MassTransit - keine Rohnachrichtenwarteschlange.
PS Ich fürchte, es gibt Anforderungen, die sich in Ihren Spezifikationen gegenseitig ausschließen:Sie können keinen Tailable-Cursor mit gleichzeitigen Verbrauchern verwenden, da Sie die Atomizität verlieren. Wenn Sie eine Warteschlange abfangen möchten, sollten Sie nur einen einzelnen Verbraucher verwenden.
