22
33import com .mongodb .client .model .changestream .ChangeStreamDocument ;
44import com .mongodb .client .model .changestream .UpdateDescription ;
5+ import jakarta .annotation .Nonnull ;
56import java .lang .reflect .Type ;
67import java .util .HashSet ;
78import java .util .List ;
89import java .util .Map ;
910import java .util .Set ;
10- import lombok .NonNull ;
1111import org .bson .BsonBinaryWriter ;
1212import org .bson .BsonDocument ;
1313import org .bson .BsonDocumentReader ;
@@ -169,7 +169,7 @@ BsonInt64 getRevisionFromFullDocument(BsonDocument fullDocument) {
169169 return fullDocument .getInt64 (DocumentFields .revision .name (), null );
170170 }
171171
172- @ NonNull MapValue <String > eventDiagnosticAttributesFromFullDocument (BsonDocument fullDocument ) {
172+ @ Nonnull MapValue <String > eventDiagnosticAttributesFromFullDocument (BsonDocument fullDocument ) {
173173 return getOrSetEventDiagnosticAttributes (getDiagnosticAttributesFromFullDocument (fullDocument ));
174174 }
175175
@@ -186,7 +186,7 @@ BsonInt64 getRevisionFromUpdateEvent(ChangeStreamDocument<BsonDocument> event) {
186186 return updatedFields .getInt64 (DocumentFields .revision .name (), null );
187187 }
188188
189- @ NonNull MapValue <String > eventDiagnosticAttributesFromUpdate (ChangeStreamDocument <BsonDocument > event ) {
189+ @ Nonnull MapValue <String > eventDiagnosticAttributesFromUpdate (ChangeStreamDocument <BsonDocument > event ) {
190190 return getOrSetEventDiagnosticAttributes (getDiagnosticAttributesFromUpdateEvent (event ));
191191 }
192192
@@ -214,7 +214,7 @@ static BsonDocument getDiagnosticAttributesIfAny(BsonDocument fullDocument) {
214214 return fullDocument .getDocument (DocumentFields .diagnostics .name (), null );
215215 }
216216
217- @ NonNull private MapValue <String > getOrSetEventDiagnosticAttributes (MapValue <String > fromEvent ) {
217+ @ Nonnull private MapValue <String > getOrSetEventDiagnosticAttributes (MapValue <String > fromEvent ) {
218218 if (fromEvent == null ) {
219219 LOGGER .debug ("No diagnostic attributes in event; assuming they are unchanged" );
220220 return lastEventDiagnosticAttributes ;
0 commit comments