@Test public void successful() { this.objectNameConsumer.consume(this.operation); doVerify(); }
@Subscribe public void consume(final Pair<Request, Response> operation) { checkNotNull(operation); final Request request = operation.getKey(); final Response response = operation.getValue(); if (this.operation != request.getOperation()) { return; } if (request.getMethod() != HttpUtil.toMethod(request.getOperation())) { return; } if (!this.statusCodes.contains(response.getStatusCode())) { return; } if (request.getContext().containsKey(Context.X_OG_SEQUENTIAL_OBJECT_NAME)) { return; } if (this.operation != Operation.MULTI_DELETE) { final String objectString = getObjectString(request, response); if (objectString == null) { throw new IllegalStateException("Unable to determine object"); } } updateObjectManager(request, response); }
AbstractObjectNameConsumer { @Subscribe public void consume(final Pair<Request, Response> operation) { checkNotNull(operation); final Request request = operation.getKey(); final Response response = operation.getValue(); if (this.operation != request.getOperation()) { return; } if (request.getMethod() != HttpUtil.toMethod(request.getOperation())) { return; } if (!this.statusCodes.contains(response.getStatusCode())) { return; } if (request.getContext().containsKey(Context.X_OG_SEQUENTIAL_OBJECT_NAME)) { return; } if (this.operation != Operation.MULTI_DELETE) { final String objectString = getObjectString(request, response); if (objectString == null) { throw new IllegalStateException("Unable to determine object"); } } updateObjectManager(request, response); } }
AbstractObjectNameConsumer { @Subscribe public void consume(final Pair<Request, Response> operation) { checkNotNull(operation); final Request request = operation.getKey(); final Response response = operation.getValue(); if (this.operation != request.getOperation()) { return; } if (request.getMethod() != HttpUtil.toMethod(request.getOperation())) { return; } if (!this.statusCodes.contains(response.getStatusCode())) { return; } if (request.getContext().containsKey(Context.X_OG_SEQUENTIAL_OBJECT_NAME)) { return; } if (this.operation != Operation.MULTI_DELETE) { final String objectString = getObjectString(request, response); if (objectString == null) { throw new IllegalStateException("Unable to determine object"); } } updateObjectManager(request, response); } AbstractObjectNameConsumer(final ObjectManager objectManager, final Operation operation,
      final Set<Integer> statusCodes); }
AbstractObjectNameConsumer { @Subscribe public void consume(final Pair<Request, Response> operation) { checkNotNull(operation); final Request request = operation.getKey(); final Response response = operation.getValue(); if (this.operation != request.getOperation()) { return; } if (request.getMethod() != HttpUtil.toMethod(request.getOperation())) { return; } if (!this.statusCodes.contains(response.getStatusCode())) { return; } if (request.getContext().containsKey(Context.X_OG_SEQUENTIAL_OBJECT_NAME)) { return; } if (this.operation != Operation.MULTI_DELETE) { final String objectString = getObjectString(request, response); if (objectString == null) { throw new IllegalStateException("Unable to determine object"); } } updateObjectManager(request, response); } AbstractObjectNameConsumer(final ObjectManager objectManager, final Operation operation,
      final Set<Integer> statusCodes); @Subscribe void consume(final Pair<Request, Response> operation); }
AbstractObjectNameConsumer { @Subscribe public void consume(final Pair<Request, Response> operation) { checkNotNull(operation); final Request request = operation.getKey(); final Response response = operation.getValue(); if (this.operation != request.getOperation()) { return; } if (request.getMethod() != HttpUtil.toMethod(request.getOperation())) { return; } if (!this.statusCodes.contains(response.getStatusCode())) { return; } if (request.getContext().containsKey(Context.X_OG_SEQUENTIAL_OBJECT_NAME)) { return; } if (this.operation != Operation.MULTI_DELETE) { final String objectString = getObjectString(request, response); if (objectString == null) { throw new IllegalStateException("Unable to determine object"); } } updateObjectManager(request, response); } AbstractObjectNameConsumer(final ObjectManager objectManager, final Operation operation,
      final Set<Integer> statusCodes); @Subscribe void consume(final Pair<Request, Response> operation);  }