Skip to content

FMWK-704 add auth properties #948

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 3 commits into
base: main
Choose a base branch
from
+18 −1
Open

FMWK-704 add auth properties #948

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
e20da62
add auth properties
gagan405 Nov 24, 2025
edda260
fix conflict
gagan405 Nov 25, 2025
41c6812
fix conflict
gagan405 Nov 25, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions src/main/java/org/springframework/data/aerospike/config/AerospikeConnectionSettings.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,14 @@ public class AerospikeConnectionSettings {
// Storing hosts
Host[] hostsArray;

String user;
String password;

public AerospikeConnectionSettings(Environment environment) {
if (environment != null) {
setStringFromConfig(this::setHosts, environment, CONFIG_PREFIX_CONNECTION, "hosts");
setStringFromConfig(this::setUser, environment, CONFIG_PREFIX_CONNECTION, "user");
setStringFromConfig(this::setPassword, environment, CONFIG_PREFIX_CONNECTION, "password");
}
}
}
14 changes: 13 additions & 1 deletion ...ain/java/org/springframework/data/aerospike/config/AerospikeDataConfigurationSupport.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.context.EnvironmentAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ClassPathScanningCandidateComponentProvider;
import org.springframework.context.annotation.Configuration;
Expand Down Expand Up @@ -77,12 +78,19 @@
*/
@Slf4j
@Configuration
public abstract class AerospikeDataConfigurationSupport {
public abstract class AerospikeDataConfigurationSupport implements EnvironmentAware {

public static final String CONFIG_PREFIX = "spring";
public static final String CONFIG_PREFIX_DATA = CONFIG_PREFIX + ".data.aerospike";
public static final String CONFIG_PREFIX_CONNECTION = CONFIG_PREFIX + ".aerospike";

protected Environment environment;

@Override
public void setEnvironment(Environment environment) {
this.environment = environment;
}

@Bean(name = "aerospikeQueryContextBuilder")
public QueryContextBuilder queryContextBuilder(IndexesCache indexesCache) {
return new QueryContextBuilder(indexesCache);
Expand Down Expand Up @@ -293,6 +301,10 @@ protected ClientPolicy getClientPolicy() {
clientPolicy.queryPolicyDefault.sendKey = sendKey;
clientPolicy.scanPolicyDefault.sendKey = sendKey;
clientPolicy.eventLoops = eventLoops();

AerospikeConnectionSettings aerospikeConnectionSettings = readAerospikeSettings(this.environment);
clientPolicy.setUser(aerospikeConnectionSettings.getUser());
clientPolicy.setPassword(aerospikeConnectionSettings.getPassword());
return clientPolicy;
}

Expand Down
Loading