Skip to content

Instantly share code, notes, and snippets.

@push-gists
Last active May 5, 2016 09:46
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save push-gists/2a4f855ad1266ef6a4f72e4aa8bfa181 to your computer and use it in GitHub Desktop.
A value stream for maps
public abstract class MapStream extends Topics.ValueStream.Default<Map<String, Object>> {
/**
* Handle any exceptions thrown when parsing the JSON value.
* @param topicName The name of the topic
* @param value The JSON value
* @param e The exception
*/
public abstract void onTransformationException(String topicName, JSON value, Exception e);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment