Skip to content

Commit

Permalink
Removed superfluous '@nonnull' annotations and fixed log message.
Browse files Browse the repository at this point in the history
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>
  • Loading branch information
Juergen Fickel committed Jan 18, 2019
1 parent 9dca881 commit a458f60
Show file tree
Hide file tree
Showing 6 changed files with 22 additions and 28 deletions.
Expand Up @@ -10,8 +10,6 @@
*/
package org.eclipse.ditto.services.connectivity.messaging.persistence;

import javax.annotation.Nonnull;

import org.eclipse.ditto.json.JsonObject;
import org.eclipse.ditto.model.connectivity.Connection;
import org.eclipse.ditto.services.utils.persistence.mongo.AbstractMongoSnapshotAdapter;
Expand All @@ -28,8 +26,7 @@ public ConnectionMongoSnapshotAdapter() {
}

@Override
protected Connection createJsonifiableFrom(@Nonnull final JsonObject jsonObject) {

protected Connection createJsonifiableFrom(final JsonObject jsonObject) {
return ConnectionMigrationUtil.connectionFromJsonWithMigration(jsonObject);
}

Expand Down
Expand Up @@ -1862,7 +1862,8 @@ protected void apply(final C command) {
.flatMap(EntityTag::fromEntity)
.orElse(null);

log.debug("Validating conditional headers with currentETagValue <{}> on command <{}>.");
log.debug("Validating conditional headers with currentETagValue <{}> on command <{}>.", currentETagValue,
command);
try {
validator.checkConditionalHeaders(command, currentETagValue);
log.debug("Validating conditional headers succeeded.");
Expand Down
Expand Up @@ -10,7 +10,6 @@
*/
package org.eclipse.ditto.services.policies.persistence.serializer;

import javax.annotation.Nonnull;
import javax.annotation.concurrent.ThreadSafe;

import org.eclipse.ditto.json.JsonObject;
Expand All @@ -34,7 +33,7 @@ public PolicyMongoSnapshotAdapter() {
}

@Override
protected Policy createJsonifiableFrom(@Nonnull final JsonObject jsonObject) {
protected Policy createJsonifiableFrom(final JsonObject jsonObject) {
return PoliciesModelFactory.newPolicy(jsonObject);
}

Expand Down
Expand Up @@ -8,6 +8,5 @@
*
* SPDX-License-Identifier: EPL-2.0
*/

@org.eclipse.ditto.utils.jsr305.annotations.AllParametersAndReturnValuesAreNonnullByDefault
package org.eclipse.ditto.services.policies.persistence.serializer;
Expand Up @@ -14,7 +14,6 @@

import java.text.MessageFormat;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import javax.annotation.concurrent.ThreadSafe;

Expand Down Expand Up @@ -50,28 +49,28 @@ protected AbstractMongoSnapshotAdapter(final Logger logger) {
this.logger = logger;
}

/**
* This method is called exactly once when a snapshot is created. It does nothing by default. Subclasses
* may override it to inject code.
*
* @param snapshotEntity The entity for which the snapshot is created.
* @param json The JSON object to store as snapshot.
*/
protected void onSnapshotStoreConversion(final T snapshotEntity, final JsonObject json) {
// does nothing by default
}

@Override
public Object toSnapshotStore(final T snapshotEntity) {
checkNotNull(snapshotEntity, "snapshot entity");
final JsonObject json = convertToJson(snapshotEntity);
final JsonObject json = convertToJson(checkNotNull(snapshotEntity, "snapshot entity"));

onSnapshotStoreConversion(snapshotEntity, json);

final DittoBsonJson dittoBsonJson = DittoBsonJson.getInstance();
return dittoBsonJson.parse(json);
}

/**
* This method is called exactly once when a snapshot is created.
* It does nothing by default.
* Subclasses may override it to inject code.
*
* @param snapshotEntity The entity for which the snapshot is created.
* @param json The JSON object to store as snapshot.
*/
protected void onSnapshotStoreConversion(final T snapshotEntity, final JsonObject json) {
// does nothing by default
}

@Override
public T fromSnapshotStore(final SnapshotOffer snapshotOffer) {
return convertSnapshotToJsonifiable(snapshotOffer.snapshot());
Expand Down Expand Up @@ -103,13 +102,13 @@ protected JsonObject convertToJson(final T snapshotEntity) {
* @throws IllegalArgumentException if {@code rawSnapshotEntity} is not an instance of {@code DBObject}.
*/
@Nullable
private T convertSnapshotToJsonifiable(@Nonnull final Object rawSnapshotEntity) {
private T convertSnapshotToJsonifiable(final Object rawSnapshotEntity) {
final DBObject snapshotEntityAsDBObject = getSnapshotEntityAsDBObject(rawSnapshotEntity);
final JsonObject jsonObject = convertToJson(snapshotEntityAsDBObject);
return tryToCreateJsonifiableFrom(jsonObject);
}

private static DBObject getSnapshotEntityAsDBObject(@Nonnull final Object rawSnapshotEntity) {
private static DBObject getSnapshotEntityAsDBObject(final Object rawSnapshotEntity) {
checkNotNull(rawSnapshotEntity, "raw snapshot entity");
if (!(rawSnapshotEntity instanceof DBObject)) {
final String pattern = "Unable to create a Jsonifiable from <{0}>! Expected was a DBObject instance.";
Expand All @@ -127,15 +126,15 @@ private static DBObject getSnapshotEntityAsDBObject(@Nonnull final Object rawSna
* @throws org.eclipse.ditto.model.base.exceptions.DittoJsonException if {@code dbObject} cannot be serialized to a
* JsonObject.
*/
private static JsonObject convertToJson(@Nonnull final DBObject dbObject) {
private static JsonObject convertToJson(final DBObject dbObject) {
checkNotNull(dbObject, "DBObject to be converted");
final DittoBsonJson dittoBsonJson = DittoBsonJson.getInstance();
final JsonObject jsonObject = dittoBsonJson.serialize(dbObject).asObject();
return DittoJsonException.wrapJsonRuntimeException(() -> jsonObject);
}

@Nullable
private T tryToCreateJsonifiableFrom(@Nonnull final JsonObject jsonObject) {
private T tryToCreateJsonifiableFrom(final JsonObject jsonObject) {
try {
return createJsonifiableFrom(jsonObject);
} catch (final JsonParseException | DittoRuntimeException e) {
Expand All @@ -152,6 +151,6 @@ private T tryToCreateJsonifiableFrom(@Nonnull final JsonObject jsonObject) {
* @return the Jsonifiable which originates from {@code jsonObject}.
* @throws org.eclipse.ditto.json.JsonParseException if {@code jsonObject} does not have the correct format.
*/
protected abstract T createJsonifiableFrom(@Nonnull JsonObject jsonObject);
protected abstract T createJsonifiableFrom(JsonObject jsonObject);

}
Expand Up @@ -8,6 +8,5 @@
*
* SPDX-License-Identifier: EPL-2.0
*/

@org.eclipse.ditto.utils.jsr305.annotations.AllParametersAndReturnValuesAreNonnullByDefault
package org.eclipse.ditto.services.utils.persistence.mongo;

0 comments on commit a458f60

Please sign in to comment.