+ final CompositeNode parsedNotification = messageTransformer.toNotification(cachedNotification);
+ // TODO possible race condition here, because this exception is thrown occasionally
+ Preconditions.checkNotNull(parsedNotification, "Unable to parse received notification %s", cachedNotification);
+ passNotification(parsedNotification);