This is an automated email from the ASF dual-hosted git repository.
vavrtom pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
The following commit(s) were added to refs/heads/main by this push:
new e19fc70c85 QPID-8686: [Broker-J] Fixed failing EndToEndTest (#289)
e19fc70c85 is described below
commit e19fc70c852e5867fbfbada787082077941407f7
Author: Daniil Kirilyuk <[email protected]>
AuthorDate: Thu Jun 19 13:33:30 2025 +0200
QPID-8686: [Broker-J] Fixed failing EndToEndTest (#289)
---
.../qpid/disttest/jms/QpidRestAPIQueueCreator.java | 17 ++++++++++++-----
1 file changed, 12 insertions(+), 5 deletions(-)
diff --git
a/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidRestAPIQueueCreator.java
b/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidRestAPIQueueCreator.java
index 37fdb5fbb9..cbb5f2e790 100644
---
a/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidRestAPIQueueCreator.java
+++
b/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidRestAPIQueueCreator.java
@@ -23,6 +23,7 @@ import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
+import java.net.URI;
import java.net.URISyntaxException;
import java.util.Collection;
import java.util.Iterator;
@@ -39,6 +40,7 @@ import javax.jms.Session;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.hc.client5.http.auth.AuthScope;
import org.apache.hc.client5.http.auth.CredentialsProvider;
+import org.apache.hc.client5.http.auth.CredentialsStore;
import org.apache.hc.client5.http.auth.UsernamePasswordCredentials;
import org.apache.hc.client5.http.classic.methods.HttpDelete;
import org.apache.hc.client5.http.classic.methods.HttpGet;
@@ -321,18 +323,23 @@ public class QpidRestAPIQueueCreator implements
QueueCreator
private HttpClientContext getHttpClientContext(final HttpHost management)
{
+ final HttpClientContext localContext = HttpClientContext.create();
final BasicAuthCache authCache = new BasicAuthCache();
- authCache.put(management, new BasicScheme());
- HttpClientContext localContext = HttpClientContext.create();
+ final BasicScheme basicScheme = new BasicScheme();
+ basicScheme.initPreemptive(_credentialsProvider.getCredentials(new
AuthScope(management), localContext));
+ authCache.put(management, basicScheme);
localContext.setAuthCache(authCache);
return localContext;
}
private CredentialsProvider getCredentialsProvider(final String
managementUser, final String managementPassword)
{
- final BasicCredentialsProvider credentialsProvider = new
BasicCredentialsProvider();
- credentialsProvider.setCredentials(new AuthScope("localhost", 8080),
new UsernamePasswordCredentials(managementUser,
managementPassword.toCharArray()));
+ final URI managementURI =
URI.create(System.getProperty("perftests.manangement-url"));
+ final String hostname = managementURI.getHost();
+ final int port = managementURI.getPort();
+ final AuthScope authScope = new AuthScope(hostname, port);
+ final CredentialsStore credentialsProvider = new
BasicCredentialsProvider();
+ credentialsProvider.setCredentials(authScope, new
UsernamePasswordCredentials(managementUser, managementPassword.toCharArray()));
return credentialsProvider;
}
-
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
