@Override
	public void run() {
		MongoClient mongoClient = null;

		// First verify there is stuff to work with - this is hiding the bug
		// that this thread should not start unless the data is good to go
		if ((myDb == null) || (myCollection == null) || (myFilter == null)) {
			return;
		}

		try {
			// TODO - more of the connection details could be applied here
			// Establish connection
			mongoClient = new MongoClient(myConnection.getHost());

			// Get the DB data
			DB db = mongoClient.getDB(myDb);
			DBCollection collection = db.getCollection(myCollection);
			DBCursor cursor = collection.find(myFilter);

			// Publish data
			while ((!isInterrupted()) && (cursor.hasNext())) {
				String document = cursor.next().toString();
				myTwitterThread.update(null, document);
			}

		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			// close db connection
			if (mongoClient != null) {
				mongoClient.close();
			}
		}
	}