Блог

Я пытаюсь использовать пользовательский диспетчер транзакций с ignite, однако это приводит к невозможности десериализации объекта с заданным загрузчиком классов при запуске. Фабрика диспетчера транзакций реализована как

 public class TransactionManagerFactory implements Factory<TransactionManager> {
private static final long serialVersionUID = 1L;

private TransactionManager txMgr;

public TransactionManagerFactory(TransactionManager txMgr) {
    this.txMgr=txMgr;
}

@Override
public TransactionManager create() {
    return this.txMgr;
}
}
 

Завод привязан к конфигурации клиента следующим образом:

 TransactionConfiguration txConfiguration=new TransactionConfiguration();
txConfiguration.setDeadlockTimeout(acquireTimeout);
txConfiguration.setDefaultTxIsolation(TransactionIsolation.READ_COMMITTED);
txConfiguration.setDefaultTxConcurrency(TransactionConcurrency.PESSIMISTIC);
txConfiguration.setTxManagerFactory(new TransactionManagerFactory(txMgr));           
this.clientConfig.setTransactionConfiguration(txConfiguration);
 

Ошибка говорит, что сам диспетчер транзакций, переданный на завод, не сериализуем:
Вызвано: java.io.NotSerializableException: org.infinispan.transaction.tm.EmbeddedBaseTransactionManager

Однако сам диспетчер транзакций не должен быть сериализуемым. Как мы можем передать существующий диспетчер транзакций клиенту ignite?

Юлиан Ойфа

Ваша фабрика диспетчера транзакций сохраняет экземпляр диспетчера транзакций вместо того, чтобы создавать его в create() методе на удаленном узле. Вот как это должно работать.

Все нестационарные поля сериализуемого объекта также должны быть сериализуемыми.