* ============LICENSE_START=======================================================
* feature-healthcheck
* ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
for (HttpServletServer server : servers) {
if (server.isAaf()) {
- server.addFilterClass(null, AafHealthCheckFilter.class.getCanonicalName());
+ server.addFilterClass(null, AafHealthCheckFilter.class.getName());
}
startServer(server);
}
@Override
public boolean ownsCoder(Class<? extends Object> coderClass, int modelHash) {
- if (!ReflectionUtil.isClass(this.policyContainer.getClassLoader(), coderClass.getCanonicalName())) {
- logger.error("{}{} cannot be retrieved. ", this, coderClass.getCanonicalName());
+ if (!ReflectionUtil.isClass(this.policyContainer.getClassLoader(), coderClass.getName())) {
+ logger.error("{}{} cannot be retrieved. ", this, coderClass.getName());
return false;
}
if (modelHash == this.modelClassLoaderHash) {
if (logger.isInfoEnabled()) {
- logger.info(coderClass.getCanonicalName()
+ logger.info(coderClass.getName()
+ this + " class loader matches original drools controller rules classloader "
+ coderClass.getClassLoader());
}
return true;
} else {
if (logger.isWarnEnabled()) {
- logger.warn(this + coderClass.getCanonicalName() + " class loaders don't match "
+ logger.warn(this + coderClass.getName() + " class loaders don't match "
+ coderClass.getClassLoader() + " vs "
+ this.policyContainer.getClassLoader());
}
@Override
public <T> List<T> facts(@NonNull String sessionName, @NonNull Class<T> clazz) {
- return facts(sessionName, clazz.getCanonicalName(), false)
+ return facts(sessionName, clazz.getName(), false)
.stream()
.filter(clazz::isInstance)
.map(clazz::cast)
}
private String makeInvokeMsg() {
- return this.getClass().getCanonicalName() + " invoked";
+ return this.getClass().getName() + " invoked";
}
}
throw new IllegalArgumentException("Invalid topic");
}
- String reverseKey = this.reverseCodersKey(topic, event.getClass().getCanonicalName());
+ String reverseKey = this.reverseCodersKey(topic, event.getClass().getName());
if (!this.reverseCoders.containsKey(reverseKey)) {
throw new IllegalArgumentException("no reverse coder has been found");
}
List<DroolsController> droolsControllers = new ArrayList<>();
- String reverseKey = this.reverseCodersKey(topic, encodedClass.getClass().getCanonicalName());
+ String reverseKey = this.reverseCodersKey(topic, encodedClass.getClass().getName());
if (!this.reverseCoders.containsKey(reverseKey)) {
logger.warn("{}: no reverse mapping for {}", this, reverseKey);
return droolsControllers;
"No Encoders toolsets available for topic "
+ topic
+ " encoder "
- + encodedClass.getClass().getCanonicalName());
+ + encodedClass.getClass().getName());
}
for (ProtocolCoderToolset encoderSet : toolsets) {
String artifactId = encoderSet.getArtifactId();
List<CoderFilters> coderFilters = encoderSet.getCoders();
for (CoderFilters coder : coderFilters) {
- if (coder.getCodedClass().equals(encodedClass.getClass().getCanonicalName())) {
+ if (coder.getCodedClass().equals(encodedClass.getClass().getName())) {
DroolsController droolsController = DroolsController.factory.get(groupId, artifactId, "");
if (droolsController.ownsCoder(
encodedClass.getClass(), coder.getModelClassLoaderHash())) {
"No Encoders toolsets available for "
+ topic
+ ":"
- + encodedClass.getClass().getCanonicalName());
+ + encodedClass.getClass().getName());
}
return droolsControllers;
this,
droolsControllers,
topic,
- fact.getClass().getCanonicalName());
+ fact.getClass().getName());
// continue
}
return droolsControllers.get(0);
this,
droolsControllers,
topic,
- fact.getClass().getCanonicalName());
+ fact.getClass().getName());
// continue
}
return droolsControllers;
this.httpServers = getServletFactory().build(properties);
for (HttpServletServer server : this.httpServers) {
if (server.isAaf()) {
- server.addFilterClass(null, AafTelemetryAuthFilter.class.getCanonicalName());
+ server.addFilterClass(null, AafTelemetryAuthFilter.class.getName());
}
}
} catch (final IllegalArgumentException e) {
@Test(expected = IllegalArgumentException.class)
public void fetchModelClass() {
- new NullDroolsController().fetchModelClass(this.getClass().getCanonicalName());
+ new NullDroolsController().fetchModelClass(this.getClass().getName());
}
@Test
public void factQuery() {
Assert.assertTrue(new NullDroolsController().factQuery(null, null, null, false).isEmpty());
}
-}
\ No newline at end of file
+}
EventProtocolCoder.manager.addEncoder(
EventProtocolParams.builder().groupId(ENCODER_GROUP).artifactId(ENCODER_ARTIFACT)
- .topic(NOOP_TOPIC).eventClass(DroolsConfiguration.class.getCanonicalName())
+ .topic(NOOP_TOPIC).eventClass(DroolsConfiguration.class.getName())
.protocolFilter(new JsonProtocolFilter()).customGsonCoder(null)
.modelClassLoaderHash(DroolsConfiguration.class.getName().hashCode()));
EventProtocolParams.builder().topic(JUNIT_PROTOCOL_CODER_TOPIC)
.groupId(this.releaseId.getGroupId())
.artifactId(this.releaseId.getArtifactId())
- .eventClass(Triple.class.getCanonicalName())
+ .eventClass(Triple.class.getName())
.protocolFilter(protocolFilter)
.customGsonCoder(null)
.modelClassLoaderHash(12345678), CONTROLLER_ID);
testToolset(protocolFilter, gsonToolset);
Triple<String, String, String> triple = createTriple();
- gsonToolset.setCustomCoder(new CustomGsonCoder(this.getClass().getCanonicalName(), "customCoder"));
+ gsonToolset.setCustomCoder(new CustomGsonCoder(this.getClass().getName(), "customCoder"));
String tripleEncoded = encode(gsonToolset, triple);
decode(protocolFilter, gsonToolset, triple, tripleEncoded);
}
addRemoveCoder(coderToolset);
/* restore original filters */
- coderToolset.addCoder(Triple.class.getCanonicalName(), protocolFilter, 654321);
+ coderToolset.addCoder(Triple.class.getName(), protocolFilter, 654321);
Triple<String, String, String> triple = createTriple();
logger.trace("Junit expected exception - decode does not pass filtering", e);
}
- CoderFilters coderFilters = coderToolset.getCoder(Triple.class.getCanonicalName());
- Assert.assertTrue(coderFilters.getCodedClass() == Triple.class.getCanonicalName());
+ CoderFilters coderFilters = coderToolset.getCoder(Triple.class.getName());
+ Assert.assertTrue(coderFilters.getCodedClass() == Triple.class.getName());
Assert.assertTrue(coderFilters.getFilter() == protocolFilter);
Assert.assertTrue(coderFilters.getFilter().getRule() != null);
}
private void addRemoveCoder(ProtocolCoderToolset coderToolset) {
- coderToolset.addCoder(this.getClass().getCanonicalName(),
+ coderToolset.addCoder(this.getClass().getName(),
new JsonProtocolFilter("[?($.second =~ /.*/)]"), 654321);
Assert.assertTrue(coderToolset.getCoders().size() == 2);
- coderToolset.removeCoders(this.getClass().getCanonicalName());
+ coderToolset.removeCoders(this.getClass().getName());
Assert.assertTrue(coderToolset.getCoders().size() == 1);
}
private void updateCoderFilterRule(ProtocolCoderToolset coderToolset) {
- coderToolset.addCoder(Triple.class.getCanonicalName(), new JsonProtocolFilter("[?($.third =~ /.*/)]"), 654321);
+ coderToolset.addCoder(Triple.class.getName(), new JsonProtocolFilter("[?($.third =~ /.*/)]"), 654321);
Assert.assertTrue(coderToolset.getCoders().size() == 1);
- Assert.assertTrue(coderToolset.getCoder(Triple.class.getCanonicalName()).getModelClassLoaderHash() == 654321);
+ Assert.assertTrue(coderToolset.getCoder(Triple.class.getName()).getModelClassLoaderHash() == 654321);
Assert.assertTrue(
coderToolset.getCoder(
- Triple.class.getCanonicalName()).getFilter().getRule() != null);
+ Triple.class.getName()).getFilter().getRule() != null);
- Assert.assertTrue("[?($.third =~ /.*/)]".equals(coderToolset.getCoder(Triple.class.getCanonicalName())
+ Assert.assertTrue("[?($.third =~ /.*/)]".equals(coderToolset.getCoder(Triple.class.getName())
.getFilter().getRule()));
}
CoderFilters coderFilters = coderToolset.getCoder(CONTROLLER_ID);
Assert.assertTrue(coderFilters == null);
- coderFilters = coderToolset.getCoder(Triple.class.getCanonicalName());
+ coderFilters = coderToolset.getCoder(Triple.class.getName());
Assert.assertNotNull(coderFilters);
Assert.assertEquals(coderFilters.getFilter(), protocolFilter);
droolsControllerConfig.put(DroolsProperties.RULES_ARTIFACTID, releaseId.getArtifactId());
droolsControllerConfig.put(DroolsProperties.RULES_VERSION, releaseId.getVersion());
droolsControllerConfig.put(PolicyEndPointProperties.PROPERTY_NOOP_SINK_TOPICS + "." + JUNIT_PROTOCOL_CODER_TOPIC
- + PolicyEndPointProperties.PROPERTY_TOPIC_EVENTS_SUFFIX, Triple.class.getCanonicalName());
+ + PolicyEndPointProperties.PROPERTY_TOPIC_EVENTS_SUFFIX, Triple.class.getName());
DroolsController.factory.build(droolsControllerConfig, null, noopTopics);
}
EventProtocolCoder.manager.addEncoder(
EventProtocolParams.builder().groupId(ENCODER_GROUP).artifactId(ENCODER_ARTIFACT)
- .topic(NOOP_TOPIC).eventClass(DroolsConfiguration.class.getCanonicalName())
+ .topic(NOOP_TOPIC).eventClass(DroolsConfiguration.class.getName())
.protocolFilter(new JsonProtocolFilter()).customGsonCoder(null)
.modelClassLoaderHash(DroolsConfiguration.class.getName().hashCode()));