Module: SharedBroker::Validation

Defined in:
lib/shared_broker/validation.rb

Defined Under Namespace

Classes: ValidationError

Class Method Summary collapse

Class Method Details

.clear ⇒ Object 



20
21
22
23
24
 
# File 'lib/shared_broker/validation.rb', line 20

def self.clear
  SharedBroker::SchemaRegistry.clear_cache
  provider = SharedBroker::SchemaRegistry.provider || SharedBroker::SchemaRegistry.send(:default_provider)
  provider.clear if provider.respond_to?(:clear)
end

.register(topic, schema) ⇒ Object 



7
8
9
10
11
12
13
14
 
# File 'lib/shared_broker/validation.rb', line 7

def self.register(topic, schema)
  provider = SharedBroker::SchemaRegistry.provider || SharedBroker::SchemaRegistry.send(:default_provider)
  if provider.respond_to?(:register)
    provider.register(topic, schema)
  else
    raise RuntimeError, "Current SchemaRegistry provider #{provider.class} does not support local registration. Expected a provider that responds to :register."
  end
end

.validate!(topic, message) ⇒ Object 



16
17
18
 
# File 'lib/shared_broker/validation.rb', line 16

def self.validate!(topic, message)
  SharedBroker::SchemaRegistry.validate!(topic, message)
end