--- !ruby/object:Gem::Specification
name: nulogy_message_bus_consumer
version: !ruby/object:Gem::Version
  version: 2.0.1
platform: ruby
authors:
- Nulogy
autorequire:
bindir: bin
cert_chain: []
date: 2023-11-17 00:00:00.000000000 Z
dependencies:
- !ruby/object:Gem::Dependency
  name: activerecord
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '5.1'
  type: :runtime
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '5.1'
- !ruby/object:Gem::Dependency
  name: railties
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '5.1'
  type: :runtime
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '5.1'
- !ruby/object:Gem::Dependency
  name: rdkafka
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '0'
  type: :runtime
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '0'
- !ruby/object:Gem::Dependency
  name: bundler-audit
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 0.7.0.1
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 0.7.0.1
- !ruby/object:Gem::Dependency
  name: dotenv
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 2.7.6
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 2.7.6
- !ruby/object:Gem::Dependency
  name: pg
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 1.2.3
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 1.2.3
- !ruby/object:Gem::Dependency
  name: pry
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '0'
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '0'
- !ruby/object:Gem::Dependency
  name: pry-byebug
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '0'
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - ">="
      - !ruby/object:Gem::Version
        version: '0'
- !ruby/object:Gem::Dependency
  name: rails
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 6.0.3.5
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 6.0.3.5
- !ruby/object:Gem::Dependency
  name: rspec
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - "~>"
      - !ruby/object:Gem::Version
        version: '3.10'
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - "~>"
      - !ruby/object:Gem::Version
        version: '3.10'
- !ruby/object:Gem::Dependency
  name: rspec-json_expectations
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 2.2.0
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 2.2.0
- !ruby/object:Gem::Dependency
  name: rspec-rails
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 4.0.1
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 4.0.1
- !ruby/object:Gem::Dependency
  name: standard
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 0.11.0
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 0.11.0
- !ruby/object:Gem::Dependency
  name: rubocop-rails
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 2.5.2
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 2.5.2
- !ruby/object:Gem::Dependency
  name: rubocop-rspec
  requirement: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 1.38.1
  type: :development
  prerelease: false
  version_requirements: !ruby/object:Gem::Requirement
    requirements:
    - - '='
      - !ruby/object:Gem::Version
        version: 1.38.1
