inteligr8/common-rest-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

moved CXF/Jersey config to common

Browse Source
This commit is contained in:
Brian Long 2021-08-31 13:20:42 -04:00
parent 5564513134
commit 41b7ee255a
5 changed files with 54 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/java/com/inteligr8/rs/ClientConfiguration.java
View File

@ -4,31 +4,31 @@ import java.net.URI;
import javax.ws.rs.client.ClientRequestFilter;
public abstract class ClientConfiguration {
public interface ClientConfiguration {
public abstract String getBaseUrl();
String getBaseUrl();
public abstract String getBasicAuthUsername();
String getBasicAuthUsername();
public abstract String getBasicAuthPassword();
String getBasicAuthPassword();
public abstract String getAccessToken();
String getAccessToken();
public abstract String getOAuthTokenUrl();
String getOAuthTokenUrl();
public abstract String getOAuthClientId();
String getOAuthClientId();
public abstract String getOAuthClientSecret();
String getOAuthClientSecret();
public abstract String getOAuthAuthCode();
String getOAuthAuthCode();
public abstract String getOAuthAuthRedirectUri();
String getOAuthAuthRedirectUri();
public abstract String getOAuthUsername();
String getOAuthUsername();
public abstract String getOAuthPassword();
String getOAuthPassword();
public ClientRequestFilter getAuthorizationFilter() {
default ClientRequestFilter getAuthorizationFilter() {
if (this.getAccessToken() != null) {
return new AccessTokenRequestFilter(this.getAccessToken());
} else if (this.getOAuthTokenUrl() != null) {

9
src/main/java/com/inteligr8/rs/ClientCxfConfiguration.java Normal file
View File

@ -0,0 +1,9 @@
package com.inteligr8.rs;
public interface ClientCxfConfiguration extends ClientConfiguration {
default boolean isDefaultBusEnabled() {
return true;
}
}

12
src/main/java/com/inteligr8/rs/ClientCxfImpl.java
View File

@ -6,6 +6,7 @@ import java.util.List;
import javax.ws.rs.client.ClientRequestFilter;
import javax.ws.rs.ext.RuntimeDelegate;
import org.apache.cxf.BusFactory;
import org.apache.cxf.jaxrs.client.JAXRSClientFactory;
import org.apache.cxf.jaxrs.client.WebClient;
import org.apache.cxf.jaxrs.impl.RuntimeDelegateImpl;
@ -22,6 +23,9 @@ public abstract class ClientCxfImpl extends Client implements InitializingBean {
private final Logger logger = LoggerFactory.getLogger(ClientCxfImpl.class);
@Override
protected abstract ClientCxfConfiguration getConfig();
@Override
public void afterPropertiesSet() {
if (RuntimeDelegate.getInstance() == null) {
@ -50,6 +54,14 @@ public abstract class ClientCxfImpl extends Client implements InitializingBean {
// so we need to create a CXF client
WebClient client = WebClient.create(this.getConfig().getBaseUrl(), providersAndFilters);
if (!this.getConfig().isDefaultBusEnabled()) {
// Some applications (like ACS) add interceptors to the default bus
// those interceptors may treat all messages as SOAP messages (like ACS), resulting in ClassCastExceptions
// we need to ignore the default bus
org.apache.cxf.jaxrs.client.ClientConfiguration config = WebClient.getConfig(client);
config.setBus(BusFactory.newInstance().createBus());
}
return client;
}

9
src/main/java/com/inteligr8/rs/ClientJerseyConfiguration.java Normal file
View File

@ -0,0 +1,9 @@
package com.inteligr8.rs;
public interface ClientJerseyConfiguration extends ClientConfiguration {
default boolean isPutBodyRequired() {
return true;
}
}

14
src/main/java/com/inteligr8/rs/ClientJerseyImpl.java
View File

@ -16,6 +16,9 @@ public abstract class ClientJerseyImpl extends Client implements InitializingBea
private final Logger logger = LoggerFactory.getLogger(ClientJerseyImpl.class);
@Override
protected abstract ClientJerseyConfiguration getConfig();
@Override
public void afterPropertiesSet() {
if (RuntimeDelegate.getInstance() == null) {
@ -34,9 +37,14 @@ public abstract class ClientJerseyImpl extends Client implements InitializingBea
@Override
public javax.ws.rs.client.Client getClient() {
return super.getClient()
// allow PUT operations without body data
.property(ClientProperties.SUPPRESS_HTTP_COMPLIANCE_VALIDATION, true);
javax.ws.rs.client.Client client = super.getClient();
if (!this.getConfig().isPutBodyRequired()) {
// allow PUT operations without body data
client.property(ClientProperties.SUPPRESS_HTTP_COMPLIANCE_VALIDATION, true);
}
return client;
}
@Override