Class HazelcastMetadataStore

java.lang.Object
org.springframework.integration.hazelcast.metadata.HazelcastMetadataStore
All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean, org.springframework.integration.metadata.ConcurrentMetadataStore, org.springframework.integration.metadata.ListenableMetadataStore, org.springframework.integration.metadata.MetadataStore

public class HazelcastMetadataStore extends Object implements org.springframework.integration.metadata.ListenableMetadataStore, org.springframework.beans.factory.InitializingBean
The Hazelcast IMap-based ListenableMetadataStore implementation.
  • Constructor Details

    • HazelcastMetadataStore

      public HazelcastMetadataStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)
    • HazelcastMetadataStore

      public HazelcastMetadataStore(com.hazelcast.map.IMap<String,String> map)
  • Method Details

    • putIfAbsent

      public String putIfAbsent(String key, String value)
      Specified by:
      putIfAbsent in interface org.springframework.integration.metadata.ConcurrentMetadataStore
    • replace

      public boolean replace(String key, String oldValue, String newValue)
      Specified by:
      replace in interface org.springframework.integration.metadata.ConcurrentMetadataStore
    • put

      public void put(String key, String value)
      Specified by:
      put in interface org.springframework.integration.metadata.MetadataStore
    • get

      public String get(String key)
      Specified by:
      get in interface org.springframework.integration.metadata.MetadataStore
    • remove

      public String remove(String key)
      Specified by:
      remove in interface org.springframework.integration.metadata.MetadataStore
    • addListener

      public void addListener(org.springframework.integration.metadata.MetadataStoreListener callback)
      Specified by:
      addListener in interface org.springframework.integration.metadata.ListenableMetadataStore
    • removeListener

      public void removeListener(org.springframework.integration.metadata.MetadataStoreListener callback)
      Specified by:
      removeListener in interface org.springframework.integration.metadata.ListenableMetadataStore
    • afterPropertiesSet

      public void afterPropertiesSet() throws Exception
      Specified by:
      afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
      Throws:
      Exception