LavinMQ
str = "my/example/string" it = StringTokenIterator.new(str, '/') while substr = it.next puts substr end outputs: my example string
Note that "empty" parts will also be returned str = "/" will result in two "" str "a//b" will result in "a", "" and "b"
Constants
BUILD_INFO = "LavinMQ #{VERSION}\n#{Crystal::DESCRIPTION.lines.reject(&.empty?).join("\n")}\nBuild flags: #{build_flags}"
Log = ::Log.for("lmq")
VERSION = {{ (`[ -n \"$version\" ] && echo \"$version\" || git describe --tags 2>/dev/null || shards version`).chomp.stringify.gsub(/^v/, "") }}
Macros
build_flags
SourceNested types
- LavinMQ::AMQP
- LavinMQ::AcceptLoop
- LavinMQ::Auth
- LavinMQ::BytesMessage
- LavinMQ::Client
- LavinMQ::Clustering
- LavinMQ::Config
- LavinMQ::ConnectionFactory
- LavinMQ::ConnectionInfo
- LavinMQ::ConnectionStore
- LavinMQ::ConsistentHashAlgorithm
- LavinMQ::DataDirLock
- LavinMQ::Deduplication
- LavinMQ::DefinitionsImporter
- LavinMQ::DefinitionsStore
- LavinMQ::DeletedVHostStats
- LavinMQ::DirectReplyConsumerStore
- LavinMQ::Envelope
- LavinMQ::Error
- LavinMQ::Etcd
- LavinMQ::EventType
- LavinMQ::Exchange
- LavinMQ::Federation
- LavinMQ::FileSystem
- LavinMQ::GCPauseRecorder
- LavinMQ::GlobalDefinitions
- LavinMQ::HTTP
- LavinMQ::IPMatcher
- LavinMQ::JournalLogFormat
- LavinMQ::Launcher
- LavinMQ::Logger
- LavinMQ::MQTT
- LavinMQ::Message
- LavinMQ::MessageStore
- LavinMQ::MinHeap(T)
- LavinMQ::OperatorPolicy
- LavinMQ::OutdatedSchemaVersion
- LavinMQ::Parameter
- LavinMQ::ParameterId
- LavinMQ::ParameterStore(T)
- LavinMQ::ParameterTarget
- LavinMQ::Persister
- LavinMQ::Pidfile
- LavinMQ::Policy
- LavinMQ::PolicyTarget
- LavinMQ::Protocol
- LavinMQ::ProtocolServer
- LavinMQ::ProxyProtocol
- LavinMQ::Queue
- LavinMQ::QueueFactory
- LavinMQ::QueueState
- LavinMQ::RateLimiter
- LavinMQ::SNIHost
- LavinMQ::SNIManager
- LavinMQ::Schema
- LavinMQ::SchemaVersion
- LavinMQ::SegmentPosition
- LavinMQ::Server
- LavinMQ::Shovel
- LavinMQ::SortableJSON
- LavinMQ::StandaloneRunner
- LavinMQ::Stats
- LavinMQ::StdoutLogFormat
- LavinMQ::Tag
- LavinMQ::UnackedMessage
- LavinMQ::UnsupportedSchemaVersion
- LavinMQ::VHost
- LavinMQ::VHostDefinitions
- LavinMQ::VHostStore
- LavinMQ::WebSocketHandler
- LavinMQ::WebSocketIO
- LavinMQ::WebsocketProxy