class Bus

• Bus
• Reference
• Object

Overview

A Bus sends messages to interested subscribers. Those subscribers can reply to a message. Those replies will be routed back to the original sender.

Defined in:

bus.cr
bus/confidence.cr
bus/evaluation.cr
bus/handler.cr
bus/message.cr
bus/pipeline.cr
bus/version.cr

Constant Summary

VERSION = "0.1.1"

Constructors

• .new

Instance Method Summary

• #has_subscription?(key)
• #message(body : Array(String) | String, origin : String | Nil = nil, tags : Array(String) = [] of String, parameters : Hash(String, String) = Hash(String, String).new, strategy : Message::Strategy = Message::Strategy::RandomWinner)

  Generate a message for this bus.

• #origin_tag

  Generate a random UUID that does not already exist in the subscriptions.

• #pipeline : Pipeline(Message)
• #send(body : Array(String) | String, origin : String | Nil = nil, tags : Array(String) = [] of String, parameters : Hash(String, String) = Hash(String, String).new, strategy : Message::Strategy = Message::Strategy::RandomWinner)
• #send(message : Message)

  Send a message to the subscribers

• #subscribe(tags = [] of String)

  Subscribe a new message consumer to the Bus

• #subscriptions : SplayTreeMap(String, Hash(Pipeline(Message), Bool))

  As of Crystal 1.0.0, using Hashes here is faster in single threaded release mode, but it fails UGLY in multithreaded release mode.

• #unsubscribe(pipeline)

  Remove a message consumer from the Bus

Constructor Detail

Instance Method Detail