import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.bson.Document;

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

public class PressureTest {
	public static void main(String[] args) {
		ExecutorService executor = Executors.newFixedThreadPool(100);
		for (int i = 0; i < 100; i++) {
			Runnable worker = new WorkerThread();
			executor.execute(worker);
		}
	}
}

class WorkerThread implements Runnable {

	@Override
	public void run() {
		System.setProperty("javax.net.ssl.trustStore",
				"C:/ssl/atlas-truststore.ts");
		System.setProperty("javax.net.ssl.trustStorePassword", "password");
		while (true) {
			insert();
			hangup();
		}
	}

	private void hangup() {
		try {
			Thread.sleep(60000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}

	private void insert() {
		MongoClient client = null;
		try {
			if (client == null) {
				client = new MongoClient(new MongoClientURI(
						"mongodb://192.168.244.193:27017/atlas?ssl=true&sslInvalidHostNameAllowed=true"));
			}
			MongoDatabase db = client.getDatabase("atlas");
			MongoCollection<Document> collection = db.getCollection("operating_data");
				document.put("serialNumber", Thread.currentThread().getName());
			document.put("timestamp", new Date());
			document.put("FWver", "01.00.00");
			document.put("HWver", "03");
			document.put("harmonizerModel", "String");
			document.put("bypassTap1", "00.0");
			document.put("lowTap", "00.00");
			document.put("medTap", "00.00");
			document.put("highTap", "00.00");
			document.put("id", 0);
			document.put("msg", "Message string");
			collection.insertOne(document);
		} catch (Exception e) {
		} finally {
			if (client != null) {
				client.close();
			}
		}
	}
}