@Test public void ensureNoIdentityResolverBoundWhenNoOperations() { commandProcessor.onCougarStart(); verify(ev, times(0)).registerOperation(JsonRpcTransportCommandProcessor.IDENTITY_RESOLUTION_NAMESPACE, JsonRpcTransportCommandProcessor.IDENTITY_RESOLUTION_OPDEF, JsonRpcTransportCommandProcessor.IDENTITY_RESOLUTION_EXEC, JsonRpcTransportCommandProcessor.IDENTITY_RESOLUTION_TIMING_RECORDER, 0); }
@Override public void onCougarStart() { boolean operationsBound = false; for (ServiceBindingDescriptor bindingDescriptor : getServiceBindingDescriptors()) { for (OperationBindingDescriptor opDesc : bindingDescriptor.getOperationBindings()) { if (bindOperation(getOperationDefinition(opDesc.getOperationKey()))) { operationsBound = true; } } } if (operationsBound) { getExecutionVenue().registerOperation(IDENTITY_RESOLUTION_NAMESPACE,IDENTITY_RESOLUTION_OPDEF,IDENTITY_RESOLUTION_EXEC, IDENTITY_RESOLUTION_TIMING_RECORDER, 0); } }
JsonRpcTransportCommandProcessor extends AbstractHttpCommandProcessor<Void> { @Override public void onCougarStart() { boolean operationsBound = false; for (ServiceBindingDescriptor bindingDescriptor : getServiceBindingDescriptors()) { for (OperationBindingDescriptor opDesc : bindingDescriptor.getOperationBindings()) { if (bindOperation(getOperationDefinition(opDesc.getOperationKey()))) { operationsBound = true; } } } if (operationsBound) { getExecutionVenue().registerOperation(IDENTITY_RESOLUTION_NAMESPACE,IDENTITY_RESOLUTION_OPDEF,IDENTITY_RESOLUTION_EXEC, IDENTITY_RESOLUTION_TIMING_RECORDER, 0); } } }
JsonRpcTransportCommandProcessor extends AbstractHttpCommandProcessor<Void> { @Override public void onCougarStart() { boolean operationsBound = false; for (ServiceBindingDescriptor bindingDescriptor : getServiceBindingDescriptors()) { for (OperationBindingDescriptor opDesc : bindingDescriptor.getOperationBindings()) { if (bindOperation(getOperationDefinition(opDesc.getOperationKey()))) { operationsBound = true; } } } if (operationsBound) { getExecutionVenue().registerOperation(IDENTITY_RESOLUTION_NAMESPACE,IDENTITY_RESOLUTION_OPDEF,IDENTITY_RESOLUTION_EXEC, IDENTITY_RESOLUTION_TIMING_RECORDER, 0); } } JsonRpcTransportCommandProcessor(DehydratedExecutionContextResolution contextResolution, String requestTimeoutHeader, ObjectMapper mapper);  JsonRpcTransportCommandProcessor(DehydratedExecutionContextResolution contextResolution, String requestTimeoutHeader, JSONBindingFactory jsonBindingFactory); }
JsonRpcTransportCommandProcessor extends AbstractHttpCommandProcessor<Void> { @Override public void onCougarStart() { boolean operationsBound = false; for (ServiceBindingDescriptor bindingDescriptor : getServiceBindingDescriptors()) { for (OperationBindingDescriptor opDesc : bindingDescriptor.getOperationBindings()) { if (bindOperation(getOperationDefinition(opDesc.getOperationKey()))) { operationsBound = true; } } } if (operationsBound) { getExecutionVenue().registerOperation(IDENTITY_RESOLUTION_NAMESPACE,IDENTITY_RESOLUTION_OPDEF,IDENTITY_RESOLUTION_EXEC, IDENTITY_RESOLUTION_TIMING_RECORDER, 0); } } JsonRpcTransportCommandProcessor(DehydratedExecutionContextResolution contextResolution, String requestTimeoutHeader, ObjectMapper mapper);  JsonRpcTransportCommandProcessor(DehydratedExecutionContextResolution contextResolution, String requestTimeoutHeader, JSONBindingFactory jsonBindingFactory); @Override void onCougarStart(); boolean bindOperation(OperationDefinition operationDefinition); @Override void process(HttpCommand command); @Override void writeErrorResponse(HttpCommand command, DehydratedExecutionContext context, CougarException error, boolean traceStarted); boolean writeResponseIfComplete(HttpCommand command, DehydratedExecutionContext context, boolean isBatch, List<JsonRpcRequest> requests, List<JsonRpcResponse> responses, long bytesRead, Tracer tracer); }
JsonRpcTransportCommandProcessor extends AbstractHttpCommandProcessor<Void> { @Override public void onCougarStart() { boolean operationsBound = false; for (ServiceBindingDescriptor bindingDescriptor : getServiceBindingDescriptors()) { for (OperationBindingDescriptor opDesc : bindingDescriptor.getOperationBindings()) { if (bindOperation(getOperationDefinition(opDesc.getOperationKey()))) { operationsBound = true; } } } if (operationsBound) { getExecutionVenue().registerOperation(IDENTITY_RESOLUTION_NAMESPACE,IDENTITY_RESOLUTION_OPDEF,IDENTITY_RESOLUTION_EXEC, IDENTITY_RESOLUTION_TIMING_RECORDER, 0); } } JsonRpcTransportCommandProcessor(DehydratedExecutionContextResolution contextResolution, String requestTimeoutHeader, ObjectMapper mapper);  JsonRpcTransportCommandProcessor(DehydratedExecutionContextResolution contextResolution, String requestTimeoutHeader, JSONBindingFactory jsonBindingFactory); @Override void onCougarStart(); boolean bindOperation(OperationDefinition operationDefinition); @Override void process(HttpCommand command); @Override void writeErrorResponse(HttpCommand command, DehydratedExecutionContext context, CougarException error, boolean traceStarted); boolean writeResponseIfComplete(HttpCommand command, DehydratedExecutionContext context, boolean isBatch, List<JsonRpcRequest> requests, List<JsonRpcResponse> responses, long bytesRead, Tracer tracer);  }