Skip to content

SoftwareAG/cumulocity-clients-java-v2

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

CumulocityCoreLibrary

Usage

When using APIs, a new WebTarget needs to be created and passed using the constructor of each API class. Therefore, create a new Client and pass the resource target:

import jakarta.ws.rs.client.Client;
import jakarta.ws.rs.client.ClientBuilder;
import jakarta.ws.rs.client.WebTarget;

final Client client = ClientBuilder.newClient();
final WebTarget webTarget = client.target("endpoint");
final SystemOptionsApi service = new SystemOptionsApi(webTarget);

The resource implementation returns an instance of java.util.concurrent.CompletionStage<T> to allow developers to process a response using reactive concepts. Convert the CompletionStage into a completeable Future using #toCompletableFuture() and invoke either #get() or #join() on the Future. Both methods will wait until a response is received.

Use your own domain model

The CumulocityCoreLibrary allows custom data models. The following classes are designed to be extensible:

  • Alarm, AuditRecord, CategoryOptions, CustomProperties, Event, ManagedObject, Measurement, Operation

Those classes allow to add an arbitrary number of additional properties as a list of key-value pairs. These properties are known as custom fragments and can be of any type. Each custom fragment is identified by a unique name. Thus, developers can propagate their custom fragments using:

Alarm.Serialization.registerAdditionalProperty(String, Class<?>);

Each of the extensible objects contains a dictionary object holding instances of custom fragments. Use the custom fragment's key to access it's value.

Working with errors

HTTP error codes will be forwarded and can be accessed using a jakarta.ws.rs.core.Response. Error codes can be retrievied by calling #getStatus(), respectively #getStatusInfo. The response object also allows access to error objects by calling #readEntity(Class<?>). See the JavaDoc comment on each resource method to know what error types are returned.

The response object is only accessible when the underlying resource did not complete successfully. In this case, a jakarta.ws.rs.WebApplicationException is thrown.

The java.util.concurrent API enables different solutions to handle this exception. Common use cases are CompletionStage#exceptionally(Function<Throwable, ? extends U>) and CompletionStage#handle(BiFunction<? super U, Throwable, ? extends Object>) as shown in the following listing.

final CompletionStage<T> stage = ...;
stage.exceptionally(exception -> {
    if (exception.getCause() instanceof WebApplicationException) {
    	final Response response = ((WebApplicationException) exception.getCause()).getResponse();
        response.readEntity(Error.class);
    }
    return null;
});

stage.handle((result, exception) -> {
    // exception might be null if the resource completes successfully
    return null;
});

Basic Authentication

The client sends HTTP requests with the Authorization header that contains the word Basic word followed by a space and a base64-encoded string username:password. Using Jersey, the Authorization header is added using a HttpAuthenticationFeature.

import org.glassfish.jersey.client.ClientConfig;
import org.glassfish.jersey.client.authentication.HttpAuthenticationFeature;

import jakarta.ws.rs.client.Client;
import jakarta.ws.rs.client.ClientBuilder;
import jakarta.ws.rs.client.WebTarget;

final ClientConfig clientConfig = new ClientConfig();
final HttpAuthenticationFeature feature = HttpAuthenticationFeature.basic("userName", "password");
clientConfig.register(feature);

The HttpAuthenticationFeature will be used to create a new Client and afterwards the Authorization header is automatically added to each request.

final Client client = ClientBuilder.newClient(clientConfig);

Contribution

If you've spotted something that doesn't work as you'd expect, or if you have a new feature you'd like to add, we're happy to accept contributions and bug reports.

For bug reports, please raise an issue directly in this repository by selecting the issues tab and then clicking the new issue button. Please ensure that your bug report is as detailed as possible and allows us to reproduce your issue easily.

In the case of new contributions, please create a new branch from the latest version of main. When your feature is complete and ready to evaluate, raise a new pull request.


These tools are provided as-is and without warranty or support. They do not constitute part of the Software AG product suite. Users are free to use, fork and modify them, subject to the license agreement. While Software AG welcomes contributions, we cannot guarantee to include every contribution in the master project.

About

A Java gradle/maven project to work with Cumulocity IoT, generated using the Cumulocity IoT OpenAPI specification.

Topics

Resources

License

Stars

Watchers

Forks

Languages