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 2021/10/05 07:10:27 UTC
[camel-quarkus] branch main updated (045d2a5 -> f7ec28a)
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.
from 045d2a5 Updated CHANGELOG.md
new 934adba Remove workaround for gRPC producers with TLS
new 4a58af3 Enable sqsAutoCreateDelayedQueue test
new c35fb6f Remove reflective class registration for subclasses of ServiceCallConfiguration
new f7ec28a Remove redundant reflective class configuration for ThreadPoolProfileConfigurationProperties
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../core/cloud/deployment/CloudProcessor.java | 17 --
.../main/CamelMainNativeImageProcessor.java | 4 -
.../component/grpc/deployment/GrpcProcessor.java | 14 --
.../quarkus/grpc/runtime/CamelGrpcRecorder.java | 223 ---------------------
.../component/aws2/sqs/it/Aws2SqsSnsResource.java | 2 +-
.../component/aws2/sqs/it/Aws2SqsSnsTest.java | 6 +-
6 files changed, 3 insertions(+), 263 deletions(-)
delete mode 100644 extensions/grpc/runtime/src/main/java/org/apache/camel/quarkus/grpc/runtime/CamelGrpcRecorder.java
[camel-quarkus] 03/04: Remove reflective class registration for
subclasses of ServiceCallConfiguration
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit c35fb6f4f9f05121955710a0d8c0dccf8e61113a
Author: James Netherton <ja...@gmail.com>
AuthorDate: Mon Oct 4 15:45:02 2021 +0100
Remove reflective class registration for subclasses of ServiceCallConfiguration
Fixes #2955
---
.../quarkus/core/cloud/deployment/CloudProcessor.java | 17 -----------------
1 file changed, 17 deletions(-)
diff --git a/extensions-core/core-cloud/deployment/src/main/java/org/apache/camel/quarkus/core/cloud/deployment/CloudProcessor.java b/extensions-core/core-cloud/deployment/src/main/java/org/apache/camel/quarkus/core/cloud/deployment/CloudProcessor.java
index 7c0d620..87ee69c 100644
--- a/extensions-core/core-cloud/deployment/src/main/java/org/apache/camel/quarkus/core/cloud/deployment/CloudProcessor.java
+++ b/extensions-core/core-cloud/deployment/src/main/java/org/apache/camel/quarkus/core/cloud/deployment/CloudProcessor.java
@@ -18,13 +18,8 @@ package org.apache.camel.quarkus.core.cloud.deployment;
import io.quarkus.deployment.annotations.BuildProducer;
import io.quarkus.deployment.annotations.BuildStep;
-import io.quarkus.deployment.builditem.CombinedIndexBuildItem;
-import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
-import org.apache.camel.model.cloud.ServiceCallConfiguration;
import org.apache.camel.quarkus.core.deployment.spi.CamelServiceDestination;
import org.apache.camel.quarkus.core.deployment.spi.CamelServicePatternBuildItem;
-import org.jboss.jandex.DotName;
-import org.jboss.jandex.IndexView;
class CloudProcessor {
@BuildStep
@@ -35,16 +30,4 @@ class CloudProcessor {
"META-INF/services/org/apache/camel/cloud/*"));
}
-
- @BuildStep
- void reflectiveClasses(BuildProducer<ReflectiveClassBuildItem> reflectiveClass,
- CombinedIndexBuildItem combinedIndexBuildItem) {
- // TODO: remove when https://github.com/apache/camel-quarkus/issues/2955 is fixed
- IndexView index = combinedIndexBuildItem.getIndex();
- index.getAllKnownSubclasses(DotName.createSimple(ServiceCallConfiguration.class.getName()))
- .stream()
- .map(classInfo -> new ReflectiveClassBuildItem(true, false, classInfo.name().toString()))
- .forEach(reflectiveClass::produce);
- }
-
}
[camel-quarkus] 01/04: Remove workaround for gRPC producers with TLS
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 934adba40096d039b0438b1ae939d26aeb20a913
Author: James Netherton <ja...@gmail.com>
AuthorDate: Mon Oct 4 15:08:55 2021 +0100
Remove workaround for gRPC producers with TLS
Fixes #2966
---
.../component/grpc/deployment/GrpcProcessor.java | 10 -
.../quarkus/grpc/runtime/CamelGrpcRecorder.java | 223 ---------------------
2 files changed, 233 deletions(-)
diff --git a/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java b/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java
index fa09738..0450c67 100644
--- a/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java
+++ b/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java
@@ -46,7 +46,6 @@ import io.quarkus.gizmo.ResultHandle;
import org.apache.camel.component.grpc.GrpcComponent;
import org.apache.camel.component.grpc.server.GrpcMethodHandler;
import org.apache.camel.quarkus.core.deployment.spi.CamelBeanBuildItem;
-import org.apache.camel.quarkus.grpc.runtime.CamelGrpcRecorder;
import org.apache.camel.quarkus.grpc.runtime.CamelQuarkusBindableService;
import org.apache.camel.quarkus.grpc.runtime.QuarkusBindableServiceFactory;
import org.jboss.jandex.ClassInfo;
@@ -90,15 +89,6 @@ class GrpcProcessor {
}
@BuildStep
- @Record(ExecutionTime.STATIC_INIT)
- CamelBeanBuildItem createGrpcComponent(CamelGrpcRecorder recorder) {
- return new CamelBeanBuildItem(
- "grpc",
- GrpcComponent.class.getName(),
- recorder.createGrpcComponent());
- }
-
- @BuildStep
void createBindableServiceBeans(
BuildProducer<GeneratedBeanBuildItem> generatedBean,
BuildProducer<ReflectiveClassBuildItem> reflectiveClass,
diff --git a/extensions/grpc/runtime/src/main/java/org/apache/camel/quarkus/grpc/runtime/CamelGrpcRecorder.java b/extensions/grpc/runtime/src/main/java/org/apache/camel/quarkus/grpc/runtime/CamelGrpcRecorder.java
deleted file mode 100644
index 79b139a..0000000
--- a/extensions/grpc/runtime/src/main/java/org/apache/camel/quarkus/grpc/runtime/CamelGrpcRecorder.java
+++ /dev/null
@@ -1,223 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.quarkus.grpc.runtime;
-
-import java.util.Map;
-
-import com.google.auth.Credentials;
-import com.google.auth.oauth2.GoogleCredentials;
-import io.grpc.CallCredentials;
-import io.grpc.ManagedChannel;
-import io.grpc.auth.MoreCallCredentials;
-import io.grpc.netty.GrpcSslContexts;
-import io.grpc.netty.NegotiationType;
-import io.grpc.netty.NettyChannelBuilder;
-import io.grpc.stub.StreamObserver;
-import io.netty.handler.ssl.SslContextBuilder;
-import io.netty.handler.ssl.SslProvider;
-import io.quarkus.runtime.RuntimeValue;
-import io.quarkus.runtime.annotations.Recorder;
-import org.apache.camel.AsyncCallback;
-import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
-import org.apache.camel.Producer;
-import org.apache.camel.component.grpc.GrpcAuthType;
-import org.apache.camel.component.grpc.GrpcComponent;
-import org.apache.camel.component.grpc.GrpcConfiguration;
-import org.apache.camel.component.grpc.GrpcEndpoint;
-import org.apache.camel.component.grpc.GrpcProducer;
-import org.apache.camel.component.grpc.GrpcUtils;
-import org.apache.camel.component.grpc.auth.jwt.JwtCallCredentials;
-import org.apache.camel.component.grpc.auth.jwt.JwtHelper;
-import org.apache.camel.component.grpc.client.GrpcExchangeForwarder;
-import org.apache.camel.component.grpc.client.GrpcExchangeForwarderFactory;
-import org.apache.camel.component.grpc.client.GrpcResponseAggregationStreamObserver;
-import org.apache.camel.component.grpc.client.GrpcResponseRouterStreamObserver;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.camel.support.ResourceHelper;
-import org.apache.camel.support.SynchronousDelegateProducer;
-import org.apache.camel.support.service.ServiceHelper;
-import org.apache.camel.util.ObjectHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@Recorder
-public class CamelGrpcRecorder {
-
- public RuntimeValue<GrpcComponent> createGrpcComponent() {
- return new RuntimeValue<>(new QuarkusGrpcComponent());
- }
-
- @Component("grpc")
- static final class QuarkusGrpcComponent extends GrpcComponent {
-
- @Override
- protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
- GrpcConfiguration config = new GrpcConfiguration();
- config = parseConfiguration(config, uri);
-
- Endpoint endpoint = new QuarkusGrpcEndpoint(uri, this, config);
- setProperties(endpoint, parameters);
- return endpoint;
- }
- }
-
- static final class QuarkusGrpcEndpoint extends GrpcEndpoint {
-
- public QuarkusGrpcEndpoint(String uri, GrpcComponent component, GrpcConfiguration config) throws Exception {
- super(uri, component, config);
- }
-
- public Producer createProducer() throws Exception {
- GrpcProducer producer = new QuarkusGrpcProducer(this, this.configuration);
- return this.configuration.isSynchronous() ? new SynchronousDelegateProducer(producer) : producer;
- }
- }
-
- // Allow producer SSL configuration to do fallback when unsupported native providers are specified
- // Most of GrpcProducer is reproduced due to much of the configuration being done by directly accessing private fields
- // TODO: Remove when https://github.com/apache/camel-quarkus/issues/2966 is resolved
- static final class QuarkusGrpcProducer extends GrpcProducer {
-
- private static final Logger LOG = LoggerFactory.getLogger(QuarkusGrpcProducer.class);
- private ManagedChannel channel;
- private Object grpcStub;
- private GrpcExchangeForwarder forwarder;
- private GrpcResponseRouterStreamObserver globalResponseObserver;
-
- public QuarkusGrpcProducer(GrpcEndpoint endpoint, GrpcConfiguration configuration) {
- super(endpoint, configuration);
- }
-
- @Override
- protected void doStart() throws Exception {
- if (channel == null) {
- CallCredentials callCreds = null;
- initializeChannel();
-
- if (configuration.getAuthenticationType() == GrpcAuthType.GOOGLE) {
- ObjectHelper.notNull(configuration.getKeyCertChainResource(), "serviceAccountResource");
-
- Credentials creds = GoogleCredentials.fromStream(
- ResourceHelper.resolveResourceAsInputStream(endpoint.getCamelContext(),
- configuration.getServiceAccountResource()));
- callCreds = MoreCallCredentials.from(creds);
- } else if (configuration.getAuthenticationType() == GrpcAuthType.JWT) {
- ObjectHelper.notNull(configuration.getJwtSecret(), "jwtSecret");
-
- String jwtToken = JwtHelper.createJwtToken(configuration.getJwtAlgorithm(), configuration.getJwtSecret(),
- configuration.getJwtIssuer(), configuration.getJwtSubject());
- callCreds = new JwtCallCredentials(jwtToken);
- }
-
- if (configuration.isSynchronous()) {
- LOG.debug("Getting synchronous method stub from channel");
- grpcStub = GrpcUtils.constructGrpcBlockingStub(endpoint.getServicePackage(), endpoint.getServiceName(),
- channel,
- callCreds, endpoint.getCamelContext());
- } else {
- LOG.debug("Getting asynchronous method stub from channel");
- grpcStub = GrpcUtils.constructGrpcAsyncStub(endpoint.getServicePackage(), endpoint.getServiceName(),
- channel,
- callCreds, endpoint.getCamelContext());
- }
- forwarder = GrpcExchangeForwarderFactory.createExchangeForwarder(configuration, grpcStub);
-
- if (configuration.getStreamRepliesTo() != null) {
- this.globalResponseObserver = new GrpcResponseRouterStreamObserver(configuration, getEndpoint());
- }
-
- if (this.globalResponseObserver != null) {
- ServiceHelper.startService(this.globalResponseObserver);
- }
- }
- }
-
- @Override
- protected void doStop() throws Exception {
- if (this.globalResponseObserver != null) {
- ServiceHelper.stopService(this.globalResponseObserver);
- }
- if (channel != null) {
- forwarder.shutdown();
- forwarder = null;
-
- LOG.debug("Terminating channel to the remote gRPC server");
- channel.shutdown().shutdownNow();
- channel = null;
- grpcStub = null;
- globalResponseObserver = null;
- }
- super.doStop();
- }
-
- @Override
- protected void initializeChannel() throws Exception {
- NettyChannelBuilder channelBuilder;
-
- if (!ObjectHelper.isEmpty(configuration.getHost()) && !ObjectHelper.isEmpty(configuration.getPort())) {
- LOG.info("Creating channel to the remote gRPC server {}:{}", configuration.getHost(), configuration.getPort());
- channelBuilder = NettyChannelBuilder.forAddress(configuration.getHost(), configuration.getPort());
- } else {
- throw new IllegalArgumentException("No connection properties (host or port) specified");
- }
- if (configuration.getNegotiationType() == NegotiationType.TLS) {
- ObjectHelper.notNull(configuration.getKeyCertChainResource(), "keyCertChainResource");
- ObjectHelper.notNull(configuration.getKeyResource(), "keyResource");
-
- SslContextBuilder sslContextBuilder = GrpcSslContexts.forClient()
- .sslProvider(SslProvider.OPENSSL)
- .keyManager(
- ResourceHelper.resolveResourceAsInputStream(endpoint.getCamelContext(),
- configuration.getKeyCertChainResource()),
- ResourceHelper.resolveResourceAsInputStream(endpoint.getCamelContext(),
- configuration.getKeyResource()),
- configuration.getKeyPassword());
-
- if (ObjectHelper.isNotEmpty(configuration.getTrustCertCollectionResource())) {
- sslContextBuilder = sslContextBuilder
- .trustManager(ResourceHelper.resolveResourceAsInputStream(endpoint.getCamelContext(),
- configuration.getTrustCertCollectionResource()));
- }
-
- channelBuilder = channelBuilder.sslContext(GrpcSslContexts.configure(sslContextBuilder).build());
- }
-
- channel = channelBuilder.negotiationType(configuration.getNegotiationType())
- .flowControlWindow(configuration.getFlowControlWindow())
- .userAgent(configuration.getUserAgent())
- .maxInboundMessageSize(configuration.getMaxMessageSize())
- .intercept(configuration.getClientInterceptors())
- .build();
- }
-
- @Override
- public boolean process(Exchange exchange, AsyncCallback callback) {
- StreamObserver<Object> streamObserver = this.globalResponseObserver;
- if (globalResponseObserver == null) {
- streamObserver = new GrpcResponseAggregationStreamObserver(exchange, callback);
- }
-
- return forwarder.forward(exchange, streamObserver, callback);
- }
-
- @Override
- public void process(Exchange exchange) throws Exception {
- forwarder.forward(exchange);
- }
- }
-}
[camel-quarkus] 02/04: Enable sqsAutoCreateDelayedQueue test
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 4a58af3a9886f2f86381c0a085a8595456747fb3
Author: James Netherton <ja...@gmail.com>
AuthorDate: Mon Oct 4 15:26:58 2021 +0100
Enable sqsAutoCreateDelayedQueue test
Fixes #3097
---
.../camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java | 2 +-
.../apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java | 6 ++----
2 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java b/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java
index f1c3021..5435ef7 100644
--- a/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java
+++ b/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java
@@ -174,7 +174,7 @@ public class Aws2SqsSnsResource {
}
@Path("/sqs/queue/autocreate/delayed/{queueName}/{delay}")
- @GET
+ @POST
@Produces(MediaType.APPLICATION_JSON)
public List<String> autoCreateDelayedQueue(@PathParam("queueName") String queueName, @PathParam("delay") String delay)
throws Exception {
diff --git a/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java b/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java
index 7f41c1b..96e766c 100644
--- a/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java
+++ b/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java
@@ -34,7 +34,6 @@ import org.awaitility.Awaitility;
import org.eclipse.microprofile.config.ConfigProvider;
import org.hamcrest.Matchers;
import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import static org.hamcrest.CoreMatchers.anyOf;
@@ -103,7 +102,6 @@ class Aws2SqsSnsTest {
}
@Test
- @Disabled("https://github.com/apache/camel-quarkus/issues/3097")
public void sqsAutoCreateDelayedQueue() {
final String qName = "delayQueue";
final int delay = 10;
@@ -129,7 +127,7 @@ class Aws2SqsSnsTest {
}
private void deleteQueue(String queueName) {
- RestAssured.get("/aws2-sqs-sns/sqs/delete/queue/" + queueName)
+ RestAssured.delete("/aws2-sqs-sns/sqs/delete/queue/" + queueName)
.then()
.statusCode(200);
awaitQueueDeleted(queueName);
@@ -137,7 +135,7 @@ class Aws2SqsSnsTest {
private void awaitQueueDeleted(String queueName) {
Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120, TimeUnit.SECONDS).until(
- () -> Stream.of(listQueues()).peek(System.out::println).noneMatch(url -> url.contains(queueName)));
+ () -> Stream.of(listQueues()).noneMatch(url -> url.contains(queueName)));
}
private String receiveMessageFromQueue(String queueName) {
[camel-quarkus] 04/04: Remove redundant reflective class
configuration for ThreadPoolProfileConfigurationProperties
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit f7ec28a399bfbb5e88dd855cf7bbadc719e80351
Author: James Netherton <ja...@gmail.com>
AuthorDate: Mon Oct 4 15:54:13 2021 +0100
Remove redundant reflective class configuration for ThreadPoolProfileConfigurationProperties
Fixes #2828
---
.../quarkus/core/deployment/main/CamelMainNativeImageProcessor.java | 4 ----
.../apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java | 4 ----
2 files changed, 8 deletions(-)
diff --git a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/main/CamelMainNativeImageProcessor.java b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/main/CamelMainNativeImageProcessor.java
index 870ccc3..430ed2b 100644
--- a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/main/CamelMainNativeImageProcessor.java
+++ b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/main/CamelMainNativeImageProcessor.java
@@ -24,7 +24,6 @@ import io.quarkus.deployment.annotations.BuildProducer;
import io.quarkus.deployment.annotations.BuildStep;
import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem;
import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
-import org.apache.camel.main.ThreadPoolProfileConfigurationProperties;
import org.apache.camel.quarkus.core.deployment.main.spi.CamelMainEnabled;
import org.apache.camel.support.ResourceHelper;
import org.apache.camel.util.AntPathMatcher;
@@ -45,9 +44,6 @@ public class CamelMainNativeImageProcessor {
org.apache.camel.model.Resilience4jConfigurationCommon.class,
org.apache.camel.spi.RestConfiguration.class,
org.apache.camel.quarkus.main.CamelMainApplication.class));
-
- // Needed for camel.threadpool.* properties
- producer.produce(new ReflectiveClassBuildItem(true, false, ThreadPoolProfileConfigurationProperties.class));
}
@BuildStep(onlyIf = CamelMainEnabled.class)
diff --git a/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java b/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java
index 0450c67..ec0efa7 100644
--- a/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java
+++ b/extensions/grpc/deployment/src/main/java/org/apache/camel/quarkus/component/grpc/deployment/GrpcProcessor.java
@@ -33,8 +33,6 @@ import io.quarkus.arc.deployment.GeneratedBeanBuildItem;
import io.quarkus.arc.deployment.GeneratedBeanGizmoAdaptor;
import io.quarkus.deployment.annotations.BuildProducer;
import io.quarkus.deployment.annotations.BuildStep;
-import io.quarkus.deployment.annotations.ExecutionTime;
-import io.quarkus.deployment.annotations.Record;
import io.quarkus.deployment.builditem.CombinedIndexBuildItem;
import io.quarkus.deployment.builditem.FeatureBuildItem;
import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
@@ -43,9 +41,7 @@ import io.quarkus.gizmo.FieldCreator;
import io.quarkus.gizmo.MethodCreator;
import io.quarkus.gizmo.MethodDescriptor;
import io.quarkus.gizmo.ResultHandle;
-import org.apache.camel.component.grpc.GrpcComponent;
import org.apache.camel.component.grpc.server.GrpcMethodHandler;
-import org.apache.camel.quarkus.core.deployment.spi.CamelBeanBuildItem;
import org.apache.camel.quarkus.grpc.runtime.CamelQuarkusBindableService;
import org.apache.camel.quarkus.grpc.runtime.QuarkusBindableServiceFactory;
import org.jboss.jandex.ClassInfo;