jrask · June 17, 2016 04:55
diff --git a/lumbermill-grok-sample.groovy b/lumbermill-grok-sample.groovy
 package lumbermill

 import lumbermill.api.Codecs
 import rx.Observable

 import static lumbermill.Core.*

 // Simply replace with correct contents and play around
 Observable.just(Codecs.TEXT_TO_JSON.from('Hello World'))
    .flatMap (
        grok.parse (
            field        : 'message',
            pattern      : '%{NUMBER:notexisting}',
            tagOnFailure : true,
            tag          : 'myCustomFailureTag')
        )
        .doOnNext(console.stdout())
        .subscribe()
	package lumbermill

	import lumbermill.api.Codecs
	import rx.Observable

	import static lumbermill.Core.*

	// Simply replace with correct contents and play around
	Observable.just(Codecs.TEXT_TO_JSON.from('Hello World'))
	.flatMap (
	grok.parse (
	field : 'message',
	pattern : '%{NUMBER:notexisting}',
	tagOnFailure : true,
	tag : 'myCustomFailureTag')
	)
	.doOnNext(console.stdout())
	.subscribe()