Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Revert plugin version changes #150

Merged
merged 3 commits into from
Mar 14, 2019
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 9 additions & 19 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -37,20 +37,22 @@
<github.global.server>github</github.global.server>

<!-- dependencies -->
<activemq.version>5.15.5</activemq.version>
<camel.version>2.19.5</camel.version>
<camel.version.range>[2.19.5,3)</camel.version.range>
<activemq.version>5.14.0</activemq.version>
<camel.version>2.20.0</camel.version>
<camel.version.range>[2.20,3)</camel.version.range>
<commons.io.version>2.4</commons.io.version>
<commons.lang3.version>3.8.1</commons.lang3.version>
<commons.lang3.version>3.7</commons.lang3.version>
<httpclient.version>4.5.2</httpclient.version>
<karaf.version>4.2.2</karaf.version>
<karaf.version>4.0.6</karaf.version>
<jena.version>3.1.1</jena.version>
<mockito.version>1.10.8</mockito.version>
<pax-exam.version>4.13.1</pax-exam.version>
<pax-exam.version>4.8.0</pax-exam.version>
<slf4j.version>1.7.20</slf4j.version>
<spring.version>4.3.22.RELEASE</spring.version>
<spring.version>4.2.5.RELEASE</spring.version>
<fcrepo.version>5.0.1</fcrepo.version>
<fcrepo-java-client.version>0.4.0</fcrepo-java-client.version>
<!-- jared's -->
<failsafe.plugin.version>2.18.1</failsafe.plugin.version>

<!-- osgi bundle transitive dependencies (for karaf provisioning) -->
<commons.codec.version>1.10</commons.codec.version>
Expand Down Expand Up @@ -206,12 +208,6 @@
<artifactId>camel-test-karaf</artifactId>
<version>${camel.version}</version>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.ops4j.pax.exam</groupId>
<artifactId>pax-exam</artifactId>
</exclusion>
</exclusions>
</dependency>

<dependency>
Expand Down Expand Up @@ -345,16 +341,10 @@
<fcrepo.dynamic.stomp.port>${fcrepo.dynamic.stomp.port}</fcrepo.dynamic.stomp.port>
<commons.codec.version>${commons.codec.version}</commons.codec.version>
<commons.csv.version>${commons.csv.version}</commons.csv.version>
<commons.lang3.version>${commons.lang3.version}</commons.lang3.version>
<camelKarafFeatureVersion>${camel.version}</camelKarafFeatureVersion>
<dexx.version>${dexx-collection.version}</dexx.version>
<httpclient.version>${httpclient.version}</httpclient.version>
<httpcore.version>${httpcore.version}</httpcore.version>
<jsonld.version>${jsonld.version}</jsonld.version>
<jena.osgi.version>${jena.version}</jena.osgi.version>
<jsonld.version>${jsonld.version}</jsonld.version>
<fcrepo.client.version>${fcrepo-java-client.version}</fcrepo.client.version>

