public class SDKRequest extends VaultRequest
HTTP_HEADER_AUTHORIZATION, HTTP_HEADER_VAULT_CLIENT_ID, vaultClient
Modifier and Type | Method and Description |
---|---|
SDKResponse |
addOrReplaceSingleSourceCodeFile()
Add or Replace Single Source Code File
|
VaultResponse |
deleteSingleSourceCodeFile(String className)
Delete Single Source Code File
|
VaultResponse |
disableDelivery(String queueName)
Disable Delivery
|
SDKResponse |
disableVaultExtension(String className)
Disable Vault Extension
|
VaultResponse |
enableDelivery(String queueName)
Enable Delivery
|
SDKResponse |
enableVaultExtension(String className)
Enable Vault Extension
|
VaultResponse |
resetQueue(String queueName)
Reset Queue
|
QueueResponse |
retrieveAllQueues()
Retrieve all Queues
|
QueueResponse |
retrieveQueueStatus(String queueName)
Retrieve Queue Status
|
VaultResponse |
retrieveSigningCertificate(String certificateId)
The following endpoint allows you to retrieve a signing certificate included
in a Spark message header to verify that the received message came from Vault.
|
SDKResponse |
retrieveSingleSourceCodeFile(String className)
Retrieve Single Source Code File
|
SDKRequest |
setBinaryFile(String filename,
byte[] binaryContent)
Specify source data in an input file
|
SDKRequest |
setInputPath(String inputPath)
Specify source data in an input file
|
SDKRequest |
setOutputPath(String outputPath)
Specify source data in an output file
|
ValidatePackageResponse |
validateImportedPackage(String packageId)
Validate Imported Package
|
ValidatePackageResponse |
validatePackage()
Validate Package
Validate a VPK package with Vault Java SDK code attached to this request.
|
getBaseObjectMapper, send, send, sendReturnBinary, sendReturnBinary, sendToFile, sendToFile, setVaultClient
public SDKResponse retrieveSingleSourceCodeFile(String className)
Retrieve a single source code file from the currently authenticated vault
className
- The fully qualified class name of your file.GET /api/{version}/code/{class_name}
SDKResponse resp = vaultClient.newRequest(SDKRequest.class) .retrieveSingleSourceCodeFile(className);
System.out.println("Status = " + resp.getResponseStatus()); System.out.println("Binary Length = " + resp.getBinaryContent().length);
public SDKResponse disableVaultExtension(String className)
Disable a deployed Vault extension in the currently authenticated vault. Only available on entry-point classes, such as triggers and actions.
className
- The fully qualified class name of your file.PUT /api/{version}/code/{class_name}/disable
SDKResponse resp = vaultClient.newRequest(SDKRequest.class) .disableVaultExtension(className);
System.out.println("Status = " + resp.getResponseStatus());
public SDKResponse enableVaultExtension(String className)
Enable a deployed Vault extension in the currently authenticated vault. Only available on entry-point classes, such as triggers and actions.
className
- The fully qualified class name of your file.PUT /api/{version}/code/{class_name}/enable
SDKResponse resp = vaultClient.newRequest(SDKRequest.class) .enableVaultExtension(className);
System.out.println("Status = " + resp.getResponseStatus());
public SDKResponse addOrReplaceSingleSourceCodeFile()
Add or replace a single .java file in the currently authenticated Vault. If the given file does not already exist in the vault, it is added. If the file already exists in the vault, the file is updated. Maximum allowed size is 1MB.
PUT /api/{version}/code
SDKResponse resp = vaultClient.newRequest(SDKRequest.class) .setBinaryFile(sdkFile.getName(), Files.readAllBytes(sdkFile.toPath())) .addOrReplaceSingleSourceCodeFile();
System.out.println("Status = " + resp.getResponseStatus()); System.out.println("Message = " + resp.getResponseMessage()); System.out.println("Url = " + resp.getUrl()); System.out.println("\n****** Add/Replace SDK Component - Local File ******"); resp = vaultClient.newRequest(SDKRequest.class) .setInputPath(fileName) .addOrReplaceSingleSourceCodeFile(); System.out.println("Status = " + resp.getResponseStatus()); System.out.println("Message = " + resp.getResponseMessage()); System.out.println("Url = " + resp.getUrl());
public VaultResponse deleteSingleSourceCodeFile(String className)
Delete a single source code file from the currently authenticated Vault. You cannot delete a code component currently in-use.
className
- The fully qualified class name of your file.DELETE /api/{version}/code/{class_name}
VaultResponse resp = vaultClient.newRequest(SDKRequest.class) .deleteSingleSourceCodeFile(className);
System.out.println("Status = " + resp.getResponseStatus());
public ValidatePackageResponse validatePackage()
POST /api/{version}/services/package/actions/validate
ValidatePackageResponse resp = vaultClient.newRequest(SDKRequest.class) .setInputPath(fileName) .validatePackage();
System.out.println("Status = " + resp.getResponseStatus()); System.out.println("Author = " + resp.getResponseDetails().getAuthor());
public ValidatePackageResponse validateImportedPackage(String packageId)
Validate a previously imported VPK package with Vault Java SDK code.
packageId
- id of package to validatePOST /api/{version}/services/vobject/vault_package__v/{package_id}/actions/validate
ValidatePackageResponse resp = vaultClient.newRequest(SDKRequest.class) .validateImportedPackage(packageId);
System.out.println("Status = " + resp.getResponseStatus()); System.out.println("Author = " + resp.getResponseDetails().getAuthor());
public QueueResponse retrieveAllQueues()
GET /api/{version}/services/queues
QueueResponse resp = vaultClient.newRequest(SDKRequest.class) .retrieveAllQueues();
System.out.println("Status = " + resp.getResponseStatus()); String queueName = null; if (resp.isSuccessful()) { System.out.println("# Queues = " + resp.getData().size()); for (QueueResponse.Queue queue : resp.getData()) { queueName = queue.getName(); System.out.println("Queue Name = " + queue.getName()); } } }
public QueueResponse retrieveQueueStatus(String queueName)
Retrieve the status of a specific queue.
queueName
- name of queueGET /api/{version}/services/queues/{queue_name}
QueueResponse resp = vaultClient.newRequest(SDKRequest.class) .retrieveQueueStatus(queueName);
System.out.println("Status = " + resp.getResponseStatus()); if (resp.isSuccessful()) { System.out.println("# Queues = " + resp.getData().size()); for (QueueResponse.Queue queue : resp.getData()) { System.out.println("Queue Name = " + queue.getName()); } }
public VaultResponse disableDelivery(String queueName)
The following endpoint allows you to disable the delivery of messages in an outbound queue. This endpoint is not available for inbound queues, as inbound queues process received messages rather than deliver messages. Vault uses Message Processor to process received messages. There is no way to stop received messages from processing.
queueName
- name of queuePUT /api/{version}/services/queues/{queue_name}/actions/disable_delivery
VaultResponse disableResponse = vaultClient.newRequest(SDKRequest.class) .disableDelivery(queueName);
System.out.println("Status = " + disableResponse.getResponseStatus());
public VaultResponse enableDelivery(String queueName)
The following endpoint allows you to enable the delivery of messages in an outbound queue. This endpoint is not available for inbound queues, as inbound queues process received messages rather than deliver messages.
queueName
- name of queuePUT /api/{version}/services/queues/{queue_name}/actions/enable_delivery
VaultResponse enableResponse = vaultClient.newRequest(SDKRequest.class) .enableDelivery(queueName);
System.out.println("Status = " + enableResponse.getResponseStatus());
public VaultResponse resetQueue(String queueName)
Delete all messages in a specific queue. This action is final and cannot be undone.
queueName
- name of queuePUT /api/{version}/services/queues/{queue_name}/actions/reset
VaultResponse resetResponse = vaultClient.newRequest(SDKRequest.class) .resetQueue(queueName);
System.out.println("Status = " + resetResponse.getResponseStatus());
public VaultResponse retrieveSigningCertificate(String certificateId)
certificateId
- certificate idGET /api/{version}/services/certificate/{cert_id}
VaultResponse resp = vaultClient.newRequest(SDKRequest.class) .setOutputPath(fileName) .retrieveSigningCertificate("00001");
System.out.println("Status = " + resp.getResponseStatus());
public SDKRequest setBinaryFile(String filename, byte[] binaryContent)
filename
- file name (no path)binaryContent
- byte array of the file contentpublic SDKRequest setInputPath(String inputPath)
inputPath
- Absolute path to the file for the requestpublic SDKRequest setOutputPath(String outputPath)
outputPath
- Absolute path to the file for the responseCopyright © 2021. All rights reserved.