A framework for getting Flowlink objects from other sources. For example: class Distributor::Product < Flowlink::Product def sku(hashable) # code that picks sku data out of a hashable object. end end Distributor::Product.new(CSV::Row).to_message #=> A bunch of NotImplementedError because just a sku is an invalid product