Sync high-level consumers and producers based on official client pynsq