我正在尝试使用Twitter hbc 库来获取基于位置的推文。我已经根据示例文件设置了我的代码FilterStreamExample。该示例有效，但是当我尝试向端点添加位置时，我收到致命错误代码：406。
这是有效的代码：
StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();
endpoint.trackTerms(Lists.newArrayList("twitterapi", "#yolo"));
但是当我添加以下代码时，我得到了错误：
Coordinate southwest = new Coordinate(-87.648926, 41.883109);
Coordinate northeast = new Coordinate(-87.606354, 41.828050);
Location chicago = new Location(southwest, northeast);
endpoint.locations(Lists.newArrayList(chicago));
谢谢您的帮助！
格雷格
编辑 这是我的全部代码：
public class App {
public static void oauth(String consumerKey, String consumerSecret, String token, String secret) throws InterruptedException {
BlockingQueue<String> queue = new LinkedBlockingQueue<String>(100000);
StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();
Coordinate southwest = new Coordinate(-87.857666, 41.657347);
Coordinate northeast = new Coordinate(-87.587128, 41.795712);
Location chicago = new Location(southwest, northeast);
endpoint.locations(Lists.newArrayList(chicago));
Authentication auth = new OAuth1(consumerKey, consumerSecret, token, secret);
BasicClient client = new ClientBuilder()
.name("exampleStream")
.hosts(Constants.STREAM_HOST)
.endpoint(endpoint)
.authentication(auth)
.processor(new StringDelimitedProcessor(queue))
.build();
// Establish a connection
client.connect();
PrintWriter writer;
try {
writer = new PrintWriter("twitterstream.txt", "UTF-8");
// Do whatever needs to be done with messages
for (int msgRead = 0; msgRead < 1000; msgRead++) {
if (client.isDone()) {
System.out.println("Client connection closed unexpectedly: " + client.getExitEvent().getMessage());
break;
}
String msg = queue.poll(5, TimeUnit.SECONDS);
if (msg == null) {
System.out.println("Did not receive a message in 5 seconds");
} else {
writer.println(msg);
}
}
writer.close();
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
client.stop();
}
public static void main(String[] args) {
try {
App.oauth("LEDrJPDhn6C2trbde95WZg", "gEmlgewUodOoDjMNl2QbcqsbGvYDxNZWNRULchPE", "292576546-SWzEgMU7mC7Haat3lLEOQ0mXsZFwBf8F3ZKLBMVa", "ajPN2rGLx57yPoUjYe2qN4bE763orux4KwYeoCAvuLRPM");
} catch (InterruptedException e) {
System.out.println(e);
}
}