Show / Hide Table of Contents

    Class AbstractDiscoveryAgent

    Inheritance
    System.Object
    AbstractDiscoveryAgent
    HttpDiscoveryAgent
    Implements
    IDiscoveryAgent
    Apache.NMS.IStartable
    Apache.NMS.IStoppable
    System.IDisposable
    Inherited Members
    System.Object.Equals(System.Object)
    System.Object.Equals(System.Object, System.Object)
    System.Object.GetHashCode()
    System.Object.GetType()
    System.Object.MemberwiseClone()
    System.Object.ReferenceEquals(System.Object, System.Object)
    System.Object.ToString()
    Namespace: Apache.NMS.ActiveMQ.Transport.Discovery
    Assembly: Apache.NMS.ActiveMQ.dll
    Syntax
    public abstract class AbstractDiscoveryAgent : IDiscoveryAgent, IStartable, IStoppable, IDisposable

    Fields

    | Improve this Doc View Source

    DEFAULT_BACKOFF_MULTIPLIER

    Declaration
    public const int DEFAULT_BACKOFF_MULTIPLIER = 2
    Field Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    DEFAULT_INITIAL_RECONNECT_DELAY

    Declaration
    public const int DEFAULT_INITIAL_RECONNECT_DELAY = 5000
    Field Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    DEFAULT_MAX_RECONNECT_DELAY

    Declaration
    public const int DEFAULT_MAX_RECONNECT_DELAY = 30000
    Field Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    discoveredServices

    Declaration
    protected Dictionary<string, DiscoveredServiceData> discoveredServices
    Field Value
    Type Description
    System.Collections.Generic.Dictionary<System.String, DiscoveredServiceData>
    | Improve this Doc View Source

    discoveredServicesLock

    Declaration
    protected readonly object discoveredServicesLock
    Field Value
    Type Description
    System.Object
    | Improve this Doc View Source

    executor

    Declaration
    protected readonly ThreadPoolExecutor executor
    Field Value
    Type Description
    ThreadPoolExecutor
    | Improve this Doc View Source

    started

    Declaration
    protected readonly Atomic<bool> started
    Field Value
    Type Description
    Apache.NMS.Util.Atomic<System.Boolean>
    | Improve this Doc View Source

    worker

    Declaration
    protected Thread worker
    Field Value
    Type Description
    System.Threading.Thread

    Properties

    | Improve this Doc View Source

    BackOffMultiplier

    Declaration
    public long BackOffMultiplier { get; set; }
    Property Value
    Type Description
    System.Int64
    | Improve this Doc View Source

    DiscoveryURI

    Declaration
    public Uri DiscoveryURI { get; set; }
    Property Value
    Type Description
    System.Uri
    | Improve this Doc View Source

    Group

    Declaration
    public string Group { get; set; }
    Property Value
    Type Description
    System.String
    | Improve this Doc View Source

    InitialReconnectDelay

    Declaration
    public long InitialReconnectDelay { get; set; }
    Property Value
    Type Description
    System.Int64
    | Improve this Doc View Source

    IsStarted

    Declaration
    public bool IsStarted { get; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    KeepAliveInterval

    Gets or sets the keep alive interval. This interval controls the amount of time that a service is kept before being considered idle and removed from the list of discovered services. This value is also used to control the period of time that this service will wait before advertising itself.

    Declaration
    public abstract long KeepAliveInterval { get; set; }
    Property Value
    Type Description
    System.Int64
    | Improve this Doc View Source

    MaxReconnectAttempts

    Declaration
    public int MaxReconnectAttempts { get; set; }
    Property Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    MaxReconnectDelay

    Declaration
    public long MaxReconnectDelay { get; set; }
    Property Value
    Type Description
    System.Int64
    | Improve this Doc View Source

    ServiceAdd

    Declaration
    public ServiceAddHandler ServiceAdd { get; set; }
    Property Value
    Type Description
    ServiceAddHandler
    | Improve this Doc View Source

    ServiceRemove

    Declaration
    public ServiceRemoveHandler ServiceRemove { get; set; }
    Property Value
    Type Description
    ServiceRemoveHandler
    | Improve this Doc View Source

    UseExponentialBackOff

    Declaration
    public bool UseExponentialBackOff { get; set; }
    Property Value
    Type Description
    System.Boolean

    Methods

    | Improve this Doc View Source

    Dispose()

    Declaration
    public void Dispose()
    | Improve this Doc View Source

    DoAdvertizeSelf()

    Overriden by the actual agent class to handle the publish of this service if supported by the agent.

    Declaration
    protected abstract void DoAdvertizeSelf()
    | Improve this Doc View Source

    DoDiscovery()

    Called from the Agent background thread to allow the concrete agent implementation to perform its discovery of new services.

    Declaration
    protected abstract void DoDiscovery()
    | Improve this Doc View Source

    DoStartAgent()

    Overriden by the agent class to handle starting any agent related services or opening resources needed for the agent.

    Declaration
    protected abstract void DoStartAgent()
    | Improve this Doc View Source

    DoStopAgent()

    Overriden by the agent to handle shutting down any agent created resources.

    Declaration
    protected abstract void DoStopAgent()
    | Improve this Doc View Source

    FireServiceAddEvent(DiscoveryEvent)

    Declaration
    protected void FireServiceAddEvent(DiscoveryEvent data)
    Parameters
    Type Name Description
    DiscoveryEvent data
    | Improve this Doc View Source

    FireServiceRemoveEvent(DiscoveryEvent)

    Declaration
    protected void FireServiceRemoveEvent(DiscoveryEvent data)
    Parameters
    Type Name Description
    DiscoveryEvent data
    | Improve this Doc View Source

    IsTimeForRecovery(DiscoveredServiceData)

    Returns true if this Broker has been marked as failed and it is now time to start a recovery attempt.

    Declaration
    public bool IsTimeForRecovery(DiscoveredServiceData service)
    Parameters
    Type Name Description
    DiscoveredServiceData service
    Returns
    Type Description
    System.Boolean
    | Improve this Doc View Source

    ProcessDeadService(String)

    Declaration
    protected void ProcessDeadService(string service)
    Parameters
    Type Name Description
    System.String service
    | Improve this Doc View Source

    ProcessLiveService(String, String)

    Declaration
    protected void ProcessLiveService(string brokerName, string service)
    Parameters
    Type Name Description
    System.String brokerName
    System.String service
    | Improve this Doc View Source

    RegisterService(String)

    Declaration
    public void RegisterService(string name)
    Parameters
    Type Name Description
    System.String name
    | Improve this Doc View Source

    ServiceFailed(DiscoveryEvent)

    Declaration
    public void ServiceFailed(DiscoveryEvent failedEvent)
    Parameters
    Type Name Description
    DiscoveryEvent failedEvent
    | Improve this Doc View Source

    Start()

    Declaration
    public void Start()
    | Improve this Doc View Source

    Stop()

    Declaration
    public void Stop()

    Implements

    IDiscoveryAgent
    Apache.NMS.IStartable
    Apache.NMS.IStoppable
    System.IDisposable
    • Improve this Doc
    • View Source
    Back to top Copyright � 2005-2019 Apache Software Foundation project
    Generated by DocFX