org.apache.activemq.apollo.broker

Broker

class Broker extends BaseService with SecuredResource with PluginStateSupport

A Broker is parent object of all services assoicated with the serverside of a message passing system. It keeps track of all running connections, virtual hosts and assoicated messaging destintations.

Linear Supertypes
PluginStateSupport, SecuredResource, BaseService, Dispatched, Service, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Broker
  2. PluginStateSupport
  3. SecuredResource
  4. BaseService
  5. Dispatched
  6. Service
  7. AnyRef
  8. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Broker()

Type Members

  1. class CREATED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  2. class FAILED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  3. class PeriodStat extends AnyRef

  4. class STARTED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  5. class STARTING extends State

    Attributes
    protected
    Definition Classes
    BaseService
  6. class STOPPED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  7. class STOPPING extends State

    Attributes
    protected
    Definition Classes
    BaseService
  8. sealed class State extends AnyRef

    Definition Classes
    BaseService

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. object PeriodStat

  7. var _service_failure: Throwable

    Attributes
    protected
    Definition Classes
    BaseService
  8. var _service_state: State

    Attributes
    protected
    Definition Classes
    BaseService
  9. def _start(on_completed: Task): Unit

    Definition Classes
    Broker → BaseService
  10. var _start_transition_counter: Int

    Definition Classes
    BaseService
  11. def _stop(on_completed: Task): Unit

    Definition Classes
    Broker → BaseService
  12. def accepting_connector(id: String): Option[AcceptingConnector]

  13. def apply_update(tracker: LoggingTracker): Unit

    Attributes
    protected
  14. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  15. def assert_executing: Unit

    Definition Classes
    Dispatched
  16. var audit_log: Log

  17. var authenticator: Authenticator

  18. var authorizer: Authorizer

  19. var auto_tuned_send_receiver_buffer_size: Int

  20. def clear_plugin_state[T](clazz: Class[T]): T

    Used to clear out previously set plugin state.

    Used to clear out previously set plugin state.

    Definition Classes
    PluginStateSupport
  21. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  22. var config: BrokerDTO

  23. var config_log: Log

  24. val connection_id_counter: LongCounter

  25. var connection_log: Log

  26. val connections: LinkedHashMap[Long, BrokerConnection]

  27. val connectors: LinkedHashMap[String, Connector]

  28. var console_log: Log

  29. var container: AnyRef

    A reference to a container that created the broker.

    A reference to a container that created the broker. This might something like an ServletContext or an OSGi service factory.

  30. var cow_virtual_hosts_by_hostname: Map[AsciiBuffer, VirtualHost]

    This is a copy of the virtual_hosts_by_hostname variable which can be accessed by any thread.

  31. var current_period: PeriodStat

  32. var default_virtual_host: VirtualHost

  33. val dispatch_queue: DispatchQueue

    Definition Classes
    Broker → Dispatched
  34. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  35. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  36. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  37. def first_accepting_connector: Option[AcceptingConnector]

  38. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  39. def getConfig(): BrokerDTO

  40. def getTmp(): File

  41. def get_connect_address: String

  42. def get_default_virtual_host: VirtualHost

  43. def get_socket_address(id: String): SocketAddress

  44. def get_socket_address: SocketAddress

  45. def get_virtual_host(name: AsciiBuffer): VirtualHost

  46. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  47. var id: String

    Definition Classes
    BrokerSecuredResource
  48. def init_logs: Unit

    Attributes
    protected
  49. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  50. var key_storage: KeyStorage

  51. var max_connections_in_5min: Int

  52. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  53. final def notify(): Unit

    Definition Classes
    AnyRef
  54. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  55. def now: Long

    Annotations
    @volatile()
  56. def plugin_state[T](factory: ⇒ T, clazz: Class[T]): T

    Plugins can associate state data with the virtual host instance using this method.

    Plugins can associate state data with the virtual host instance using this method. The factory will be used to create the state if it does not yet exist.

    Definition Classes
    PluginStateSupport
  57. def resource_kind: BrokerKind.type

    Definition Classes
    BrokerSecuredResource
  58. def roll_current_period: Unit

  59. var rules_cache: SecurityRules

    Definition Classes
    SecuredResource
  60. def schedule_reoccurring(time: Long, unit: TimeUnit)(func: ⇒ Unit): Unit

    Definition Classes
    BaseService
  61. var security_log: Log

  62. def service_failure(): Throwable

    Definition Classes
    BaseService → Service
  63. def service_state: State

    Definition Classes
    BaseService
  64. var services: Map[CustomServiceDTO, Service]

  65. def setConfig(arg0: BrokerDTO): Unit

  66. def setTmp(arg0: File): Unit

  67. def ssl_context(protocol: String): SSLContext

  68. def start(on_completed: Task): Unit

    Definition Classes
    Broker → BaseService → Service
  69. def start(on_completed: Runnable): Unit

  70. val stats_of_5min: CircularBuffer[PeriodStat]

  71. def stop(on_completed: Task): Unit

    Definition Classes
    Broker → BaseService → Service
  72. def stop(on_completed: Runnable): Unit

  73. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  74. var tmp: File

  75. def toString(): String

    Definition Classes
    Broker → AnyRef → Any
  76. def tune_send_receive_buffers: Unit

  77. def update(config: BrokerDTO, on_completed: Task): Unit

    Validates and then applies the configuration.

  78. def update(config: BrokerDTO, on_completed: Runnable): Unit

  79. val virtual_hosts: LinkedHashMap[AsciiBuffer, VirtualHost]

  80. val virtual_hosts_by_hostname: LinkedHashMap[AsciiBuffer, VirtualHost]

  81. def virtualhost_maintenance: Unit

  82. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  83. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  84. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  85. def web_admin_url: String

  86. var web_server: WebServer

Inherited from PluginStateSupport

Inherited from SecuredResource

Inherited from BaseService

Inherited from Dispatched

Inherited from Service

Inherited from AnyRef

Inherited from Any

Ungrouped