File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -424,7 +424,7 @@ class ActiveState {
424
424
ActiveState (final OutMessage outMessage ) {
425
425
namespace = outMessage .getNamespace ();
426
426
opCode = outMessage .getOpCode ();
427
- query = outMessage .getQuery () != null ? outMessage . getQuery (). toString () : null ;
427
+ query = outMessage .getQuery ();
428
428
numDocuments = outMessage .getNumDocuments ();
429
429
this .startTime = System .nanoTime ();
430
430
this .threadName = Thread .currentThread ().getName ();
@@ -438,7 +438,7 @@ OutMessage.OpCode getOpCode() {
438
438
return opCode ;
439
439
}
440
440
441
- String getQuery () {
441
+ DBObject getQuery () {
442
442
return query ;
443
443
}
444
444
@@ -456,7 +456,7 @@ String getThreadName() {
456
456
457
457
private final String namespace ;
458
458
private final OutMessage .OpCode opCode ;
459
- private final String query ;
459
+ private final DBObject query ;
460
460
private int numDocuments ;
461
461
private final long startTime ;
462
462
private final String threadName ;
Original file line number Diff line number Diff line change @@ -41,7 +41,7 @@ public class InUseConnectionBean {
41
41
durationMS = TimeUnit .NANOSECONDS .toMillis (currentNanoTime - activeState .getStartTime ());
42
42
namespace = activeState .getNamespace ();
43
43
opCode = activeState .getOpCode ();
44
- query = activeState .getQuery ();
44
+ query = activeState .getQuery (). toString () ;
45
45
threadName = activeState .getThreadName ();
46
46
numDocuments = activeState .getNumDocuments ();
47
47
}
You can’t perform that action at this time.
0 commit comments