Je tu můj malý projekt – implementace sběrnice zpráv .net, která pracuje s frontami MS SQL nebo MongoDB (podpora MongoDB je nedávným přírůstkem). Odkaz:http://code.google.com/p/nginn-messagebus/ a http://nginn.org/blog pro některé příklady. Nejsem si jistý, jestli je to to, co hledáte, chybí to také v dokumentaci a odděleních příkladů a přesně neodpovídá vašim specifikacím (dotazování místo sledování) - ale možná to stojí za to vyzkoušet . Toto je sběrnice zpráv publikovat-odběr, jako je NServiceBus nebo MassTransit – nikoli fronta nezpracovaných zpráv.
PS Obávám se, že ve vašich specifikacích jsou vzájemně se vylučující požadavky:nemůžete používat tailable kurzor se souběžnými spotřebiteli, protože ztrácíte atomicitu. Pokud chcete omezit frontu, měli byste používat pouze jednoho spotřebitele.