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(new Envelope(envelope.getMessage(), "documents"));
    }

}

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);
    }

}

--- 
+++ 
@@ -13,7 +13,7 @@
     @Override
     public void process(Envelope envelope, SystemProducer producer) {
         // [TODO] For now, just pass the envelope straight along
-        producer.send(envelope);
+        producer.send(new Envelope(envelope.getMessage(), "documents"));
     }
 
 }
Send envelope in solr task to right topic
