private SignalJsonRpcCommandHandler commandHandler;
public SignalJsonRpcDispatcherHandler(
- final JsonWriter jsonWriter, final Supplier<String> lineSupplier, final boolean noReceiveOnStart
+ final JsonWriter jsonWriter,
+ final Supplier<String> lineSupplier,
+ final boolean noReceiveOnStart
) {
this.noReceiveOnStart = noReceiveOnStart;
this.objectMapper = Util.createJsonObjectMapper();
@Override
public void handleCommand(
- final Void request, final Manager m, final JsonWriter jsonWriter
+ final Void request,
+ final Manager m,
+ final JsonWriter jsonWriter
) throws CommandException {
final var subscriptionId = subscribeReceive(m, false);
jsonWriter.write(subscriptionId);
@Override
public void handleCommand(
- final Void request, final MultiAccountManager c, final JsonWriter jsonWriter
+ final Void request,
+ final MultiAccountManager c,
+ final JsonWriter jsonWriter
) throws CommandException {
final var subscriptionId = subscribeReceive(c.getManagers(), false);
jsonWriter.write(subscriptionId);
@Override
public void handleCommand(
- final JsonNode request, final Manager m, final JsonWriter jsonWriter
+ final JsonNode request,
+ final Manager m,
+ final JsonWriter jsonWriter
) throws CommandException {
final var subscriptionId = getSubscriptionId(request);
if (subscriptionId == null) {
@Override
public void handleCommand(
- final JsonNode request, final MultiAccountManager c, final JsonWriter jsonWriter
+ final JsonNode request,
+ final MultiAccountManager c,
+ final JsonWriter jsonWriter
) throws CommandException {
final var subscriptionId = getSubscriptionId(request);
if (subscriptionId == null) {