Deveel.Data.Diagnostics.EventRegistry Class Reference

Inheritance diagram for Deveel.Data.Diagnostics.EventRegistry:

Public Member Functions
	EventRegistry (IContext context)
void	RegisterEvent (IEvent @event)
	Adds the specified event object to the registry. More...
Public Member Functions inherited from Deveel.Data.Diagnostics.ThreadedQueue< IEvent >
void	Dispose ()

Protected Member Functions
override void	Consume (IEvent message)
override void	Dispose (bool disposing)
Protected Member Functions inherited from Deveel.Data.Diagnostics.ThreadedQueue< IEvent >
	ThreadedQueue ()
abstract void	Consume (TMessage message)
void	Enqueue (TMessage message)

Properties
IContext	Context [get, private set]
override int	ThreadCount [get]
Properties inherited from Deveel.Data.Diagnostics.ThreadedQueue< IEvent >
virtual int	ThreadCount [get]

Private Member Functions
	~EventRegistry ()

Private Attributes
bool	disposed
readonly int	threadCount

Additional Inherited Members
Public Attributes inherited from Deveel.Data.Diagnostics.ThreadedQueue< IEvent >
const int	DefaultThreadCount

Detailed Description

Definition at line 22 of file EventRegistry.cs.

Constructor & Destructor Documentation

Deveel.Data.Diagnostics.EventRegistry.EventRegistry ( IContext  context )

inline

Definition at line 27 of file EventRegistry.cs.

                                               {
            if (context == null)
                throw new ArgumentNullException("context");

            Context = context;

            var config = context.ResolveService<IConfiguration>();
            threadCount = config.GetInt32("system.events.threadCount", 4);
        }

Deveel.Data.Diagnostics.EventRegistry.~EventRegistry ( )

inlineprivate

Definition at line 37 of file EventRegistry.cs.

                         {
            Dispose(false);
        }

Member Function Documentation

override void Deveel.Data.Diagnostics.EventRegistry.Consume ( IEvent  message )

inlineprotected

Definition at line 51 of file EventRegistry.cs.

                                                        {
            var routers = Context.ResolveAllServices<IEventRouter>();
            foreach (var router in routers) {
                try {
                    if (router.CanRoute(message))
                        router.RouteEvent(message);
                } catch (Exception ex) {
                    Enqueue(new ErrorEvent(ex, -1, ErrorLevel.Critical));
                }
            }
        }

override void Deveel.Data.Diagnostics.EventRegistry.Dispose ( bool  disposing )

inlineprotectedvirtual

Reimplemented from Deveel.Data.Diagnostics.ThreadedQueue< IEvent >.

Definition at line 63 of file EventRegistry.cs.

                                                        {
            if (disposed) {
                Context = null;
                disposed = true;
            }

            base.Dispose(disposing);
        }

void Deveel.Data.Diagnostics.EventRegistry.RegisterEvent ( IEvent @  event )

inline

Adds the specified event object to the registry.

Parameters

event

The event object to be registered.

Implements Deveel.Data.Diagnostics.IEventRegistry.

Definition at line 47 of file EventRegistry.cs.

                                                 {
            Enqueue(@event);
        }

Member Data Documentation

bool Deveel.Data.Diagnostics.EventRegistry.disposed

private

Definition at line 23 of file EventRegistry.cs.

readonly int Deveel.Data.Diagnostics.EventRegistry.threadCount

private

Definition at line 25 of file EventRegistry.cs.

Property Documentation

IContext Deveel.Data.Diagnostics.EventRegistry.Context

getprivate set

Definition at line 41 of file EventRegistry.cs.

override int Deveel.Data.Diagnostics.EventRegistry.ThreadCount

get

Definition at line 43 of file EventRegistry.cs.

---

The documentation for this class was generated from the following file:

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Diagnostics/EventRegistry.cs