public void clear() {
<BUG>ClearRequest request = new ClearRequest(name);
invoke(request);</BUG>
}
<BUG>protected <T> T invoke(ClientRequest req) {
</BUG>
return super.invoke(req, getPartitionKey());
}
<BUG>protected <T> T invokeInterruptibly(ClientRequest req) throws InterruptedException {
</BUG>
return super.invokeInterruptibly(req, getPartitionKey());

public void clear() {
ClientMessage request = QueueClearParameters.encode(name);
invoke(request);
}
protected <T> T invoke(ClientMessage req) {
return super.invoke(req, getPartitionKey());
}
protected <T> T invokeInterruptibly(ClientMessage req) throws InterruptedException {
