import twitter4j.*

def oAuthConsumer = "入れる"

def oAuthConsumerSecret = "入れる"

def twitter = new TwitterFactory().getInstance()

twitter.setOAuthConsumer(oAuthConsumer, oAuthConsumerSecret)

def requestToken = twitter.getOAuthRequestToken()

def accessToken = ""

println "ブラウザで以下の URL にアクセスして表示された PIN コードを入力してください。"

println "　${requestToken.getAuthorizationURL()}"

System.in.withReader {

    print "PIN コード: "

    accessToken = twitter.getOAuthAccessToken(requestToken, it.readLine())

}

println "access.token=${accessToken.getToken()}"

println "access.token.secret=${accessToken.getTokenSecret()}"

import twitter4j.*

import twitter4j.conf.*

def consumer = "入れる"

def consumer_secret = "入れる"

def access_token = "入れる"

def access_token_secret = "入れる"

def builder = new ConfigurationBuilder()

builder.setOAuthConsumerKey(consumer)

builder.setOAuthConsumerSecret(consumer_secret)

builder.setOAuthAccessToken(access_token)

builder.setOAuthAccessTokenSecret(access_token_secret)

def config = builder.build()

def twitter = new TwitterFactory(config).getInstance()

def stream =

    new TwitterStreamFactory(config).getInstance(twitter.getOAuthAccessToken())

stream.addListener(new UserStreamAdapter() {

    @Override

    public void onStatus(Status status) {

        def user = status.getUser().getScreenName()

        def text = status.getText()

        println "@${user} ${text}"

    }

})

println "Start streaming..."

stream.user()

System.in.withReader {

    while((line = it.readLine()) && (line=line.trim()));

}

println "Stop streaming and cleanup..."

stream.cleanUp()