Исходящий канал MongoDB переопределяет документ в БД

Я использую интеграцию Spring для обновления БД значениями, поступающими в сообщении.

Входящий канал запрашивает базу данных Mongo, набор результатов должен быть обновлен в соответствии со статусом обработки.

Поток работает, но я не получаю ожидаемого поведения.

Я ожидал, что обработчик сообщений, MongoDbStoringMessageHandler, в конечном итоге выполнит обновление, но похоже, что он полностью переопределяет объект в БД с помощью полезной нагрузки сообщения.

В полезной нагрузке есть не все поля, которые присутствуют в БД.

Есть ли какая-то конфигурация, которую мне не хватает? Или это не типичный вариант использования?

Ниже моя конфигурация:

Источник входящего сообщения

@Bean
    public MessageSource mongoMessageSource(MongoDbFactory mongoDbFactory) {
        MongoDbMessageSource mongoDbMessageSource = new MongoDbMessageSource(mongoDbFactory,
                new LiteralExpression(new BasicDBObject("status","test").toString()));
        mongoDbMessageSource.
                setCollectionNameExpression(new LiteralExpression("BankAccountDetail"));
        mongoDbMessageSource.setEntityClass(AccountBalanceDetails.class);
        return mongoDbMessageSource;
    }

Выходной канал для указанного выше источника

@Bean
public IntegrationFlow mongoInboundChannel(MessageSource messageSource) {
    return IntegrationFlows.from(messageSource).
            channel("messageChannel")
            .get();
}

Выходной канал:

@Bean
public MessageChannel messageChannel() {
    return new DirectChannel();
}

Основной поток: -

@Bean
public IntegrationFlow fromDirect(@Qualifier("messageChannel") MessageChannel messageChannel,
                                  AccountBalanceTransformer accountBalanceTransformer,
                                  MongoDbFactory mongoDbFactory, AccountBalanceUpdater accountBalanceUpdater) {
    return IntegrationFlows.from(messageChannel).split().
            handle(accountBalanceUpdater, "update").
            //handle(System.out::println).
            handle(mongoOutput(mongoDbFactory)).
            get();
}

Обработчик исходящего сообщения

@Bean
public MessageHandler mongoOutput(MongoDbFactory mongoDbFactory) {
    MongoDbStoringMessageHandler mongoDbStoringMessageHandler = new MongoDbStoringMessageHandler(mongoDbFactory);
    mongoDbStoringMessageHandler.setCollectionNameExpression(new LiteralExpression("BankAccountDetail"));
    return mongoDbStoringMessageHandler;
}

Вот мой модельный класс: -

@Document(collection = "BankAccountDetail")

открытый класс AccountBalanceDetails {

private String id;
private String status;
private String message;

public String getId() {
    return id;
}

public void setId(String id) {
    this.id = id;
}

public String getStatus() {
    return status;
}

public void setStatus(String status) {
    this.status = status;
}

public String getMessage() {
    return message;
}

public void setMessage(String message) {
    this.message = message;
}

@Override
public String toString() {
    return "AccountBalanceDetails{" +
            "id='" + id + '\'' +
            ", status='" + status + '\'' +
            ", message='" + message + '\'' +
            '}';
}

}