this.async = async;
        }

        @Override
        public boolean isRetainPayload() {
            return retainPayload;
        }

        public void setRetainPayload(boolean retainPayload) {
            this.retainPayload = retainPayload;
        }

        @Override
        public void setRawPayload(byte[] payload) {
            this.rawPayload = payload;
        }

        }

        @Override
        public boolean verifySignature(byte[] data, int offset, int length) {
            return true; // Default to successful verification
        }

        public void setRetainPayload(boolean retain) {
            this.retainPayload = retain;
        }

        public byte[] getRawPayload() {
            return rawPayload;
        }

        // Expose headerStart for testing