Skip to content

Commit 7d9ef68

Browse files
author
James Leigh
authored
Merge pull request #873 from jamesrdf/issues/#872-guava
Fix #872: Move guava dependency from util to sail-model
2 parents 782fe42 + ec766a4 commit 7d9ef68

6 files changed

Lines changed: 24 additions & 22 deletions

File tree

core/http/client/src/main/java/org/eclipse/rdf4j/http/client/SPARQLProtocolSession.java

Lines changed: 3 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -94,8 +94,6 @@
9494
import org.slf4j.Logger;
9595
import org.slf4j.LoggerFactory;
9696

97-
import com.google.common.base.Joiner;
98-
9997
/**
10098
* The SPARQLProtocolSession provides low level HTTP methods for communication with SPARQL endpoints. All
10199
* methods are compliant to the <a href="https://www.w3.org/TR/sparql11-protocol/">SPARQL 1.1 Protocol W3C
@@ -151,11 +149,6 @@ public class SPARQLProtocolSession implements HttpClientDependent {
151149

152150
final Logger logger = LoggerFactory.getLogger(this.getClass());
153151

154-
/**
155-
* shared instance of a {@link Joiner} for creating a comma-separated string.
156-
*/
157-
private static final Joiner commaJoiner = Joiner.on(", ");
158-
159152
/*-----------*
160153
* Variables *
161154
*-----------*/
@@ -828,7 +821,7 @@ private HttpResponse sendTupleQueryViaHttp(HttpUriRequest method, Set<QueryResul
828821
}
829822
}
830823

831-
method.addHeader(ACCEPT_PARAM_NAME, commaJoiner.join(acceptValues));
824+
method.addHeader(ACCEPT_PARAM_NAME, String.join(", ", acceptValues));
832825

833826
try {
834827
return executeOK(method);
@@ -966,7 +959,7 @@ private HttpResponse sendGraphQueryViaHttp(HttpUriRequest method, boolean requir
966959
List<String> acceptParams = RDFFormat.getAcceptParams(rdfFormats, requireContext,
967960
getPreferredRDFFormat());
968961

969-
method.addHeader(ACCEPT_PARAM_NAME, commaJoiner.join(acceptParams));
962+
method.addHeader(ACCEPT_PARAM_NAME, String.join(", ", acceptParams));
970963

971964
try {
972965
return executeOK(method);
@@ -1047,7 +1040,7 @@ private HttpResponse sendBooleanQueryViaHttp(HttpUriRequest method, Set<QueryRes
10471040
}
10481041
}
10491042

1050-
method.addHeader(ACCEPT_PARAM_NAME, commaJoiner.join(acceptValues));
1043+
method.addHeader(ACCEPT_PARAM_NAME, String.join(", ", acceptValues));
10511044

10521045
return executeOK(method);
10531046
}

core/http/client/src/main/java/org/eclipse/rdf4j/http/client/SharedHttpClientSessionManager.java

Lines changed: 14 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,24 +10,25 @@
1010
import java.util.Objects;
1111
import java.util.concurrent.ExecutorService;
1212
import java.util.concurrent.Executors;
13+
import java.util.concurrent.ThreadFactory;
1314
import java.util.concurrent.TimeUnit;
15+
import java.util.concurrent.atomic.AtomicLong;
1416

1517
import org.apache.http.client.HttpClient;
1618
import org.apache.http.client.utils.HttpClientUtils;
1719
import org.apache.http.impl.client.CloseableHttpClient;
1820
import org.apache.http.impl.client.HttpClientBuilder;
19-
import org.apache.http.impl.client.HttpClients;
2021
import org.eclipse.rdf4j.http.client.util.HttpClientBuilders;
2122

22-
import com.google.common.util.concurrent.ThreadFactoryBuilder;
23-
2423
/**
2524
* A Manager for HTTP sessions that uses a shared {@link HttpClient} to manage HTTP connections.
2625
*
2726
* @author James Leigh
2827
*/
2928
public class SharedHttpClientSessionManager implements HttpClientSessionManager, HttpClientDependent {
3029

30+
private static final AtomicLong threadCount = new AtomicLong();
31+
3132
/** independent life cycle */
3233
private volatile HttpClient httpClient;
3334

@@ -46,8 +47,16 @@ public class SharedHttpClientSessionManager implements HttpClientSessionManager,
4647
*--------------*/
4748

4849
public SharedHttpClientSessionManager() {
49-
this.executor = Executors.newCachedThreadPool(
50-
new ThreadFactoryBuilder().setNameFormat("rdf4j-sesameclientimpl-%d").build());
50+
final ThreadFactory backingThreadFactory = Executors.defaultThreadFactory();
51+
this.executor = Executors.newCachedThreadPool(new ThreadFactory() {
52+
53+
public Thread newThread(Runnable runnable) {
54+
Thread thread = backingThreadFactory.newThread(runnable);
55+
thread.setName(String.format("rdf4j-sesameclientimpl-%d", threadCount.getAndIncrement()));
56+
thread.setDaemon(true);
57+
return thread;
58+
}
59+
});
5160
}
5261

5362
public SharedHttpClientSessionManager(CloseableHttpClient dependentClient,

core/sail/model/pom.xml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,10 @@
1919
<artifactId>rdf4j-sail-api</artifactId>
2020
<version>${project.version}</version>
2121
</dependency>
22+
<dependency>
23+
<groupId>com.google.guava</groupId>
24+
<artifactId>guava</artifactId>
25+
</dependency>
2226
</dependencies>
2327
<build>
2428
<plugins>

core/util/src/main/java/org/eclipse/rdf4j/util/NonSerializables.java renamed to core/sail/model/src/main/java/org/eclipse/rdf4j/sail/model/NonSerializables.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,13 @@
55
* which accompanies this distribution, and is available at
66
* http://www.eclipse.org/org/documents/edl-v10.php.
77
*******************************************************************************/
8-
package org.eclipse.rdf4j.util;
8+
package org.eclipse.rdf4j.sail.model;
99

1010
import java.util.Map;
1111
import java.util.UUID;
1212

13+
import org.eclipse.rdf4j.util.UUIDable;
14+
1315
import com.google.common.cache.Cache;
1416
import com.google.common.cache.CacheBuilder;
1517

core/sail/model/src/main/java/org/eclipse/rdf4j/sail/model/SailModel.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@
3333
import org.eclipse.rdf4j.model.util.ModelException;
3434
import org.eclipse.rdf4j.sail.SailConnection;
3535
import org.eclipse.rdf4j.sail.SailException;
36-
import org.eclipse.rdf4j.util.NonSerializables;
3736

3837
/**
3938
* Model implementation for a {@link org.eclipse.rdf4j.sail.SailConnection}. All

core/util/pom.xml

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,6 @@
1414
<description>RDF4J utility classes</description>
1515

1616
<dependencies>
17-
<dependency>
18-
<groupId>com.google.guava</groupId>
19-
<artifactId>guava</artifactId>
20-
</dependency>
21-
2217
<dependency>
2318
<groupId>org.slf4j</groupId>
2419
<artifactId>slf4j-api</artifactId>

0 commit comments

Comments
 (0)