View Source

Class DatabaseServerMessenger

An IServerMessenger that works by storing messages in the database.

Inheritance

System.Object

ServerMessengerBase

Namespace: Umbraco.Core.Sync

Assembly: Umbraco.Core.dll

Syntax

public class DatabaseServerMessenger : ServerMessengerBase, IServerMessenger, ISyncBootStateAccessor

Constructors

DatabaseServerMessenger(IRuntimeState, IScopeProvider, ISqlContext, IProfilingLogger, IGlobalSettings, Boolean, DatabaseServerMessengerOptions)

Declaration

public DatabaseServerMessenger(IRuntimeState runtime, IScopeProvider scopeProvider, ISqlContext sqlContext, IProfilingLogger proflog, IGlobalSettings globalSettings, bool distributedEnabled, DatabaseServerMessengerOptions options)

Parameters

Type	Name	Description
IRuntimeState	runtime
IScopeProvider	scopeProvider
ISqlContext	sqlContext
IProfilingLogger	proflog
IGlobalSettings	globalSettings
System.Boolean	distributedEnabled
DatabaseServerMessengerOptions	options

Fields

LocalIdentity

Gets the unique local identity of the executing AppDomain.

Declaration

protected static readonly string LocalIdentity

Field Value

Type	Description
System.String

Remarks

It is not only about the "server" (machine name and appDomainappId), but also about an AppDomain, within a Process, on that server - because two AppDomains running at the same time on the same server (eg during a restart) are, practically, a LB setup.

Practically, all we really need is the guid, the other infos are here for information and debugging purposes.

Properties

Logger

Declaration

protected ILogger Logger { get; }

Property Value

Type	Description
ILogger

Options

Declaration

public DatabaseServerMessengerOptions Options { get; }

Property Value

Type	Description
DatabaseServerMessengerOptions

ScopeProvider

Declaration

protected IScopeProvider ScopeProvider { get; }

Property Value

Type	Description
IScopeProvider

Methods

Boot()

Declaration

[Obsolete("This is no longer used and will be removed in future versions")]
protected void Boot()

DeliverRemote(ICacheRefresher, MessageType, IEnumerable<Object>, String)

Declaration

protected override void DeliverRemote(ICacheRefresher refresher, MessageType messageType, IEnumerable<object> ids = null, string json = null)

Parameters

Type	Name	Description
ICacheRefresher	refresher
MessageType	messageType
System.Collections.Generic.IEnumerable<System.Object>	ids
System.String	json

GetSyncBootState()

Declaration

public virtual SyncBootState GetSyncBootState()

Returns

Type	Description
SyncBootState

RequiresDistributed(ICacheRefresher, MessageType)

Declaration

protected override bool RequiresDistributed(ICacheRefresher refresher, MessageType dispatchType)

Parameters

Type	Name	Description
ICacheRefresher	refresher
MessageType	dispatchType

Returns

Type	Description
System.Boolean

Sql()

Declaration

protected Sql<ISqlContext> Sql()

Returns

Type	Description
Sql<ISqlContext>

Sync()

Synchronize the server (throttled).

Declaration

protected void Sync()