Skip to content

Commit

Permalink
[KOGITO-5718] Fix bogus Quarkus WARN for namespace clash (#1572)
Browse files Browse the repository at this point in the history
Signed-off-by: Ricardo Zanini <zanini@redhat.com>
  • Loading branch information
ricardozanini authored Sep 6, 2021
1 parent ecf1d33 commit 13ac92a
Show file tree
Hide file tree
Showing 27 changed files with 31 additions and 29 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public class AddonsConfigDiscovery {
private static final String PROMETHEUS_CLASS = "org.kie.kogito.monitoring.prometheus.common.rest.MetricsResource";
private static final String MONITORING_CORE_CLASS = "org.kie.kogito.monitoring.core.common.MonitoringRegistry";
private static final String TRACING_CLASS = "org.kie.kogito.tracing.decision.DecisionTracingListener";
private static final String QUARKUS_CLOUD_EVENTS = "org.kie.kogito.addon.cloudevents.quarkus.QuarkusCloudEventEmitter";
private static final String QUARKUS_CLOUD_EVENTS = "org.kie.kogito.addon.quarkus.messaging.QuarkusCloudEventEmitter";
private static final String SPRING_CLOUD_EVENTS = "org.kie.kogito.addon.cloudevents.spring.SpringKafkaCloudEventEmitter";
private static final String QUARKUS_EXPLAINABILITY = "org.kie.kogito.explainability.QuarkusExplainableResource";
private static final String SPRING_EXPLAINABILITY = "org.kie.kogito.explainability.SpringBootExplainableResource";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

import javax.ws.rs.Path;

import org.kie.kogito.addon.cloudevents.quarkus.http.AbstractQuarkusCloudEventResource;
import org.kie.kogito.addon.quarkus.messaging.common.http.AbstractQuarkusCloudEventResource;

@Path("/")
public class CloudEventListenerResource extends AbstractQuarkusCloudEventResource {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
import org.eclipse.microprofile.reactive.messaging.Emitter;
import org.eclipse.microprofile.reactive.messaging.Message;

import org.kie.kogito.addon.cloudevents.quarkus.AbstractQuarkusCloudEventEmitter;
import org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventEmitter;

import io.quarkus.runtime.Startup;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@

import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.eclipse.microprofile.reactive.messaging.Message;
import org.kie.kogito.addon.cloudevents.quarkus.AbstractQuarkusCloudEventReceiver;
import org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver ;

import io.quarkus.runtime.Startup;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging.common;

import java.util.Optional;
import java.util.concurrent.CompletionStage;
Expand All @@ -24,7 +24,7 @@
import javax.inject.Inject;

import org.eclipse.microprofile.reactive.messaging.Message;
import org.kie.kogito.addon.cloudevents.quarkus.message.MessageFactory;
import org.kie.kogito.addon.quarkus.messaging.common.message.MessageFactory;
import org.kie.kogito.conf.ConfigBean;
import org.kie.kogito.event.EventEmitter;
import org.kie.kogito.event.EventMarshaller;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging.common;

import java.io.IOException;
import java.util.Collection;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging.common;

import javax.annotation.PostConstruct;
import javax.inject.Inject;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging.common;

import java.util.ArrayList;
import java.util.List;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging.common;

import javax.annotation.PostConstruct;
import javax.enterprise.context.ApplicationScoped;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.http;
package org.kie.kogito.addon.quarkus.messaging.common.http;

import java.io.IOException;
import java.util.concurrent.CompletableFuture;
Expand All @@ -28,7 +28,7 @@
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import org.kie.kogito.addon.cloudevents.quarkus.AbstractQuarkusCloudEventReceiver;
import org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver;
import org.kie.kogito.cloudevents.Printer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.http;
package org.kie.kogito.addon.quarkus.messaging.common.http;

import io.cloudevents.CloudEvent;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.http;
package org.kie.kogito.addon.quarkus.messaging.common.http;

import javax.enterprise.context.Dependent;
import javax.ws.rs.core.Response;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.http;
package org.kie.kogito.addon.quarkus.messaging.common.http;

/**
* Simple structure to hold CloudEvent processing errors
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.http;
package org.kie.kogito.addon.quarkus.messaging.common.http;

import javax.ws.rs.core.Response;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.message;
package org.kie.kogito.addon.quarkus.messaging.common.message;

import javax.ws.rs.core.HttpHeaders;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.message;
package org.kie.kogito.addon.quarkus.messaging.common.message;

import org.eclipse.microprofile.reactive.messaging.Message;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.message;
package org.kie.kogito.addon.quarkus.messaging.common.message;

/**
* Provides a {@link MessageDecorator} instance. Ideally should not be used outside the {@link MessageFactory}.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.message;
package org.kie.kogito.addon.quarkus.messaging.common.message;

import org.eclipse.microprofile.reactive.messaging.Message;
import org.kie.kogito.addon.cloudevents.message.MessagePayloadDecorator;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.message;
package org.kie.kogito.addon.quarkus.messaging.common.message;

import org.eclipse.microprofile.reactive.messaging.Message;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging.common;

import java.util.ArrayList;
import java.util.Collections;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.http;
package org.kie.kogito.addon.quarkus.messaging.common.http;

import javax.ws.rs.core.Response;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.message;
package org.kie.kogito.addon.quarkus.messaging.common.message;

import org.eclipse.microprofile.reactive.messaging.Message;
import org.junit.jupiter.api.Test;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus.message;
package org.kie.kogito.addon.quarkus.messaging.common.message;

import org.junit.jupiter.api.Test;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging;

import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;
Expand All @@ -22,6 +22,7 @@
import org.eclipse.microprofile.config.ConfigProvider;
import org.eclipse.microprofile.reactive.messaging.Emitter;
import org.eclipse.microprofile.reactive.messaging.Message;
import org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventEmitter;
import org.kie.kogito.event.KogitoEventStreams;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.kie.kogito.addon.cloudevents.quarkus;
package org.kie.kogito.addon.quarkus.messaging;

import java.lang.reflect.Method;
import java.util.Collections;
Expand All @@ -29,6 +29,7 @@
import org.eclipse.microprofile.reactive.messaging.Acknowledgment;
import org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy;
import org.eclipse.microprofile.reactive.messaging.Message;
import org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver;
import org.kie.kogito.event.KogitoEventStreams;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
import javax.ws.rs.Path;
import javax.ws.rs.core.Response;

import org.kie.kogito.addon.cloudevents.quarkus.http.AbstractQuarkusCloudEventResource;
import org.kie.kogito.addon.quarkus.messaging.common.http.AbstractQuarkusCloudEventResource;

import io.cloudevents.CloudEvent;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ public void test() {
KogitoExtension kogitoExtension = ExtensionProvider.getInstance().parseExtension(KogitoExtension.class, event);

assertNotNull(kogitoExtension, "KogitoExtension not registered, please make sure " +
"bean org.kie.kogito.addon.cloudevents.quarkus.QuarkusKogitoExtensionInitializer has been loaded");
"bean org.kie.kogito.addon.quarkus.messaging.common.QuarkusKogitoExtensionInitializer has been loaded");
assertEquals(DecisionTestUtils.MODEL_NAME, kogitoExtension.getDmnModelName());
assertEquals(DecisionTestUtils.MODEL_NAMESPACE, kogitoExtension.getDmnModelNamespace());
}
Expand Down

0 comments on commit 13ac92a

Please sign in to comment.