Method: Kafka::Message.ensure_snappy!

Defined in:
lib/kafka/message.rb

.ensure_snappy! ⇒ Object 



137
138
139
140
141
142
143
 
# File 'lib/kafka/message.rb', line 137

def self.ensure_snappy!
  if Object.const_defined? "Snappy"
    yield
  else
    fail "Snappy not available!"
  end
end