Sha256: c5f586bbbd0c077203307e8b7f2ac24b0a538c4cda6c08aa6be6f745646d6ed3
Contents?: true
Size: 245 Bytes
Versions: 27
Compression:
Stored size: 245 Bytes
Contents
# frozen_string_literal: true class ProducingConsumer < Racecar::Consumer subscribes_to "messages", start_from_beginning: false def process(message) value = message.value.reverse produce value, topic: "reverse-messages" end end
Version data entries
27 entries across 27 versions & 1 rubygems