File tree Expand file tree Collapse file tree
src/main/java/fi/hsl/transitdata/pulsarpubtransconnect Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -118,10 +118,10 @@ public Collection<TypedMessageBuilder<byte[]>> handleResultSet(
118118 }
119119
120120 PubtransConnector .closeQuery (resultSet , statement );
121- queryDuration = System .currentTimeMillis () - queryStartTime ;
121+ long queryEndTime = System .currentTimeMillis ();
122+ queryDuration = queryEndTime - queryStartTime ;
122123
123124 for (QueryResultItem queryResultItem : queryResultItems ) {
124- final long resultHandlerStartTime = System .currentTimeMillis ();
125125 final long dvjId = queryResultItem .common .getIsOnDatedVehicleJourneyId ();
126126 final long scheduledJppId = queryResultItem .common .getIsTimetabledAtJourneyPatternPointGid ();
127127 final long targetedJppId = queryResultItem .common .getIsTargetedAtJourneyPatternPointGid ();
@@ -147,8 +147,9 @@ public Collection<TypedMessageBuilder<byte[]>> handleResultSet(
147147 if (queryResultItem .eventTimestampUtcMs > tempTimeStamp ) {
148148 tempTimeStamp = queryResultItem .eventTimestampUtcMs ;
149149 }
150- resultHandlerDuration = System .currentTimeMillis () - resultHandlerStartTime ;
151- queryAndResultHandlerDuration = System .currentTimeMillis () - queryStartTime ;
150+ long endTime = System .currentTimeMillis ();
151+ resultHandlerDuration = endTime - queryEndTime ;
152+ queryAndResultHandlerDuration = endTime - queryStartTime ;
152153 }
153154
154155 log .info ("{} rows processed from the result set. {} rows skipped with metro trips (route ids: {}). "
You can’t perform that action at this time.
0 commit comments