Skip to content

Instantly share code, notes, and snippets.

@minudika

minudika/HttpRequestResponseSample.siddhi

Created August 7, 2019 17:36
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save minudika/d4ce997ed84ab96b6e8ab4aa7d9f1bfd to your computer and use it in GitHub Desktop.
Save minudika/d4ce997ed84ab96b6e8ab4aa7d9f1bfd to your computer and use it in GitHub Desktop.
Download ZIP
Raw
HttpRequestResponseSample.siddhi
@sink(type='http-request', sink.id='production-alerts',
publisher.url='http://localhost:8080/alerts',
@map(type='json'))
define stream ProductionAlertStream (id string, name string, amount double);
@source(type='http-response' , sink.id='production-alerts', http.status.code='200',
@map(type='json'))
define stream ResponseStream(alertId long, alertMessage string);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment