search

salesforce / storm-dynamic-spout

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
BSD 3-Clause "New" or "Revised" License
40 stars 13 forks source link

Split out sideline config & persistence #18

Closed stanlemon closed 7 years ago

stanlemon commented 7 years ago

@Crim I'm going to split the persistence adapter over here and double the necessary config too, just FYI - this is a WIP.

stanlemon commented 7 years ago

@Crim Tests are a wreck, and sidelining has broken references still but here's the line I drew. What do you think?

Crim commented 7 years ago

Added a couple tests and tweaked the definition of a couple methods to use generics.