Operation implements Cloneable { public void sendWith(ServiceRequestSender sender) { sender.sendRequest(this); } Operation(); static void fail(Operation request, int statusCode, int errorCode, Throwable e); static void failActionNotSupported(Operation request); static void failLimitExceeded(Operation request, int errorCode, String queueDescription); static void failForwardedRequest(Operation op, Operation fo, Throwable fe); static void failServiceNotFound(Operation inboundOp); static void failServiceNotFound(Operation inboundOp, int errorCode,
            String errorMsg); static void failServiceNotFound(Operation inboundOp, int errorCode); static Operation create(SerializedOperation ctx, ServiceHost host); static Operation createPost(Service sender, String targetPath); static Operation createPost(ServiceHost sender, String targetPath); static Operation createPost(URI uri); static Operation createPatch(Service sender, String targetPath); static Operation createPatch(ServiceHost sender, String targetPath); static Operation createPatch(URI uri); static Operation createPut(Service sender, String targetPath); static Operation createPut(ServiceHost sender, String targetPath); static Operation createPut(URI uri); static Operation createOptions(Service sender, String targetPath); static Operation createOptions(ServiceHost sender, String targetPath); static Operation createOptions(URI uri); static Operation createDelete(Service sender, String targetPath); static Operation createDelete(ServiceHost sender, String targetPath); static Operation createDelete(URI uri); static Operation createGet(Service sender, String targetPath); static Operation createGet(ServiceHost sender, String targetPath); static Operation createGet(URI uri); void sendWith(ServiceRequestSender sender); @Override String toString(); String toLogString(); @Override Operation clone(); boolean isRemote(); Operation forceRemote(); AuthorizationContext getAuthorizationContext(); Operation setAuthorizationContext(AuthorizationContext ctx); String getTransactionId(); Operation setTransactionId(String transactionId); boolean isWithinTransaction(); String getContextId(); Operation setContextId(String id); Operation setBody(Object body); Operation setStatusCode(int code); Operation setBodyNoCloning(Object body); ServiceErrorResponse getErrorResponseBody(); @SuppressWarnings("unchecked") T getBody(Class<T> type); Object getBodyRaw(); long getContentLength(); Operation setContentLength(long l); String getContentType(); Operation setContentType(String type); Operation setCookies(Map<String, String> cookies); Map<String, String> getCookies(); int getRetriesRemaining(); int getRetryCount(); int incrementRetryCount(); Operation setRetryCount(int retryCount); Operation setCompletion(CompletionHandler completion); Operation setCompletion(Consumer<Operation> successHandler,
            CompletionHandler failureHandler); Operation setServerSentEventHandler(Consumer<ServerSentEvent> serverSentEventHandler); Operation nestServerSentEventHandler(Consumer<ServerSentEvent> serverSentEventHandler); Operation setHeadersReceivedHandler(Consumer<Operation> handler); Operation nestHeadersReceivedHandler(Consumer<Operation> handler); CompletionHandler getCompletion(); Operation setUri(URI uri); URI getUri(); Operation setReferer(URI uri); Operation setReferer(String uri); Operation transferRefererFrom(Operation op); boolean hasReferer(); URI getReferer(); String getRefererAsString(); Operation setAction(Action action); Action getAction(); long getId(); Operation setSocketContext(SocketContext socketContext); SocketContext getSocketContext(); long getExpirationMicrosUtc(); Operation setExpiration(long futureMicrosUtc); int getStatusCode(); void complete(); void fail(Throwable e); void sendServerSentEvent(ServerSentEvent event); void sendHeaders(); void startEventStream(); void fail(int statusCode); void fail(int statusCode, Throwable e, Object failureBody); void fail(Throwable e, Object failureBody); boolean hasBody(); Operation nestCompletion(CompletionHandler h); Operation nestCompletionCloneSafe(CompletionHandler h); void nestCompletion(Consumer<Operation> successHandler); Operation appendCompletion(CompletionHandler h); Operation addRequestHeader(String name, String value); Operation addResponseHeader(String name, String value); Operation addResponseCookie(String key, String value); Operation addPragmaDirective(String directive); boolean hasPragmaDirective(String directive); boolean hasAnyPragmaDirective(List<String> directives); Operation removePragmaDirective(String directive); boolean isKeepAlive(); Operation setKeepAlive(boolean isKeepAlive); Operation setConnectionTag(String tag); String getConnectionTag(); Operation toggleOption(OperationOption option, boolean enable); boolean hasOption(OperationOption option); EnumSet<OperationOption> getOptions(); Operation disableFailureLogging(boolean disable); boolean isFailureLoggingDisabled(); Operation setReplicationDisabled(boolean disable); boolean isReplicationDisabled(); Map<String, String> getRequestHeaders(); Map<String, String> getResponseHeaders(); boolean hasResponseHeaders(); boolean hasRequestHeaders(); String getRequestHeader(String headerName); String getRequestHeaderAsIs(String headerName); String getAndRemoveRequestHeaderAsIs(String headerName); String getResponseHeader(String headerName); String getResponseHeaderAsIs(String headerName); String getAndRemoveResponseHeaderAsIs(String headerName); Principal getPeerPrincipal(); X509Certificate[] getPeerCertificateChain(); void setPeerCertificates(Principal peerPrincipal, X509Certificate[] certificates); int decrementRetriesRemaining(); boolean isTargetReplicated(); Operation setFromReplication(boolean isFromReplication); boolean isFromReplication(); Operation setConnectionSharing(boolean enable); boolean isConnectionSharing(); boolean isForwarded(); Operation transferResponseHeadersFrom(Operation op); Operation transferRequestHeadersFrom(Operation op); Operation transferResponseHeadersToRequestHeadersFrom(Operation op); Operation transferRequestHeadersToResponseHeadersFrom(Operation op); boolean isNotification(); Operation setNotificationDisabled(boolean disable); boolean isNotificationDisabled(); boolean isForwardingDisabled(); boolean isCommit(); boolean isSynchronize(); boolean isSynchronizeOwner(); boolean isSynchronizePeer(); boolean isUpdate(); static final String REFERER_HEADER; static final String CONNECTION_HEADER; static final String CONTENT_TYPE_HEADER; static final String CONTENT_ENCODING_HEADER; static final String CONTENT_LENGTH_HEADER; static final String CONTENT_RANGE_HEADER; static final String RANGE_HEADER; static final String RETRY_AFTER_HEADER; static final String PRAGMA_HEADER; static final String SET_COOKIE_HEADER; static final String COOKIE_HEADER; static final String LOCATION_HEADER; static final String USER_AGENT_HEADER; static final String HOST_HEADER; static final String ACCEPT_HEADER; static final String ACCEPT_ENCODING_HEADER; static final String AUTHORIZATION_HEADER; static final String ACCEPT_LANGUAGE_HEADER; static final String TRANSFER_ENCODING_HEADER; static final String CHUNKED_ENCODING; static final String LAST_EVENT_ID_HEADER; static final String STREAM_ID_HEADER; static final String STREAM_WEIGHT_HEADER; static final String HTTP2_SCHEME_HEADER; static final String HEADER_NAME_PREFIX; static final String CONTEXT_ID_HEADER; static final String REQUEST_AUTH_TOKEN_HEADER; static final String REPLICATION_PHASE_HEADER; static final String REPLICATION_QUORUM_HEADER; static final String REPLICATION_PARENT_HEADER; static final String REPLICATION_QUORUM_HEADER_VALUE_ALL; static final String TRANSACTION_HEADER; static final String TRANSACTION_ID_HEADER; static final String TRANSACTION_REFLINK_HEADER; static final String PRAGMA_DIRECTIVE_CREATED; static final String PRAGMA_DIRECTIVE_FORWARDED; static final String PRAGMA_DIRECTIVE_REPLICATED; static final String PRAGMA_DIRECTIVE_SYNCH_OWNER; static final String PRAGMA_DIRECTIVE_SYNCH_PEER; static final String PRAGMA_DIRECTIVE_SYNCH_ALL_VERSIONS; static final String PRAGMA_DIRECTIVE_SYNCH_HISTORICAL_VERSIONS; static final String PRAGMA_DIRECTIVE_SYNCH_VERSION; static final String PRAGMA_DIRECTIVE_QUEUE_FOR_SERVICE_AVAILABILITY; static final String PRAGMA_DIRECTIVE_NO_FORWARDING; static final String PRAGMA_DIRECTIVE_NOTIFICATION; static final String PRAGMA_DIRECTIVE_SKIPPED_NOTIFICATIONS; static final String PRAGMA_DIRECTIVE_VERSION_CHECK; static final String PRAGMA_DIRECTIVE_INDEX_CHECK; static final String PRAGMA_DIRECTIVE_FORCE_INDEX_UPDATE; static final String PRAGMA_DIRECTIVE_NO_INDEX_UPDATE; static final String PRAGMA_DIRECTIVE_CLEAR_AUTH_CACHE; static final String PRAGMA_DIRECTIVE_POST_TO_PUT; static final String PRAGMA_DIRECTIVE_AUTHENTICATE; static final String PRAGMA_DIRECTIVE_VERIFY_TOKEN; static final String PRAGMA_DIRECTIVE_AUTHN_INVALIDATE; static final String PRAGMA_DIRECTIVE_FROM_MIGRATION_TASK; static final String PRAGMA_DIRECTIVE_STATE_NOT_MODIFIED; static final String TX_ENSURE_COMMIT; static final String TX_COMMIT; static final String TX_ABORT; static final String REPLICATION_PHASE_COMMIT; static final String MEDIA_TYPE_APPLICATION_JSON; static final String MEDIA_TYPE_TEXT_YAML; static final String MEDIA_TYPE_APPLICATION_OCTET_STREAM; static final String MEDIA_TYPE_APPLICATION_KRYO_OCTET_STREAM; static final String MEDIA_TYPE_APPLICATION_X_WWW_FORM_ENCODED; static final String MEDIA_TYPE_TEXT_HTML; static final String MEDIA_TYPE_TEXT_PLAIN; static final String MEDIA_TYPE_TEXT_CSS; static final String MEDIA_TYPE_APPLICATION_JAVASCRIPT; static final String MEDIA_TYPE_IMAGE_SVG_XML; static final String MEDIA_TYPE_APPLICATION_FONT_WOFF2; static final String MEDIA_TYPE_TEXT_EVENT_STREAM; static final String CONTENT_ENCODING_GZIP; static final int STATUS_CODE_SERVER_FAILURE_THRESHOLD; static final int STATUS_CODE_FAILURE_THRESHOLD; static final int STATUS_CODE_UNAUTHORIZED; static final int STATUS_CODE_UNAVAILABLE; static final int STATUS_CODE_FORBIDDEN; static final int STATUS_CODE_TIMEOUT; static final int STATUS_CODE_CONFLICT; static final int STATUS_CODE_NOT_MODIFIED; static final int STATUS_CODE_NOT_FOUND; static final int STATUS_CODE_MOVED_PERM; static final int STATUS_CODE_MOVED_TEMP; static final int STATUS_CODE_OK; static final int STATUS_CODE_CREATED; static final int STATUS_CODE_ACCEPTED; static final int STATUS_CODE_BAD_REQUEST; static final int STATUS_CODE_BAD_METHOD; static final int STATUS_CODE_INTERNAL_ERROR; static final String MEDIA_TYPE_EVERYTHING_WILDCARDS; static final String EMPTY_JSON_BODY; static final String HEADER_FIELD_VALUE_SEPARATOR; static final String CR_LF; }
@Test public void testSendWithOnHost() throws Throwable { testSendWith((o) -> o.sendWith(this.host)); }
@Test public void testSendWithOnService() throws Throwable { testSendWith((o) -> o.sendWith(this.services.get(0))); }
@Test public void testSendWithOnServiceClient() throws Throwable { testSendWith((o) -> o.sendWith(this.host.getClient())); }