LavinMQ::VHost

Each policy change spawns its own run, and runs can overlap. Each run takes a generation along with its snapshot of the policies, and a resource skips a run older than the newest one it has applied, so a run that read the policies before a later change can't overwrite that change's run. No lock is held while applying: applying a policy can take other locks, e.g. a delayed-message policy registers a queue.

Like stats_details but without log

Flush definitions written with fsync: false (e.g. during bulk import).

Appends a String representation of this object which includes its class name, its object address and the values of all instance variables.

class Person
  def initialize(@name : String, @age : Int32)
  end
end

Person.new("John", 32).inspect # => #<Person:0x10fd31f20 @name="John", @age=32>

Routing index for MQTT publishes. Owned by the vhost so that it exists before definitions replay; entries are sessions and x-mqtt-topic exchanges.

Routes a message through the named exchange. Returns an AMQP::Exchange::PublishResult describing whether the message was routed to at least one queue, and whether any matched queue rejected it due to a reject-publish overflow policy. As long as at least one queue rejects the publish, the caller should NACK the publisher on confirm channels, even if other queues accepted the message (behaviour confirmed with RabbitMQ). The position of the msg.body_io should be at the start of the body When this method finishes, the position will be the same, start of the body

Persist the policy/operator-policy/parameter stores; used to flush after a bulk import that created entries with save: false.