<thrift.version>${thrift.version}</thrift.version>
<karaf.ssh.port>${karaf.ssh.port}</karaf.ssh.port>
<karaf.rmiRegistry.port>${karaf.rmiRegistry.port}</karaf.rmiRegistry.port>
Expand Down
10 changes: 5 additions & 5 deletions src/main/java/org/fcrepo/camel/FcrepoEndpoint.java
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,7 @@ public FcrepoConfiguration getConfiguration() {

/**
* configuration setter
*
*
* @param config The FcrepoConfiguration
*/
public void setConfiguration(final FcrepoConfiguration config) {
Expand Down Expand Up @@ -222,7 +222,7 @@ public String getAccept() {

/**
* contentType setter
*
*
* @param type the mime-type used with Content-Type headers
*/
@ManagedAttribute(description = "Content-Type: Header")
Expand All @@ -242,7 +242,7 @@ public String getContentType() {

/**
* authUsername setter
*
*
* @param username used for repository authentication
*/
@ManagedAttribute(description = "Username for authentication")
Expand All @@ -262,7 +262,7 @@ public String getAuthUsername() {

/**
* authPassword setter
*
*
* @param password used for repository authentication
*/
@ManagedAttribute(description = "Password for authentication")
Expand All @@ -282,7 +282,7 @@ public String getAuthPassword() {

/**
* authHost setter
*
*
* @param host realm used for repository authentication
*/
@ManagedAttribute(description = "Hostname for authentication")
Expand Down
9 changes: 5 additions & 4 deletions src/main/java/org/fcrepo/camel/FcrepoProducer.java
Original file line number Diff line number Diff line change
Expand Up @@ -79,11 +79,11 @@ public class FcrepoProducer extends DefaultProducer {

private static final String REPOSITORY = "http://fedora.info/definitions/v4/repository#";

private FcrepoEndpoint endpoint;
private final FcrepoEndpoint endpoint;

private FcrepoClient fcrepoClient;

private TransactionTemplate transactionTemplate;
private final TransactionTemplate transactionTemplate;

public static final Map<String, String> PREFER_PROPERTIES;

Expand Down Expand Up @@ -141,12 +141,13 @@ public FcrepoProducer(final FcrepoEndpoint endpoint) {
public void process(final Exchange exchange) throws FcrepoOperationFailedException {
if (exchange.isTransacted()) {
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
@Override
protected void doInTransactionWithoutResult(final TransactionStatus status) {
final DefaultTransactionStatus st = (DefaultTransactionStatus)status;
final FcrepoTransactionObject tx = (FcrepoTransactionObject)st.getTransaction();
try {
doRequest(exchange, tx.getSessionId());
} catch (FcrepoOperationFailedException ex) {
} catch (final FcrepoOperationFailedException ex) {
throw new TransactionSystemException(
"Error executing fcrepo request in transaction: ", ex);
}
Expand Down Expand Up @@ -367,7 +368,7 @@ private static Object extractResponseBodyAsStream(final InputStream is, final Ex
IOHelper.copyAndCloseInput(is, cos);
// When the InputStream is closed, the CachedOutputStream will be closed
return cos.newStreamCache();
} catch (IOException ex) {
} catch (final IOException ex) {
LOGGER.debug("Error extracting body from http request", ex);
return null;
}
Expand Down
20 changes: 8 additions & 12 deletions src/test/java/org/fcrepo/camel/integration/KarafIT.java
Original file line number Diff line number Diff line change
Expand Up @@ -62,20 +62,14 @@ public Option[] config() {
final String fcrepoCamelBundle = "file:" + getBaseDir() + "/target/" + artifactName + ".jar";
final String commonsCodecVersion = cm.getProperty("commons.codec.version");
final String commonsCsvVersion = cm.getProperty("commons.csv.version");
final String commonsLang3Version = cm.getProperty("commons.lang3.version");
final String dexxVersion = cm.getProperty("dexx.version");
final String httpclientVersion = cm.getProperty("httpclient.version");
final String httpcoreVersion = cm.getProperty("httpcore.version");
final String jsonldVersion = cm.getProperty("jsonld.version");
final String jenaOsgiVersion = cm.getProperty("jena.osgi.version");
final String javaClientVersion = cm.getProperty("fcrepo.client.version");


final String thriftVersion = cm.getProperty("thrift.version");
final String rmiRegistryPort = cm.getProperty("karaf.rmiRegistry.port");
final String rmiServerPort = cm.getProperty("karaf.rmiServer.port");
final String sshPort = cm.getProperty("karaf.ssh.port");

return new Option[] {
karafDistributionConfiguration()
.frameworkUrl(maven().groupId("org.apache.karaf").artifactId("apache-karaf")
Expand All @@ -91,17 +85,19 @@ public Option[] config() {
editConfigurationFilePut("etc/org.apache.karaf.shell.cfg", "sshPort", sshPort),
features(maven().groupId("org.apache.karaf.features").artifactId("standard")
.versionAsInProject().classifier("features").type("xml"), "scr"),
features(getCamelKarafFeatureUrl(), "camel-blueprint", "camel-spring", "camel-jackson"),
features(maven().groupId("org.apache.camel.karaf").artifactId("apache-camel")
.type("xml").classifier("features").versionAsInProject(), "camel",
"camel-blueprint", "camel-spring", "camel-jackson"),
mavenBundle().groupId("org.apache.camel").artifactId("camel-test-karaf").versionAsInProject(),
mavenBundle().groupId("commons-codec").artifactId("commons-codec").version(commonsCodecVersion),
mavenBundle().groupId("org.apache.commons").artifactId("commons-csv").version(commonsCsvVersion),
mavenBundle().groupId("org.apache.commons").artifactId("commons-lang3").version(commonsLang3Version),
mavenBundle().groupId("org.apache.httpcomponents").artifactId("httpclient-osgi").version(httpclientVersion),
mavenBundle().groupId("org.apache.httpcomponents").artifactId("httpcore-osgi").version(httpcoreVersion),
mavenBundle().groupId("org.apache.jena").artifactId("jena-osgi").version(jenaOsgiVersion),
mavenBundle().groupId("org.apache.commons").artifactId("commons-lang3").versionAsInProject(),
mavenBundle().groupId("org.apache.httpcomponents").artifactId("httpclient-osgi").versionAsInProject(),
mavenBundle().groupId("org.apache.httpcomponents").artifactId("httpcore-osgi").versionAsInProject(),
mavenBundle().groupId("org.apache.jena").artifactId("jena-osgi").versionAsInProject(),
mavenBundle().groupId("com.github.jsonld-java").artifactId("jsonld-java").version(jsonldVersion),
mavenBundle().groupId("org.apache.thrift").artifactId("libthrift").version(thriftVersion),
mavenBundle().groupId("org.fcrepo.client").artifactId("fcrepo-java-client").version(javaClientVersion),
mavenBundle().groupId("org.fcrepo.client").artifactId("fcrepo-java-client").versionAsInProject(),
mavenBundle().groupId("com.github.andrewoma.dexx").artifactId("collection").version(dexxVersion),
bundle(fcrepoCamelBundle).start()
};
Expand Down