return knockKnockResult;
}
- public MessageCapturingFlowService setKnockKnockResult(final ListenableFuture<RpcResult<KnockKnockOutput>> kkOutput) {
+ public MessageCapturingFlowService setKnockKnockResult(
+ final ListenableFuture<RpcResult<KnockKnockOutput>> kkOutput) {
this.knockKnockResult = kkOutput;
return this;
}
registration.close();
}
- public MessageCapturingFlowService registerPath(final Class<? extends BaseIdentity> context, final InstanceIdentifier<?> path) {
+ public MessageCapturingFlowService registerPath(final Class<? extends BaseIdentity> context,
+ final InstanceIdentifier<?> path) {
registration.registerPath(context, path);
return this;
}
- public MessageCapturingFlowService unregisterPath(final Class<? extends BaseIdentity> context, final InstanceIdentifier<?> path) {
+ public MessageCapturingFlowService unregisterPath(final Class<? extends BaseIdentity> context,
+ final InstanceIdentifier<?> path) {
registration.unregisterPath(context, path);
return this;
}
receivedKnocks.put(input.getKnockerId(), input);
return knockKnockResult;
}
-
-
}