Removed references to TransportClientPoolExhaustedException from Java…

…doc and cleanup Signed-off-by: Alberto Codutti <alberto.codutti@eurotech.com>
eclipse · Aug 2, 2023 · be33460 · be33460
1 parent c514147
commit be33460
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 9 deletions.
diff --git a/...all/kura/src/main/java/org/eclipse/kapua/service/device/call/kura/KuraDeviceCallImpl.java b/...all/kura/src/main/java/org/eclipse/kapua/service/device/call/kura/KuraDeviceCallImpl.java
@@ -40,7 +40,6 @@
 import org.eclipse.kapua.transport.TransportClientFactory;
 import org.eclipse.kapua.transport.TransportFacade;
 import org.eclipse.kapua.transport.exception.TransportClientGetException;
-import org.eclipse.kapua.transport.exception.TransportClientPoolExhaustedException;
 import org.eclipse.kapua.transport.exception.TransportException;
 import org.eclipse.kapua.transport.exception.TransportTimeoutException;
 import org.eclipse.kapua.transport.message.TransportMessage;
@@ -194,8 +193,8 @@ protected KuraResponseMessage sendInternal(@NotNull KuraRequestMessage requestMe
      *
      * @param kuraRequestMessage The {@link KuraRequestMessage} to send.
      * @return The {@link TransportFacade} to use to send the {@link KuraResponseMessage}.
-     * @throws TransportClientPoolExhaustedException If a {@link TransportFacade} cannot be obtained within the configured timeout.
-     * @throws TransportClientGetException           If getting the {@link TransportFacade} causes an {@link Exception}.
+     * @throws TransportClientGetException If getting the {@link TransportFacade} causes an {@link Exception}.
+     * @throws TransportException          For all other errors
      * @since 1.0.0
      */
     protected TransportFacade<?, ?, ?, ?> borrowClient(KuraRequestMessage kuraRequestMessage) throws TransportException {

diff --git a/transport/api/src/main/java/org/eclipse/kapua/transport/TransportClientFactory.java b/transport/api/src/main/java/org/eclipse/kapua/transport/TransportClientFactory.java
@@ -15,7 +15,6 @@
 import org.eclipse.kapua.KapuaException;
 import org.eclipse.kapua.model.KapuaObjectFactory;
 import org.eclipse.kapua.transport.exception.TransportClientGetException;
-import org.eclipse.kapua.transport.exception.TransportClientPoolExhaustedException;
 import org.eclipse.kapua.transport.exception.TransportException;
 import org.eclipse.kapua.transport.message.TransportChannel;
 import org.eclipse.kapua.transport.message.TransportMessage;
@@ -45,8 +44,7 @@ public interface TransportClientFactory<C extends TransportChannel, P extends Tr
      *
      * @param configParameters a {@link Map} containing optional config values for the facade
      * @return An instance of the {@link TransportFacade} implementing class.
-     * @throws TransportClientPoolExhaustedException If a {@link TransportFacade} cannot be obtained within the configured timeout.
-     * @throws TransportClientGetException           If error occurs when getting the {@link TransportFacade}.
+     * @throws TransportClientGetException If error occurs when getting the {@link TransportFacade}.
      * @since 1.0.0
      */
     T getFacade(Map<String, Object> configParameters) throws TransportException;

diff --git a/transport/mqtt/src/main/java/org/eclipse/kapua/transport/mqtt/MqttFacade.java b/transport/mqtt/src/main/java/org/eclipse/kapua/transport/mqtt/MqttFacade.java
@@ -15,7 +15,6 @@
 import org.checkerframework.checker.nullness.qual.Nullable;
 import org.eclipse.kapua.transport.TransportFacade;
 import org.eclipse.kapua.transport.exception.TransportClientGetException;
-import org.eclipse.kapua.transport.exception.TransportClientPoolExhaustedException;
 import org.eclipse.kapua.transport.exception.TransportException;
 import org.eclipse.kapua.transport.exception.TransportSendException;
 import org.eclipse.kapua.transport.exception.TransportTimeoutException;
@@ -56,8 +55,7 @@ public class MqttFacade implements TransportFacade<MqttTopic, MqttPayload, MqttM
     /**
      * Initializes a {@link MqttFacade} to be used to send requests to devices.
      *
-     * @throws TransportClientPoolExhaustedException When {@link MqttClient} cannot be borrowed in the configured timeout (client.pool.borrow.wait.max)
-     * @throws TransportClientGetException           When {@link MqttClient} is not available for the given node URI.
+     * @throws TransportClientGetException When {@link MqttClient} is not available for the given node URI.
      * @since 1.0.0
      */
     public MqttFacade(@NotNull String nodeUri) throws TransportException {