Description
JavaDocs for StaticInterceptor need to be updated from this:
- agent.sources.r1.interceptors.i1.type = timestamp
..to this:
- agent.sources.r1.interceptors.i1.type = static
Confirmed successful output by testing with this config file:
agent.channels = c1
agent.sources = r1
agent.sinks = k1
agent.channels.c1.type = MEMORY
agent.sources.r1.channels = c1
agent.sources.r1.type = SEQ
agent.sources.r1.interceptors = i1
agent.sources.r1.interceptors.i1.type = static
agent.sources.r1.interceptors.i1.preserveExisting = false
agent.sources.r1.interceptors.i1.key = datacenter
agent.sources.r1.interceptors.i1.value= NYC_01
agent.sinks.k1.channel = c1
agent.sinks.k1.type = LOGGER
...and some sample output was:
2012-07-17 10:13:17,981 INFO source.SequenceGeneratorSource: Sequence generator source starting
2012-07-17 10:13:17,997 INFO sink.LoggerSink: Event: { headers:
2012-07-17 10:13:17,998 INFO sink.LoggerSink: Event: { headers:{datacenter=NYC_01}
body: 31 1 }
2012-07-17 10:13:17,998 INFO sink.LoggerSink: Event: { headers:
2012-07-17 10:13:17,999 INFO sink.LoggerSink: Event: { headers:{datacenter=NYC_01}
body: 33 3 }
2012-07-17 10:13:17,999 INFO sink.LoggerSink: Event: { headers:
body: 34 4 }
Unless requested, I'll just attach the patch here rather than uploading to ReviewBoard, since it's a very minor update.