json - hbc Twitter4jStatusClient で未加工の json 文字列を保存する

Question

Sample Stream からのツイートをデータベースに保存し、同時に生の json を保存しようとしています。hbc Github リポジトリの例Twitter4jStatusClientに従って使用しています。情報のサブセットのみをリアルタイムでデータベースに保存しているので、必要なときに追加情報を取得できるように、ツイートの未加工の json も保存したいと考えています。ただし、使用するとは、リスナーが別のスレッドで実行されることを意味し、ここでは、json オブジェクトを取得するには、json オブジェクトを取得したのと同じスレッドから実行する必要があることを示しています。使用時にjson文字列を保存する方法はありますか? この例は使用しないことにしましたTwitter4jStatusClientTwitter4JStatusClient特定のアクションのみを実行し、ステータスの場合はjson文字列を保存したかったためです。ありがとう！

    // Create an appropriately sized blocking queue
    BlockingQueue<String> queue = new LinkedBlockingQueue<String>(10000);

    // Define our endpoint: By default, delimited=length is set (we need this for our processor)
    // and stall warnings are on.
    StatusesSampleEndpoint endpoint = new StatusesSampleEndpoint();
    // Specify the language filter for the endpoint
    endpoint.addQueryParameter(Constants.LANGUAGE_PARAM, Joiner.on(',').join(Lists.newArrayList("en")));
    endpoint.stallWarnings(false);

    Authentication auth = new OAuth1(consumerKey, consumerSecret, token, secret);

    // Create a new BasicClient. By default gzip is enabled.
    BasicClient client = new ClientBuilder()
            .name("sampleStreamClient")
            .hosts(Constants.STREAM_HOST)
            .endpoint(endpoint)
            .authentication(auth)
            .processor(new StringDelimitedProcessor(queue))
            .build();

    // Create an executor service which will spawn threads to do the actual work of parsing the incoming messages and
    // calling the listeners on each message
    int numProcessingThreads = 4;
    ExecutorService service = Executors.newFixedThreadPool(numProcessingThreads);


    StatusListener listener = new SampleStreamStatusListener(jsonInserter);

    // Wrap our BasicClient with the twitter4j client
    t4jClient = new Twitter4jStatusClient(
            client, queue, Lists.newArrayList(listener), service);