MIS_Config_Change_Handler

package com.infusionsoft.mobileInteraction.config.cassandra;

import com.infusionsoft.mobileInteraction.config.CassandraConnectionService;
import com.infusionsoft.mobileInteraction.config.cassandra.CassandraConfiguration.ClusterProperties;
import com.infusionsoft.priscilla.PriscillaPropertyChangeListener;
import com.infusionsoft.priscilla.PropertyDefinition;
import com.infusionsoft.priscilla.configurator.PriscillaConfigurator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/**
 * User: wendel.schultz
 * Date: 7/1/14
 */
@Component
class CassandraConfigurationChangeListener {
    
    @Autowired
    private CassandraConnectionService connectionService;

    @Autowired
    private PriscillaConfigurator configurator;

    @PostConstruct
    void init(){
        configurator.observeStringProperty(ClusterProperties.ContactPoint, new PriscillaPropertyChangeListener<String>() {
            @Override
            public void onValueChange(PropertyDefinition<String> property, String newValue) {
                connectionService.reInitialize();;
            }
        });

        configurator.observeStringProperty(ClusterProperties.Keyspace, new PriscillaPropertyChangeListener<String>() {
            @Override
            public void onValueChange(PropertyDefinition<String> property, String newValue) {
                connectionService.reInitialize();;
            }
        });

        configurator.observeStringProperty(ClusterProperties.Password, new PriscillaPropertyChangeListener<String>() {
            @Override
            public void onValueChange(PropertyDefinition<String> property, String newValue) {
                connectionService.reInitialize();;
            }
        });

        configurator.observeStringProperty(ClusterProperties.Username, new PriscillaPropertyChangeListener<String>() {
            @Override
            public void onValueChange(PropertyDefinition<String> property, String newValue) {
                connectionService.reInitialize();;
            }
        });

    }
}