description:
email:
- platform-engineering@nulogy.com
executables: []
extensions: []
extra_rdoc_files: []
files:
- Rakefile
- config/credentials/message-bus-us-east-1.yml.enc
- config/routes.rb
- db/migrate/20200509095105_create_message_bus_processed_messages.rb
- lib/nulogy_message_bus_consumer.rb
- lib/nulogy_message_bus_consumer/clock.rb
- lib/nulogy_message_bus_consumer/config.rb
- lib/nulogy_message_bus_consumer/deployment/ecs.rb
- lib/nulogy_message_bus_consumer/engine.rb
- lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
- lib/nulogy_message_bus_consumer/kafka_utils.rb
- lib/nulogy_message_bus_consumer/lag_tracker.rb
- lib/nulogy_message_bus_consumer/message.rb
- lib/nulogy_message_bus_consumer/null_logger.rb
- lib/nulogy_message_bus_consumer/pipeline.rb
- lib/nulogy_message_bus_consumer/processed_message.rb
- lib/nulogy_message_bus_consumer/steps/commit_on_success.rb
- lib/nulogy_message_bus_consumer/steps/connect_to_message_bus.rb
- lib/nulogy_message_bus_consumer/steps/deduplicate_messages.rb
- lib/nulogy_message_bus_consumer/steps/log_messages.rb
- lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
- lib/nulogy_message_bus_consumer/steps/stream_messages.rb
- lib/nulogy_message_bus_consumer/steps/stream_messages_until_none_are_left.rb
- lib/nulogy_message_bus_consumer/steps/timed_task.rb
- lib/nulogy_message_bus_consumer/tasks/log_consumer_lag.rb
- lib/nulogy_message_bus_consumer/tasks/prune_processed_messages.rb
- lib/nulogy_message_bus_consumer/tasks/supervise_consumer_lag.rb
- lib/nulogy_message_bus_consumer/version.rb
- lib/tasks/engine/message_bus_consumer.rake
- spec/dummy/Rakefile
- spec/dummy/app/assets/config/manifest.js
- spec/dummy/app/assets/stylesheets/application.css
- spec/dummy/app/channels/application_cable/channel.rb
- spec/dummy/app/channels/application_cable/connection.rb
- spec/dummy/app/controllers/application_controller.rb
- spec/dummy/app/helpers/application_helper.rb
- spec/dummy/app/javascript/packs/application.js
- spec/dummy/app/jobs/application_job.rb
- spec/dummy/app/mailers/application_mailer.rb
- spec/dummy/app/models/application_record.rb
- spec/dummy/app/views/layouts/application.html.erb
- spec/dummy/app/views/layouts/mailer.html.erb
- spec/dummy/app/views/layouts/mailer.text.erb
- spec/dummy/bin/rails
- spec/dummy/bin/rake
- spec/dummy/bin/setup
- spec/dummy/config.ru
- spec/dummy/config/application.rb
- spec/dummy/config/boot.rb
- spec/dummy/config/cable.yml
- spec/dummy/config/credentials/message-bus-us-east-1.yml.enc
- spec/dummy/config/database.yml
- spec/dummy/config/environment.rb
- spec/dummy/config/environments/development.rb
- spec/dummy/config/environments/production.rb
- spec/dummy/config/environments/test.rb
- spec/dummy/config/initializers/application_controller_renderer.rb
- spec/dummy/config/initializers/assets.rb
- spec/dummy/config/initializers/backtrace_silencers.rb
- spec/dummy/config/initializers/content_security_policy.rb
- spec/dummy/config/initializers/cookies_serializer.rb
- spec/dummy/config/initializers/filter_parameter_logging.rb
- spec/dummy/config/initializers/inflections.rb
- spec/dummy/config/initializers/message_bus_consumer.rb
- spec/dummy/config/initializers/mime_types.rb
- spec/dummy/config/initializers/wrap_parameters.rb
- spec/dummy/config/locales/en.yml
- spec/dummy/config/puma.rb
- spec/dummy/config/routes.rb
- spec/dummy/config/spring.rb
- spec/dummy/config/storage.yml
- spec/dummy/db/schema.rb
- spec/dummy/log/test.log
- spec/dummy/public/404.html
- spec/dummy/public/422.html
- spec/dummy/public/500.html
- spec/dummy/public/apple-touch-icon-precomposed.png
- spec/dummy/public/apple-touch-icon.png
- spec/dummy/public/favicon.ico
- spec/dummy/tmp/development_secret.txt
- spec/integration/nulogy_message_bus_consumer/auditor_spec.rb
- spec/integration/nulogy_message_bus_consumer/end_to_end_spec.rb
- spec/integration/nulogy_message_bus_consumer/kafka_utils_spec.rb
- spec/integration/nulogy_message_bus_consumer/steps/commit_on_success_spec.rb
- spec/integration/nulogy_message_bus_consumer/steps/connect_to_message_bus_spec.rb
- spec/integration/nulogy_message_bus_consumer/tasks/prune_processed_messages_spec.rb
- spec/integration/nulogy_message_bus_consumer/tasks/supervise_consumer_lag_spec.rb
- spec/integration/test_topic_spec.rb
- spec/spec_helper.rb
- spec/support/kafka.rb
- spec/support/middleware_tap.rb
- spec/support/skip.rb
- spec/support/test_topic.rb
- spec/unit/nulogy_message_bus_consumer/config_spec.rb
- spec/unit/nulogy_message_bus_consumer/lag_tracker.rb
- spec/unit/nulogy_message_bus_consumer/message_spec.rb
- spec/unit/nulogy_message_bus_consumer/pipeline_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/commit_on_success_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/deduplicate_messages_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/log_messages_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/stream_messages_spec.rb
- spec/unit/nulogy_message_bus_consumer/tasks/calculator_spec.rb
- spec/unit/nulogy_message_bus_consumer_spec.rb
homepage: https://github.com/nulogy/message-bus/tree/main/gems/nulogy_message_bus_consumer
licenses: []
metadata:
  allowed_push_host: https://rubygems.org/
post_install_message:
rdoc_options: []
require_paths:
- lib
required_ruby_version: !ruby/object:Gem::Requirement
  requirements:
  - - ">="
    - !ruby/object:Gem::Version
      version: '2.6'
