CQRS.NET  2.1
A lightweight enterprise framework to write CQRS, event-sourced and micro-service applications in hybrid multi-datacentre, on-premise and Azure environments.
Public Member Functions | Protected Member Functions | Properties | List of all members
Cqrs.Bus.QueuedCommandBusReceiver< TAuthenticationToken > Class Template Referenceabstract
+ Inheritance diagram for Cqrs.Bus.QueuedCommandBusReceiver< TAuthenticationToken >:

Public Member Functions

virtual bool ReceiveCommand (ICommand< TAuthenticationToken > command)
 
abstract void Start ()
 

Protected Member Functions

 QueuedCommandBusReceiver (IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, IConfigurationManager configurationManager, IBusHelper busHelper)
 
virtual void EnqueueCommand (string targetQueueName, ICommand< TAuthenticationToken > command)
 
virtual void CreateQueueAndAttachListenerIfNotExist (string queueName)
 
virtual void DequeuAndProcessCommand (string queueName)
 

Properties

static ConcurrentDictionary< string, ConcurrentQueue< ICommand< TAuthenticationToken > > > QueueTracker [get]
 
ReaderWriterLockSlim QueueTrackerLock [get]
 
IAuthenticationTokenHelper< TAuthenticationToken > AuthenticationTokenHelper [get]
 
ICorrelationIdHelper CorrelationIdHelper [get]
 
ILogger Logger [get]
 
IConfigurationManager ConfigurationManager [get]
 
IBusHelper BusHelper [get]
 
abstract IDictionary< Type, IList< Action< IMessage > > > Routes [get]
 
int QueueCount [get]
 
ICollection< string > QueueNames [get]