struct Bus::Message

Defined in:

bus/message.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(pipeline : Pipeline(Message) | Nil = nil, body : Array(String) = [""], tags : Array(String) = [] of String, parameters : Hash(String, String) = Hash(String, String).new, origin : String | Nil = nil, uuid : CSUUID = CSUUID.new, strategy : Strategy = Strategy::RandomWinner) #

[View source]
def self.new(bus : Bus, body : Array(String) = [""], tags : Array(String) = [] of String, parameters : Hash(String, String) = Hash(String, String).new, origin : String | Nil = nil, uuid : CSUUID = CSUUID.new, strategy : Strategy = Strategy::RandomWinner) #

[View source]
def self.new(body : String, pipeline : Pipeline(Message) | Nil = nil, tags : Array(String) = [] of String, parameters : Hash(String, String) = Hash(String, String).new, origin : String | Nil = nil, uuid : CSUUID = CSUUID.new, strategy : Strategy = Strategy::RandomWinner) #

[View source]
def self.new(bus : Bus, body : String, tags : Array(String) = [] of String, parameters : Hash(String, String) = Hash(String, String).new, origin : String | Nil = nil, uuid : CSUUID = CSUUID.new, strategy : Strategy = Strategy::RandomWinner) #

[View source]

Instance Method Detail

def body : Array(String) #

[View source]
def evaluated : Bool #

[View source]
def evaluated=(evaluated : Bool) #

[View source]
def origin : String | Nil #

[View source]
def parameters : Hash(String, String) #

[View source]
def pipeline : Pipeline(Message) | Nil #

[View source]
def pipeline=(pipeline : Pipeline(Message) | Nil) #

[View source]
def reply(message : Message) #

[View source]
def reply(body : String = "", parameters : Hash(String, String) = Hash(String, String).new, tags : Array(String) = [] of String) #

[View source]
def reply(body : Array(String) = [""], parameters : Hash(String, String) = Hash(String, String).new, tags : Array(String) = [] of String) #

[View source]
def send_evaluation(receiver, relevance = 0, certainty = 0, force = nil, uuid = @uuid) #

[View source]
def strategy : Strategy #

[View source]
def tags : Array(String) #

[View source]
def uuid : CSUUID #

[View source]