Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit e4462ab

Browse files
committed
fix jwt authentication
1 parent 490b1be commit e4462ab

File tree

5 files changed

+10
-11
lines changed

5 files changed

+10
-11
lines changed

‎core/src/main/java/com/arangodb/internal/net/ConnectionPoolImpl.java‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -80,9 +80,11 @@ public synchronized Connection connection() {
8080

8181
@Override
8282
public void setJwt(String jwt) {
83-
this.jwt = jwt;
84-
for (Connection connection : connections) {
85-
connection.setJwt(jwt);
83+
if (jwt != null) {
84+
this.jwt = jwt;
85+
for (Connection connection : connections) {
86+
connection.setJwt(jwt);
87+
}
8688
}
8789
}
8890

‎core/src/main/java/com/arangodb/internal/net/HostSet.java‎

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,6 @@ public class HostSet {
1515
private final ArrayList<Host> hosts = new ArrayList<>();
1616
private volatile String jwt = null;
1717

18-
public HostSet() {
19-
super();
20-
}
21-
2218
public HostSet(List<Host> hosts) {
2319
super();
2420

‎driver/src/test/java/com/arangodb/ArangoCollectionAsyncTest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -566,7 +566,7 @@ void getDocumentsDirtyRead(ArangoCollectionAsync collection) throws ExecutionExc
566566
values.add(new BaseDocument("1"));
567567
values.add(new BaseDocument("2"));
568568
values.add(new BaseDocument("3"));
569-
collection.insertDocuments(values);
569+
collection.insertDocuments(values).get();
570570
final MultiDocumentEntity<BaseDocument> documents = collection.getDocuments(Arrays.asList("1", "2", "3"),
571571
BaseDocument.class, new DocumentReadOptions().allowDirtyRead(true)).get();
572572
assertThat(documents).isNotNull();

‎driver/src/test/java/com/arangodb/ArangoDBAsyncTest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -532,7 +532,7 @@ void setAllLogLevel(ArangoDBAsync arangoDB) throws ExecutionException, Interrupt
532532
assertThat(retrievedLevels.getAgency()).isEqualTo(LogLevelEntity.LogLevel.ERROR);
533533
} finally {
534534
entity.setAll(LogLevelEntity.LogLevel.INFO);
535-
arangoDB.setLogLevel(entity);
535+
arangoDB.setLogLevel(entity).get();
536536
}
537537
}
538538

‎driver/src/test/java/com/arangodb/internal/HostHandlerTest.java‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import com.arangodb.internal.serde.InternalSerde;
2828
import org.junit.jupiter.api.Test;
2929

30+
import java.util.Collections;
3031
import java.util.List;
3132

3233
import static org.assertj.core.api.Assertions.assertThat;
@@ -65,7 +66,7 @@ public void close() {
6566
@Override
6667
public HostSet resolve(final boolean initial, final boolean closeConnections) {
6768

68-
HostSet set = new HostSet();
69+
HostSet set = new HostSet(Collections.emptyList());
6970
set.addHost(HOST_0);
7071
return set;
7172
}
@@ -83,7 +84,7 @@ public void init(ArangoExecutorSync executor, InternalSerde arangoSerialization)
8384
@Override
8485
public HostSet resolve(final boolean initial, final boolean closeConnections) {
8586

86-
HostSet set = new HostSet();
87+
HostSet set = new HostSet(Collections.emptyList());
8788
set.addHost(HOST_0);
8889
set.addHost(HOST_1);
8990
set.addHost(HOST_2);

0 commit comments

Comments
(0)

AltStyle によって変換されたページ (->オリジナル) /