Fixes #33 - Adds middleware support #71

theanirudhvyas · 2019-07-08T11:00:03Z

This PR will make the Deadset View API unusable. Users will still be able to fetch the messages, but these messages will be serialized.

…ssed

src/ziggurat/middleware/default.clj

src/ziggurat/mapper.clj

src/ziggurat/messaging/consumer.clj

theanirudhvyas added 9 commits July 1, 2019 15:29

Moves proto->hash to default middlewares

6349664

Wraps message received from kafka in a message-payload

f2a8f92

Updates dead_set to use message_payload instead of message

19126ec

Changes indentation in accordance with cljfmt

ce83420

Fixes consumer tests

6851943

Adds retry-count to message-payload only when retry is enabled

35ce97f

Adds logic for support of old rabbitMQ messages

c774d17

Adds topic-entity to message-payload

4e180a1

removes topic-entity as message arg where message-payload is being pa…

5c0e744

…ssed

macalimlim reviewed Jul 10, 2019

View reviewed changes

src/ziggurat/middleware/default.clj Outdated Show resolved Hide resolved

src/ziggurat/mapper.clj Show resolved Hide resolved

mjayprateek reviewed Jul 10, 2019

View reviewed changes

src/ziggurat/messaging/consumer.clj Show resolved Hide resolved

theanirudhvyas added 3 commits July 10, 2019 12:47

Refactors code, moves consumer/close to utils

104be9e

Makes message_payload a Clojure record

56e435c

Passes nil to handler-fn if message deserialization fails in middleware

90ac6c0

theanirudhvyas force-pushed the master branch from 0988b5e to 90ac6c0 Compare July 10, 2019 09:14

theanirudhvyas added 4 commits July 10, 2019 16:09

Removes proto-class dependency from config and references from readme

c194218

Adds documentation for middleware support to readme and adds changelog

17321b0

Merge branch 'master' into master

dbefff4

Refactors default middleware proto->hash

661652e

theanirudhvyas merged commit ba170c2 into gojek:master Jul 10, 2019

Provide feedback