package com.bloomberg.bask.task;

import com.bloomberg.bask.system.Envelope;
import com.bloomberg.bask.system.SystemProducer;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SolrTask implements StreamTask {

    private static final Logger logger = LoggerFactory.getLogger(SolrTask.class);

    @Override
    public void process(Envelope envelope, SystemProducer producer) {
        // [TODO] For now, just pass the envelope straight along
        producer.send(envelope);
    }

}

@@ -479,24 +479,64 @@
 er.send(
-envelope
+new Envelope(envelope.getMessage(), %22documents%22)
 );%0A    %7D

Send envelope in solr task to right topic