You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2020/10/14 12:55:51 UTC
[camel-quarkus] branch master updated: pgevent: correct service name
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/master by this push:
new 21339ca pgevent: correct service name
21339ca is described below
commit 21339cae11d1b3804c8d0a7f65a6af74f9a349cf
Author: Zineb Bendhiba <be...@gmail.com>
AuthorDate: Wed Oct 14 12:53:49 2020 +0200
pgevent: correct service name
---
.../quarkus/component/pgevent/deployment/PgeventProcessor.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/extensions/pgevent/deployment/src/main/java/org/apache/camel/quarkus/component/pgevent/deployment/PgeventProcessor.java b/extensions/pgevent/deployment/src/main/java/org/apache/camel/quarkus/component/pgevent/deployment/PgeventProcessor.java
index fae15c5..bc841fb 100644
--- a/extensions/pgevent/deployment/src/main/java/org/apache/camel/quarkus/component/pgevent/deployment/PgeventProcessor.java
+++ b/extensions/pgevent/deployment/src/main/java/org/apache/camel/quarkus/component/pgevent/deployment/PgeventProcessor.java
@@ -48,15 +48,15 @@ class PgeventProcessor {
@BuildStep
void registerNativeImageResources(BuildProducer<ServiceProviderBuildItem> services) {
Stream.of(
- PGEVENT_SERVICE_BASE + ProcProvider.class.getName(),
- PGEVENT_SERVICE_BASE + Driver.class.getName())
+ ProcProvider.class.getName(),
+ Driver.class.getName())
.forEach(service -> {
try {
Set<String> implementations = ServiceUtil.classNamesNamedIn(
Thread.currentThread().getContextClassLoader(),
- service);
+ PGEVENT_SERVICE_BASE + service);
services.produce(
- new ServiceProviderBuildItem(ProcProvider.class.getName(),
+ new ServiceProviderBuildItem(service,
implementations.toArray(new String[0])));
} catch (IOException e) {