Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
lavinmq
v2.3.0
Top Level Namespace
Array
Channel
ConsistentHasher
Deque
Fiber
File
Filesystem
FilesystemInfo
Hash
IO
Buffered
LavinMQ
AMQP
Channel
ClosedError
TxAck
TxMessage
Unack
ChannelReplyCode
Client
ConnectionFactory
ConnectionReplyCode
ConsistentHashExchange
Consumer
ClosedError
DefaultExchange
DelayedExchangeQueue
DelayedMessageStore
Destination
DirectExchange
DurableDelayedExchangeQueue
DurablePriorityQueue
DurableQueue
Error
Exchange
FanoutExchange
FederationExchange
HeadersExchange
PriorityQueue
PriorityMessageStore
Queue
Closed
ClosedError
Error
ReadError
RejectOverFlow
StreamConsumer
StreamQueue
StreamQueueMessageStore
TopicExchange
Auth
Authenticator
BasicAuthenticator
Chain
BindingDetails
BindingKey
BytesMessage
Client
Channel
Consumer
Clustering
Action
AddAction
AppendAction
AuthenticationError
Client
AuthenticationError
Error
Controller
Error
DeleteAction
Error
FileIndex
FileRange
Follower
InvalidStartHeaderError
NoopServer
Proxy
Replicator
Server
Config
ConnectionFactory
ConnectionInfo
IPAddress
DataDirLock
Deduplication
Cache
Deduper
MemoryCache
Destination
Envelope
Error
ExchangeTypeError
PreconditionFailed
UnexpectedFrame
Etcd
Error
Lease
Lost
LeaseAlreadyExists
NoLeader
EventType
Exchange
AccessRefused
ExchangeEvent
Federation
AckMode
NoDownstreamConsumerError
Upstream
ExchangeLink
Link
State
QueueLink
UpstreamStore
HTTP
ApiDefaultsHandler
ApiErrorHandler
AuthHandler
BindingHelpers
BindingsController
ChannelsController
ConnectionsController
ConnectionsHelper
ConsumersController
Controller
HaltRequest
DefinitionsController
Definitions
GlobalDefinitions
VHostDefinitions
ExchangeHelpers
ExchangesController
LogsController
MainController
NodesController
ParametersController
ParameterView
PermissionsController
PermissionsView
PrometheusController
PrometheusWriter
Metric
MetricLabels
MetricValue
NameWriter
QueueHelpers
QueuesController
Router
Action
Params
Route
Routes
Server
StaticController
StatsHelpers
StrictTransportSecurity
UserHelpers
UsersController
UserView
VHostLimitsController
VHostLimitsView
VHostsController
VHostView
ViewsController
JournalLogFormat
Launcher
Logger
Message
MQTT
Broker
Brokers
Client
ConnectionFactory
Consumer
Exchange
BindingKey
RetainStore
IndexTree
Session
Sessions
StringTokenIterator
SubscriptionTree
TopicTree
Observable
Observer
OperatorPolicy
OutdatedSchemaVersion
Parameter
ParameterId
ParameterStore
ParameterTarget
Policy
Target
PolicyTarget
ProxyProtocol
Error
InvalidFamily
InvalidSignature
InvalidVersionCmd
UnsupportedTLVType
V1
V2
Queue
MessageStore
ClosedError
Error
QueueEvent
QueueFactory
QueueState
Reporter
Schema
SchemaV4
VhostMigrator
QueueMigrator
SegmentPositionBase
SegmentPositionV1
SegmentPositionV2
SegmentPositionV3
SchemaVersion
SegmentPosition
Server
Protocol
Shovel
AckMode
AMQPDestination
AMQPSource
DeleteAfter
Destination
FailedDeliveryError
HTTPDestination
MultiDestinationHandler
Runner
State
ShovelStore
SortableJSON
StandaloneRunner
Stats
StdoutLogFormat
Tag
UnackedMessage
UnsupportedSchemaVersion
User
BcryptPassword
InvalidPasswordHash
MD5Password
Password
Permissions
RabbitPassword
SHA256Password
SHA512Password
UnknownHashAlgoritm
UserStore
VHost
VHostStore
Event
WebSocketIO
WebsocketProxy
LavinMQCtl
DefinitionsGenerator
Frame
LavinMQPerf
BindChurn
ChannelChurn
ConnectionChurn
ConnectionCount
BasicConsumeFrame
ConsumerChurn
Perf
QueueChurn
QueueCount
Throughput
MFile
Advice
ClosedError
NamedTuple
NameValidator
Regex
RoughTime
Set
Slice
System
Error
ResourceUsage
Generated using Crystal 1.16.0
2025-04-18 05:53:12 UTC
class
LavinMQ::
MQTT::
Brokers
LavinMQ::MQTT::Brokers
Reference
Object
Included Modules
LavinMQ::Observer
(
LavinMQ::VHostStore::Event
)
Defined in:
lavinmq/mqtt/brokers.cr
Constructors
.new
(vhosts : VHostStore, replicator : Clustering::Replicator)
Instance Method Summary
#[]?
(vhost : String) : Broker | Nil
#on
(event : VHostStore::Event, data : Object | Nil)
Instance methods inherited from module
LavinMQ::Observer
(
LavinMQ::VHostStore::Event
)
on(event : EventT, data : Object | Nil)
on
Constructor Detail
def self.
new
(vhosts :
VHostStore
, replicator :
Clustering::Replicator
)
#
[
View source
]
Instance Method Detail
def
[]?
(vhost : String) :
Broker
| Nil
#
[
View source
]
def
on
(event :
VHostStore::Event
, data : Object | Nil)
#
[
View source
]