<BUG>private final PriorityQueue<WriteHolder> pq = new PriorityQueue<>();private boolean authorised;</BUG><CONTEXT>private final ServerImpl server;private final NetSocket socket;private final Context context;private final DocManager docManager;private final Map<Integer, SubscriptionImpl> subscriptionMap = new ConcurrentHashMap<>();<extra_id_0>private int subSeq;private long writeSeq;private long expectedRespNo;</CONTEXT>
private MewbaseAuthProvider authProvider;private boolean authorised;