fixes imports

eclipse · Feb 16, 2018 · 0019b2e · 0019b2e
1 parent 0b06494
commit 0019b2e
Showing 1 changed file with 13 additions and 15 deletions.
diff --git a/couchbase-driver/src/main/java/org/jnosql/diana/couchbase/key/CouchbaseBucketManager.java b/couchbase-driver/src/main/java/org/jnosql/diana/couchbase/key/CouchbaseBucketManager.java
@@ -25,13 +25,11 @@
 
 import javax.json.bind.Jsonb;
 import javax.json.bind.JsonbBuilder;
-import java.io.ByteArrayOutputStream;
-import java.io.OutputStream;
 import java.time.Duration;
-import java.util.Map;
 import java.util.Objects;
 import java.util.Optional;
 
+import static java.util.Objects.requireNonNull;
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import static java.util.stream.Collectors.toList;
 import static java.util.stream.StreamSupport.stream;
@@ -55,21 +53,21 @@ public class CouchbaseBucketManager implements BucketManager {
 
     @Override
     public <K, V> void put(K key, V value) throws NullPointerException {
-        Objects.requireNonNull(key, "key is required");
-        Objects.requireNonNull(value, "value is required");
+        requireNonNull(key, "key is required");
+        requireNonNull(value, "value is required");
         bucket.upsert(JsonDocument.create(key.toString(), JsonObjectCouchbaseUtil.toJson(JSONB, value)));
     }
 
     @Override
     public <K> void put(KeyValueEntity<K> entity) throws NullPointerException {
-        Objects.requireNonNull(entity, "entity is required");
+        requireNonNull(entity, "entity is required");
         put(entity.getKey(), convert(entity.getValue()));
     }
 
     @Override
     public <K> void put(KeyValueEntity<K> entity, Duration ttl) throws NullPointerException, UnsupportedOperationException {
-        Objects.requireNonNull(entity, "entity is required");
-        Objects.requireNonNull(ttl, "ttl is required");
+        requireNonNull(entity, "entity is required");
+        requireNonNull(ttl, "ttl is required");
 
 
         JsonObject jsonObject = JsonObjectCouchbaseUtil.toJson(JSONB, entity.get());
@@ -78,20 +76,20 @@ public <K> void put(KeyValueEntity<K> entity, Duration ttl) throws NullPointerEx
 
     @Override
     public <K> void put(Iterable<KeyValueEntity<K>> keyValueEntities) throws NullPointerException {
-        Objects.requireNonNull(keyValueEntities, "keyValueEntities is required");
+        requireNonNull(keyValueEntities, "keyValueEntities is required");
         keyValueEntities.forEach(this::put);
     }
 
     @Override
     public <K> void put(Iterable<KeyValueEntity<K>> keyValueEntities, Duration ttl) throws NullPointerException, UnsupportedOperationException {
-        Objects.requireNonNull(keyValueEntities, "keyValueEntities is required");
-        Objects.requireNonNull(ttl, "ttl is required");
+        requireNonNull(keyValueEntities, "keyValueEntities is required");
+        requireNonNull(ttl, "ttl is required");
         keyValueEntities.forEach(k -> this.put(k, ttl));
     }
 
     @Override
     public <K> Optional<Value> get(K key) throws NullPointerException {
-        Objects.requireNonNull(key, "key is required");
+        requireNonNull(key, "key is required");
         JsonDocument jsonDocument = bucket.get(key.toString());
         if (Objects.isNull(jsonDocument)) {
             return Optional.empty();
@@ -102,7 +100,7 @@ public <K> Optional<Value> get(K key) throws NullPointerException {
 
     @Override
     public <K> Iterable<Value> get(Iterable<K> keys) throws NullPointerException {
-        Objects.requireNonNull(keys, "keys is required");
+        requireNonNull(keys, "keys is required");
         return stream(keys.spliterator(), false)
                 .map(this::get)
                 .filter(Optional::isPresent)
@@ -112,13 +110,13 @@ public <K> Iterable<Value> get(Iterable<K> keys) throws NullPointerException {
 
     @Override
     public <K> void remove(K key) throws NullPointerException {
-        Objects.requireNonNull(key, "key is required");
+        requireNonNull(key, "key is required");
         bucket.remove(key.toString());
     }
 
     @Override
     public <K> void remove(Iterable<K> keys) throws NullPointerException {
-        Objects.requireNonNull(keys, "keys is required");
+        requireNonNull(keys, "keys is required");
         keys.forEach(this::remove);
     }