Skip to content
Original file line number Diff line number Diff line change
Expand Up @@ -3551,6 +3551,11 @@ public PulsarCommandSender getCommandSender() {
return commandSender;
}

@VisibleForTesting
public void setCommandSender(PulsarCommandSender commandSender) {
this.commandSender = commandSender;
}

@Override
public void execute(Runnable runnable) {
ctx().channel().eventLoop().execute(runnable);
Expand Down
Loading