Currently, onTransactionPrepare() ends the transaction, cleans up the buffered statements and writes them down to the oplog. However, an observer should "observe" not "participate" the operation, so the caller should end the transaction, clean up the buffered statements and pass them into the observer.