diff --git a/src/main/java/de/ozgcloud/xta/client/XtaClient.java b/src/main/java/de/ozgcloud/xta/client/XtaClient.java index 2b89768974e4e6021a4c59af71c365b6a61cf660..039964ab6fe25ccd74c30ae07dadb1468548791b 100644 --- a/src/main/java/de/ozgcloud/xta/client/XtaClient.java +++ b/src/main/java/de/ozgcloud/xta/client/XtaClient.java @@ -5,8 +5,8 @@ import jakarta.validation.constraints.NotBlank; import de.ozgcloud.xta.client.config.XtaClientConfig; import de.ozgcloud.xta.client.core.WrappedXtaService; import de.ozgcloud.xta.client.model.XtaIdentifier; -import de.ozgcloud.xta.client.model.XtaMessageMetaDataListing; import de.ozgcloud.xta.client.model.XtaMessageAndTransportReport; +import de.ozgcloud.xta.client.model.XtaMessageMetaDataListing; import genv3.de.xoev.transport.xta.x211.InvalidMessageIDException; import genv3.de.xoev.transport.xta.x211.PermissionDeniedException; import genv3.de.xoev.transport.xta.x211.XTAWSTechnicalProblemException; @@ -25,9 +25,8 @@ public class XtaClient { /** * Fetch metadata of pending messages sent to the {@code xtaIdentifier}. The returned listing contains at most - * {@link de.ozgcloud.xta.client.config.XtaClientConfig#getMaxListItems() maxListItems} messages. Use the {@code requestId} to - * {@link #close(String, String) close} pending messages. To fetch the next messages, use {@link #getNextMessagesMetadata(String)}. Note that - * {@code xtaIdentifier} has to be configured as a + * {@link de.ozgcloud.xta.client.config.XtaClientConfig#getMaxListItems() maxListItems} messages. To fetch the next messages, use + * {@link #getNextMessagesMetadata(String)}. Note that {@code xtaIdentifier} has to be configured as a * {@link de.ozgcloud.xta.client.config.XtaClientConfig#getClientIdentifiers() clientIdentifiers}. * * @param clientIdentifier the client identifier value to fetch messages for @@ -54,10 +53,11 @@ public class XtaClient { } /** - * Fetch the message content, close the message, and then fetch the transport report - * for the given {@code messageId} and reader identifier {@code clientIdentifier}. + * Fetch the message content, close the message, and then fetch the transport report for the given {@code messageId} and reader identifier + * {@code clientIdentifier}. + * * @param clientIdentifier Identifier of the reading client - * @param messageId Identifier of the message to fetch + * @param messageId Identifier of the message to fetch * @return The message and transport report */ public XtaMessageAndTransportReport getMessage(@NotBlank String clientIdentifier, @NotBlank String messageId) @@ -74,7 +74,6 @@ public class XtaClient { .build(); } - XtaIdentifier deriveIdentifier(String xtaIdentifier) { return config.getClientIdentifiers().stream() .filter(id -> id.value().equals(xtaIdentifier))