import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBObjectBuilder;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.WriteResult;
import com.mongodb.util.JSON;
import java.net.UnknownHostException;

@EnableBinding(Sink.class)
@SpringBootApplication
public class SinkApplication {

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

    @StreamListener(Sink.INPUT)
    public void loggerSink(String json)throws UnknownHostException {

        logger.info("Received: " + json);

        /*MongoClient mongo = new MongoClient("localhost", 27017);
        DB db = mongo.getDB("sinkdb");
        DBCollection collection = db.getCollection("sinkcollection");
        BasicDBObject blankDocument = new BasicDBObject();
        collection.remove(blankDocument);

        DBObject dbObject = (DBObject)JSON.parse(json);
        collection.insert(dbObject);*/
    }

    public static void main(String[] args) {
        SpringApplication.run(SinkApplication.class, args);
    }
}