required_rubygems_version: !ruby/object:Gem::Requirement
  requirements:
  - - ">="
    - !ruby/object:Gem::Version
      version: '0'
requirements: []
rubygems_version: 3.2.22
signing_key:
specification_version: 4
summary: Code for accessing the Nulogy Message Bus
test_files:
- spec/dummy/Rakefile
- spec/dummy/app/assets/config/manifest.js
- spec/dummy/app/assets/stylesheets/application.css
- spec/dummy/app/channels/application_cable/channel.rb
- spec/dummy/app/channels/application_cable/connection.rb
- spec/dummy/app/controllers/application_controller.rb
- spec/dummy/app/helpers/application_helper.rb
- spec/dummy/app/javascript/packs/application.js
- spec/dummy/app/jobs/application_job.rb
- spec/dummy/app/mailers/application_mailer.rb
- spec/dummy/app/models/application_record.rb
- spec/dummy/app/views/layouts/application.html.erb
- spec/dummy/app/views/layouts/mailer.html.erb
- spec/dummy/app/views/layouts/mailer.text.erb
- spec/dummy/bin/rails
- spec/dummy/bin/rake
- spec/dummy/bin/setup
- spec/dummy/config/application.rb
- spec/dummy/config/boot.rb
- spec/dummy/config/cable.yml
- spec/dummy/config/credentials/message-bus-us-east-1.yml.enc
- spec/dummy/config/database.yml
- spec/dummy/config/environment.rb
- spec/dummy/config/environments/development.rb
- spec/dummy/config/environments/production.rb
- spec/dummy/config/environments/test.rb
- spec/dummy/config/initializers/application_controller_renderer.rb
- spec/dummy/config/initializers/assets.rb
- spec/dummy/config/initializers/backtrace_silencers.rb
- spec/dummy/config/initializers/content_security_policy.rb
- spec/dummy/config/initializers/cookies_serializer.rb
- spec/dummy/config/initializers/filter_parameter_logging.rb
- spec/dummy/config/initializers/inflections.rb
- spec/dummy/config/initializers/message_bus_consumer.rb
- spec/dummy/config/initializers/mime_types.rb
- spec/dummy/config/initializers/wrap_parameters.rb
- spec/dummy/config/locales/en.yml
- spec/dummy/config/puma.rb
- spec/dummy/config/routes.rb
- spec/dummy/config/spring.rb
- spec/dummy/config/storage.yml
- spec/dummy/config.ru
- spec/dummy/db/schema.rb
- spec/dummy/log/test.log
- spec/dummy/public/404.html
- spec/dummy/public/422.html
- spec/dummy/public/500.html
- spec/dummy/public/apple-touch-icon-precomposed.png
- spec/dummy/public/apple-touch-icon.png
- spec/dummy/public/favicon.ico
- spec/dummy/tmp/development_secret.txt
- spec/integration/nulogy_message_bus_consumer/auditor_spec.rb
- spec/integration/nulogy_message_bus_consumer/end_to_end_spec.rb
- spec/integration/nulogy_message_bus_consumer/kafka_utils_spec.rb
- spec/integration/nulogy_message_bus_consumer/steps/commit_on_success_spec.rb
- spec/integration/nulogy_message_bus_consumer/steps/connect_to_message_bus_spec.rb
- spec/integration/nulogy_message_bus_consumer/tasks/prune_processed_messages_spec.rb
- spec/integration/nulogy_message_bus_consumer/tasks/supervise_consumer_lag_spec.rb
- spec/integration/test_topic_spec.rb
- spec/spec_helper.rb
- spec/support/kafka.rb
- spec/support/middleware_tap.rb
- spec/support/skip.rb
- spec/support/test_topic.rb
- spec/unit/nulogy_message_bus_consumer/config_spec.rb
- spec/unit/nulogy_message_bus_consumer/lag_tracker.rb
- spec/unit/nulogy_message_bus_consumer/message_spec.rb
- spec/unit/nulogy_message_bus_consumer/pipeline_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/commit_on_success_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/deduplicate_messages_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/log_messages_spec.rb
- spec/unit/nulogy_message_bus_consumer/steps/stream_messages_spec.rb
- spec/unit/nulogy_message_bus_consumer/tasks/calculator_spec.rb
- spec/unit/nulogy_message_bus_consumer_spec.rb