Module: Consumer::Postgres::Correlation

Defined in:
lib/consumer/postgres/postgres.rb

Constant Summary collapse

Error = 
Class.new(RuntimeError)

Class Method Summary collapse

Class Method Details

.assure(correlation) ⇒ Object 



87
88
89
90
91
 
# File 'lib/consumer/postgres/postgres.rb', line 87

def self.assure(correlation)
  unless MessageStore::StreamName.category?(correlation)
    raise Correlation::Error, "Correlation must be a category (Correlation: #{correlation})"
  end
end