@@ -555,25 +555,25 @@ public async Task ServerEventSubscribeLoadTestAsync()
555555 // Build an event filter for the base event type.
556556 var eventFilter = new EventFilter ( ) ;
557557 eventFilter . AddSelectClause (
558- ObjectTypes . BaseEventType ,
558+ ObjectTypeIds . BaseEventType ,
559559 QualifiedName . From ( BrowseNames . EventId ) ) ;
560560 eventFilter . AddSelectClause (
561- ObjectTypes . BaseEventType ,
561+ ObjectTypeIds . BaseEventType ,
562562 QualifiedName . From ( BrowseNames . EventType ) ) ;
563563 eventFilter . AddSelectClause (
564- ObjectTypes . BaseEventType ,
564+ ObjectTypeIds . BaseEventType ,
565565 QualifiedName . From ( BrowseNames . SourceNode ) ) ;
566566 eventFilter . AddSelectClause (
567- ObjectTypes . BaseEventType ,
567+ ObjectTypeIds . BaseEventType ,
568568 QualifiedName . From ( BrowseNames . SourceName ) ) ;
569569 eventFilter . AddSelectClause (
570- ObjectTypes . BaseEventType ,
570+ ObjectTypeIds . BaseEventType ,
571571 QualifiedName . From ( BrowseNames . Time ) ) ;
572572 eventFilter . AddSelectClause (
573- ObjectTypes . BaseEventType ,
573+ ObjectTypeIds . BaseEventType ,
574574 QualifiedName . From ( BrowseNames . Message ) ) ;
575575 eventFilter . AddSelectClause (
576- ObjectTypes . BaseEventType ,
576+ ObjectTypeIds . BaseEventType ,
577577 QualifiedName . From ( BrowseNames . Severity ) ) ;
578578
579579 // Monitor the Server node for events.
@@ -591,9 +591,9 @@ public async Task ServerEventSubscribeLoadTestAsync()
591591 Interlocked . Add ( ref eventsReceived , notification . Events . Count ) ;
592592 foreach ( EventFieldList fieldList in notification . Events )
593593 {
594- if ( fieldList . EventFields . Count > 4 && fieldList . EventFields [ 4 ] . Value is DateTime eventTime )
594+ if ( fieldList . EventFields . Count > 4 && fieldList . EventFields [ 4 ] . TryGet ( out DateTimeUtc eventTime ) )
595595 {
596- TimeSpan delay = DateTime . UtcNow - eventTime . ToUniversalTime ( ) ;
596+ TimeSpan delay = DateTime . UtcNow - ( ( DateTime ) eventTime ) . ToUniversalTime ( ) ;
597597 Interlocked . Add ( ref totalDelayTicks , delay . Ticks ) ;
598598 }
599599 }
0 commit comments