org.xdi.oxd.server.persistence.RedisPersistenceService クラス

org.xdi.oxd.server.persistence.RedisPersistenceService の継承関係図

org.xdi.oxd.server.persistence.RedisPersistenceService 連携図

公開メンバ関数
	RedisPersistenceService (OxdServerConfiguration configuration)
void	create ()
boolean	create (Rp rp)
boolean	update (Rp rp)
Rp	getRp (String oxdId)
boolean	removeAllRps ()
Set< Rp >	getRps ()
void	destroy ()
boolean	remove (String oxdId)
void	put (String key, String value)
String	get (String key)

静的公開メンバ関数
static RedisConfiguration	asRedisConfiguration (OxdServerConfiguration configuration) throws Exception
static RedisConfiguration	asRedisConfiguration (JsonNode node) throws Exception

非公開メンバ関数
void	testConnection ()

非公開変数類
final OxdServerConfiguration	configuration
AbstractRedisProvider	redisProvider

静的非公開変数類
static final Logger	LOG = LoggerFactory.getLogger(RedisPersistenceService.class)

詳解

著者

yuriyz

構築子と解体子

RedisPersistenceService()

org.xdi.oxd.server.persistence.RedisPersistenceService.RedisPersistenceService ( OxdServerConfiguration  configuration )

inline

                                                                         {
        this.configuration = configuration;
    }

関数詳解

asRedisConfiguration() [1/2]

static RedisConfiguration org.xdi.oxd.server.persistence.RedisPersistenceService.asRedisConfiguration ( OxdServerConfiguration  configuration ) throws Exception

inlinestatic

                                                                                                                 {        ;
        return asRedisConfiguration(Jackson2.asOldNode(configuration.getStorageConfiguration()));
    }

asRedisConfiguration() [2/2]

static RedisConfiguration org.xdi.oxd.server.persistence.RedisPersistenceService.asRedisConfiguration ( JsonNode  node ) throws Exception

inlinestatic

                                                                                          {
        try {
            return CoreUtils.createJsonMapper().readValue(node, RedisConfiguration.class);
        } catch (Exception e) {
            LOG.error("Failed to parse RedisConfiguration.", e);
            throw e;
        }
    }

create() [1/2]

void org.xdi.oxd.server.persistence.RedisPersistenceService.create ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                         {
        LOG.debug("Creating RedisPersistenceService ...");

        try {
            RedisConfiguration redisConfiguration = asRedisConfiguration(configuration);

            redisProvider = RedisProviderFactory.create(redisConfiguration);
            redisProvider.create();
            LOG.debug("RedisPersistenceService started.");
        } catch (Exception e) {
            throw new IllegalStateException("Error starting RedisPersistenceService", e);
        }
    }

create() [2/2]

boolean org.xdi.oxd.server.persistence.RedisPersistenceService.create ( Rp  rp )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                 {
        try {
            put(rp.getOxdId(), Jackson.asJson(rp));
            return true;
        } catch (IOException e) {
            LOG.error("Failed to create RP: " + rp, e);
            return false;
        }
    }

destroy()

void org.xdi.oxd.server.persistence.RedisPersistenceService.destroy ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                          {
        LOG.debug("Destroying RedisProvider");

        redisProvider.destroy();

        LOG.debug("Destroyed RedisProvider");
    }

get()

String org.xdi.oxd.server.persistence.RedisPersistenceService.get ( String  key )

inline

                                  {
        return (String) redisProvider.get(key);
    }

getRp()

Rp org.xdi.oxd.server.persistence.RedisPersistenceService.getRp ( String  oxdId )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                  {
        return MigrationService.parseRp(get(oxdId));
    }

getRps()

Set<Rp> org.xdi.oxd.server.persistence.RedisPersistenceService.getRps ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                            {
        return Sets.newHashSet();
    }

put()

void org.xdi.oxd.server.persistence.RedisPersistenceService.put ( String  key, String  value  )

inline

                                              {
        redisProvider.put(key, value);
    }

remove()

boolean org.xdi.oxd.server.persistence.RedisPersistenceService.remove ( String  oxdId )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                        {
        redisProvider.remove(oxdId);
        return true;
    }

removeAllRps()

boolean org.xdi.oxd.server.persistence.RedisPersistenceService.removeAllRps ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                  {
        return false;
    }

testConnection()

void org.xdi.oxd.server.persistence.RedisPersistenceService.testConnection ( )

inlineprivate

                                  {
        put("testKey", "testValue");
        if (!"testValue".equals(get("testKey"))) {
            throw new RuntimeException("Failed to connect to redis server. Storage configuration: " + configuration.getStorageConfiguration());
        }
    }

update()

boolean org.xdi.oxd.server.persistence.RedisPersistenceService.update ( Rp  rp )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                 {
        try {
            put(rp.getOxdId(), Jackson.asJson(rp));
            return true;
        } catch (IOException e) {
            LOG.error("Failed to create RP: " + rp, e);
            return false;
        }
    }

メンバ詳解

configuration

final OxdServerConfiguration org.xdi.oxd.server.persistence.RedisPersistenceService.configuration

private

LOG

final Logger org.xdi.oxd.server.persistence.RedisPersistenceService.LOG = LoggerFactory.getLogger(RedisPersistenceService.class)

staticprivate

redisProvider

AbstractRedisProvider org.xdi.oxd.server.persistence.RedisPersistenceService.redisProvider

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxd/oxd-server/src/main/java/org/xdi/oxd/server/persistence/RedisPersistenceService.java