Сконфигурируйте Cassandra с фреймворком для микронавтов из yaml - PullRequest
Новая
       11

Сконфигурируйте Cassandra с фреймворком для микронавтов из yaml

0 голосов
/ 12 января 2019

Я использую инфраструктуру micronaut и пытаюсь настроить доступ к данным cassandra с application.yml Для стандартного теста я могу настроить драйвер datastax 

cassandra:
    default:
        clusterName: "Test Cluster"
        contactPoint: "192.168.99.100"
        port: 9042
        maxSchemaAgreementWaitSeconds: 20
        ssl: false

Однако я не могу найти способ предоставить конфигурацию для использования с методом .withCredentials

Я вижу, что реализация в https://github.com/micronaut-projects/micronaut-core/blob/dc8c423be1979817c9c8f53440f3b87e775523b2/configurations/cassandra/src/main/java/io/micronaut/configuration/cassandra/CassandraConfiguration.java

сделать следующее 

 @ConfigurationBuilder(allowZeroArgs = true, prefixes = { "with", "add" })
    Cluster.Builder builder = Cluster.builder();

однако withCredentials метод требует 2 параметра https://docs.datastax.com/en/drivers/java/2.0/com/datastax/driver/core/Cluster.Builder.html#withCredentials-java.lang.String-java.lang.String-

public Cluster.Builder withCredentials(String username,
                                       String password)

Каким будет способ yaml для настройки этого метода?

1 Ответ

0 голосов
/ 18 января 2019

С новой функцией, добавленной @ graeme-rocher в https://github.com/micronaut-projects/micronaut-core/issues/1106, я смог сделать это следующим образом: 

import com.datastax.driver.core.Cluster
import io.micronaut.context.ApplicationContext
import io.micronaut.context.event.BeanCreatedEvent
import io.micronaut.context.event.BeanCreatedEventListener
import org.slf4j.Logger
import org.slf4j.LoggerFactory

import javax.inject.Singleton

@Singleton
class ClusterBuilderListener implements BeanCreatedEventListener<Cluster.Builder> {
    private static final Logger LOG = LoggerFactory.getLogger(ClusterBuilderListener.class)

    @Override
    Cluster.Builder onCreated(BeanCreatedEvent<Cluster.Builder> event) {
        def builder = event.getBean()
        ApplicationContext applicationContext = (ApplicationContext) event.getSource()

        if(applicationContext.getEnvironment().getActiveNames().contains('pro') ){
            builder.withCredentials("username", "password")
        }
        return builder
    }
}
...