add queue synchronization methods, beginEnsureSchema support