public WheresMyBusServer( int numThreads, int queueSize, String query ) {
        bq = new ArrayBlockingQueue<>( queueSize );
        twitter = TwitterFactory.getSingleton();
        tweetProcWorkers = new ArrayList<>( numThreads );

        for ( int i = 0; i < numThreads; i++ ) {
            tweetProcWorkers.add(
                    new TweetProcWorker( bq, twitter,"ProcWorker #" + i ));
        }

        twitterSearchWorker =
                new TwitterSearchWorker( bq, twitter,"SearchWorker #1", query);

        Logger.log( TAG, "server created." );
    }