}
}
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {