org.apache.ignite

## Class IgniteClientSpringBean

- java.lang.Object
- - org.apache.ignite.IgniteClientSpringBean

- All Implemented Interfaces:
    AutoCloseable, IgniteClient, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

      public class IgniteClientSpringBean
      extends Object
      implements IgniteClient, org.springframework.context.SmartLifecycle

  Represents Ignite client Spring bean that provides the ability to automatically start Ignite client during Spring Context initialization. It requires `ClientConfiguration` to be set before bean use (see `setClientConfiguration(ClientConfiguration)`}). A note should be taken that Ignite client instance is started after all other Spring beans have been initialized and right before Spring context is refreshed. That implies that it's not valid to reference `IgniteClientSpringBean` from any kind of Spring bean init methods like `PostConstruct`. If it's required to reference `IgniteClientSpringBean` for other bean initialization purposes, it should be done from a `ContextRefreshedEvent` listener method declared in that bean.

  ### Spring XML Configuration Example

       <bean id="igniteClient" class="org.apache.ignite.IgniteClientSpringBean">
           <property name="clientConfiguration">
               <bean class="org.apache.ignite.configuration.ClientConfiguration">
                   <property name="addresses">
                       <list>
                           <value>127.0.0.1:10800</value>
                       </list>
                   </property>
               </bean>
           </property>
       </bean>

- - ### Field Summary

    Fields
    Modifier and Type | Field and Description
    --- | ---
    `static int` | `DFLT_IGNITE_CLI_LIFECYCLE_PHASE` Default Ignite client `SmartLifecycle` phase.

  - ### Constructor Summary

    Constructors
    Constructor and Description
    `IgniteClientSpringBean()`

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `IgniteBinary` | `binary()`
    `<K,V> ClientCache<K,V>` | `cache(String name)` Get existing cache.
    `Collection<String>` | `cacheNames()` Gets the names of all available caches.
    `IgniteClientFuture<Collection<String>>` | `cacheNamesAsync()` Gets the names of all available caches.
    `void` | `close()`
    `ClientCluster` | `cluster()` Gets client cluster facade.
    `ClientCompute` | `compute()` Gets compute facade over all cluster nodes started in server mode.
    `ClientCompute` | `compute(ClientClusterGroup grp)` Gets compute facade over the specified cluster group.
    `<K,V> ClientCache<K,V>` | `createCache(ClientCacheConfiguration cfg)` Creates a cache with the specified configuration.
    `<K,V> ClientCache<K,V>` | `createCache(String name)` Creates a cache with a default configuration.
    `<K,V> IgniteClientFuture<ClientCache<K,V>>` | `createCacheAsync(ClientCacheConfiguration cfg)` Creates a cache with the specified configuration.
    `<K,V> IgniteClientFuture<ClientCache<K,V>>` | `createCacheAsync(String name)` Creates a cache with a default configuration.
    `void` | `destroyCache(String name)` Destroys the cache with the given name.
    `IgniteClientFuture<Void>` | `destroyCacheAsync(String name)` Destroys the cache with the given name.
    `ClientConfiguration` | `getClientConfiguration()` Gets Ignite client configuration.
    `<K,V> ClientCache<K,V>` | `getOrCreateCache(ClientCacheConfiguration cfg)` Gets the existing cache or creates a new cache if it does not exist.
    `<K,V> ClientCache<K,V>` | `getOrCreateCache(String name)` Gets the existing cache or creates a new cache with default configuration if it does not exist.
    `<K,V> IgniteClientFuture<ClientCache<K,V>>` | `getOrCreateCacheAsync(ClientCacheConfiguration cfg)` Gets the existing cache or creates a new cache if it does not exist.
    `<K,V> IgniteClientFuture<ClientCache<K,V>>` | `getOrCreateCacheAsync(String name)` Gets the existing cache or creates a new cache with default configuration if it does not exist.
    `int` | `getPhase()`
    `boolean` | `isAutoStartup()`
    `boolean` | `isRunning()`
    `FieldsQueryCursor<List<?>>` | `query(SqlFieldsQuery qry)` Execute SQL query and get cursor to iterate over results.
    `ClientServices` | `services()` Gets `services` facade over all cluster nodes started in server mode.
    `ClientServices` | `services(ClientClusterGroup grp)` Gets `services` facade over nodes within the cluster group.
    `IgniteClientSpringBean` | `setClientConfiguration(ClientConfiguration cfg)` Sets Ignite client configuration.
    `IgniteClientSpringBean` | `setPhase(int phase)` Sets `SmartLifecycle` phase during which the current bean will be initialized.
    `void` | `start()`
    `void` | `stop()`
    `void` | `stop(Runnable callback)`
    `ClientTransactions` | `transactions()` Gets client transactions facade.

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### Field Detail

    - #### DFLT_IGNITE_CLI_LIFECYCLE_PHASE

          public static final int DFLT_IGNITE_CLI_LIFECYCLE_PHASE

      Default Ignite client `SmartLifecycle` phase.
      See Also:
        Constant Field Values

  - ### Constructor Detail

    - #### IgniteClientSpringBean

          public IgniteClientSpringBean()

  - ### Method Detail

    - #### isAutoStartup

          public boolean isAutoStartup()

      Specified by:
        `isAutoStartup` in interface `org.springframework.context.SmartLifecycle`

    - #### stop

          public void stop(Runnable callback)

      Specified by:
        `stop` in interface `org.springframework.context.SmartLifecycle`

    - #### stop

          public void stop()

      Specified by:
        `stop` in interface `org.springframework.context.Lifecycle`

    - #### isRunning

          public boolean isRunning()

      Specified by:
        `isRunning` in interface `org.springframework.context.Lifecycle`

    - #### start

          public void start()

      Specified by:
        `start` in interface `org.springframework.context.Lifecycle`

    - #### getPhase

          public int getPhase()

      Specified by:
        `getPhase` in interface `org.springframework.context.Phased`

    - #### getOrCreateCache

          public <K,V> ClientCache<K,V> getOrCreateCache(String name)
                                                  throws ClientException

      Gets the existing cache or creates a new cache with default configuration if it does not exist.
      Specified by:
        `getOrCreateCache` in interface `IgniteClient`
      Parameters:
        `name` - Cache name.
      Throws:
        `ClientException`

    - #### getOrCreateCacheAsync

          public <K,V> IgniteClientFuture<ClientCache<K,V>> getOrCreateCacheAsync(String name)
                                                                           throws ClientException

      Gets the existing cache or creates a new cache with default configuration if it does not exist.
      Specified by:
        `getOrCreateCacheAsync` in interface `IgniteClient`
      Parameters:
        `name` - Cache name.
      Returns:
        a Future representing pending completion of the operation, which wraps the resulting cache.
      Throws:
        `ClientException`

    - #### getOrCreateCache

          public <K,V> ClientCache<K,V> getOrCreateCache(ClientCacheConfiguration cfg)
                                                  throws ClientException

      Gets the existing cache or creates a new cache if it does not exist.
      Specified by:
        `getOrCreateCache` in interface `IgniteClient`
      Parameters:
        `cfg` - Cache configuration. If the cache exists, this configuration is ignored.
      Throws:
        `ClientException`

    - #### getOrCreateCacheAsync

          public <K,V> IgniteClientFuture<ClientCache<K,V>> getOrCreateCacheAsync(ClientCacheConfiguration cfg)
                                                                           throws ClientException

      Gets the existing cache or creates a new cache if it does not exist.
      Specified by:
        `getOrCreateCacheAsync` in interface `IgniteClient`
      Parameters:
        `cfg` - Cache configuration. If the cache exists, this configuration is ignored.
      Returns:
        a Future representing pending completion of the operation, which wraps the resulting cache.
      Throws:
        `ClientException`

    - #### cache

          public <K,V> ClientCache<K,V> cache(String name)

      Get existing cache.
      Specified by:
        `cache` in interface `IgniteClient`
      Parameters:
        `name` - Cache name.

    - #### cacheNames

          public Collection<String> cacheNames()
                                        throws ClientException

      Gets the names of all available caches.
      Specified by:
        `cacheNames` in interface `IgniteClient`
      Returns:
        Collection of names of currently available caches or an empty collection if no caches are available.
      Throws:
        `ClientException`

    - #### cacheNamesAsync

          public IgniteClientFuture<Collection<String>> cacheNamesAsync()
                                                                 throws ClientException

      Gets the names of all available caches.
      Specified by:
        `cacheNamesAsync` in interface `IgniteClient`
      Returns:
        a Future representing pending completion of the operation, which wraps the сollection of names of currently available caches or an empty collection if no caches are available.
      Throws:
        `ClientException`

    - #### destroyCache

          public void destroyCache(String name)
                            throws ClientException

      Destroys the cache with the given name. Throws `ClientException` if the cache does not exist.
      Specified by:
        `destroyCache` in interface `IgniteClient`
      Throws:
        `ClientException`

    - #### destroyCacheAsync

          public IgniteClientFuture<Void> destroyCacheAsync(String name)
                                                     throws ClientException

      Destroys the cache with the given name. Throws `ClientException` if the cache does not exist.
      Specified by:
        `destroyCacheAsync` in interface `IgniteClient`
      Returns:
        a Future representing pending completion of the operation.
      Throws:
        `ClientException`

    - #### createCache

          public <K,V> ClientCache<K,V> createCache(String name)
                                             throws ClientException

      Creates a cache with a default configuration.
      Specified by:
        `createCache` in interface `IgniteClient`
      Parameters:
        `name` - Cache name.
      Returns:
        Resulting cache.
      Throws:
        `ClientException`

    - #### createCacheAsync

          public <K,V> IgniteClientFuture<ClientCache<K,V>> createCacheAsync(String name)
                                                                      throws ClientException

      Creates a cache with a default configuration.
      Specified by:
        `createCacheAsync` in interface `IgniteClient`
      Parameters:
        `name` - Cache name.
      Returns:
        a Future representing pending completion of the operation, which wraps the resulting cache.
      Throws:
        `ClientException`

    - #### createCache

          public <K,V> ClientCache<K,V> createCache(ClientCacheConfiguration cfg)
                                             throws ClientException

      Creates a cache with the specified configuration.
      Specified by:
        `createCache` in interface `IgniteClient`
      Parameters:
        `cfg` - Cache configuration.
      Returns:
        Resulting cache.
      Throws:
        `ClientException`

    - #### createCacheAsync

          public <K,V> IgniteClientFuture<ClientCache<K,V>> createCacheAsync(ClientCacheConfiguration cfg)
                                                                      throws ClientException

      Creates a cache with the specified configuration.
      Specified by:
        `createCacheAsync` in interface `IgniteClient`
      Parameters:
        `cfg` - Cache configuration.
      Returns:
        a Future representing pending completion of the operation, which wraps the resulting cache.
      Throws:
        `ClientException`

    - #### binary

          public IgniteBinary binary()

      Specified by:
        `binary` in interface `IgniteClient`
      Returns:
        Instance of `IgniteBinary` interface.

    - #### query

          public FieldsQueryCursor<List<?>> query(SqlFieldsQuery qry)

      Execute SQL query and get cursor to iterate over results.
      Specified by:
        `query` in interface `IgniteClient`
      Parameters:
        `qry` - SQL query.
      Returns:
        Cursor.

    - #### transactions

          public ClientTransactions transactions()

      Gets client transactions facade.
      Specified by:
        `transactions` in interface `IgniteClient`
      Returns:
        Client transactions facade.

    - #### compute

          public ClientCompute compute()

      Gets compute facade over all cluster nodes started in server mode.
      Specified by:
        `compute` in interface `IgniteClient`
      Returns:
        Compute instance over all cluster nodes started in server mode.

    - #### compute

          public ClientCompute compute(ClientClusterGroup grp)

      Gets compute facade over the specified cluster group. All operations on the returned `ClientCompute` instance will only include nodes from this cluster group.
      Specified by:
        `compute` in interface `IgniteClient`
      Parameters:
        `grp` - Cluster group.
      Returns:
        Compute instance over given cluster group.

    - #### cluster

          public ClientCluster cluster()

      Gets client cluster facade.
      Specified by:
        `cluster` in interface `IgniteClient`
      Returns:
        Client cluster facade.

    - #### services

          public ClientServices services()

      Gets `services` facade over all cluster nodes started in server mode.
      Specified by:
        `services` in interface `IgniteClient`
      Returns:
        Services facade over all cluster nodes started in server mode.

    - #### services

          public ClientServices services(ClientClusterGroup grp)

      Gets `services` facade over nodes within the cluster group. All operations on the returned `ClientServices` instance will only include nodes from the specified cluster group. Note: In some cases there will be additional requests for each service invocation from client to server to resolve cluster group.
      Specified by:
        `services` in interface `IgniteClient`
      Parameters:
        `grp` - Cluster group.
      Returns:
        `Services` functionality over given cluster group.

    - #### close

          public void close()
                     throws Exception

      Specified by:
        `close` in interface `AutoCloseable`
      Throws:
        `Exception`

    - #### setClientConfiguration

          public IgniteClientSpringBean setClientConfiguration(ClientConfiguration cfg)

      Sets Ignite client configuration.

    - #### getClientConfiguration

          public ClientConfiguration getClientConfiguration()

      Gets Ignite client configuration.

    - #### setPhase

          public IgniteClientSpringBean setPhase(int phase)

      Sets `SmartLifecycle` phase during which the current bean will be initialized. Note, underlying Ignite client will be closed during handling of `DisposableBean` since `IgniteClient` implements `AutoCloseable` interface.

2021 Copyright © Apache Software Foundation
| Follow @ApacheIgnite
Ignite Database and Caching Platform | : ver. 2.11.0
Release Date | : September 11 2021