Class: Cosmo::Stream::Data

Inherits:

Object

Object
Cosmo::Stream::Data

show all

Defined in:: lib/cosmo/stream/data.rb

Constant Summary collapse

DEFAULTS =

{
  batch_size: 100,
  fetch_timeout: 10.0,
  consumer: {
    ack_policy: "explicit",
    max_deliver: 1,
    max_ack_pending: 3,
    ack_wait: 30,
    subjects: ["%{name}.>"]
  },
  publisher: { subject: "%{name}.default", serializer: nil }
}.freeze