Package com.linkedin.helix.store

Examples of com.linkedin.helix.store.PropertyStoreException


      }
    }
    catch (Exception e)
    {
      LOG.error("Exception in creatPropertyNamespace(" + prefix + ")", e);
      throw new PropertyStoreException(e.toString());
    }
  }
View Full Code Here


    }
    catch (Exception e)
    {
      LOG.error("Exception when setProperty(" + key + ", " + value + ")", e);
      throw new PropertyStoreException(e.toString());
    }
  }
View Full Code Here

      return value;
    }
    catch (Exception e)
    {
      LOG.error("Exception in getProperty(" + key + ")", e);
      throw (new PropertyStoreException(e.toString()));
    }
  }
View Full Code Here

      // OK
    }
    catch (Exception e)
    {
      LOG.error("Exception in removeProperty(" + key + ")", e);
      throw (new PropertyStoreException(e.toString()));
    }
  }
View Full Code Here

      // OK
    }
    catch (Exception e)
    {
      LOG.error("Exception in removeProperty(" + prefix + ")", e);
      throw (new PropertyStoreException(e.toString()));
    }
  }
View Full Code Here

  }

  @Override
  public void setPropertyDelimiter(String delimiter) throws PropertyStoreException
  {
    throw new PropertyStoreException("setPropertyDelimiter() not implemented for ZKPropertyStore");
  }
View Full Code Here

      }
    }
    catch (Exception e)
    {
      LOG.error("Exception in subscribeForPropertyChange(" + prefix + ")", e);
      throw (new PropertyStoreException(e.toString()));
    }
  }
View Full Code Here

    {
      if (!_zkClient.exists(path))
      {
        if (!createIfAbsent)
        {
          throw new PropertyStoreException("Can't update " + key
              + " since no node exists");
        }
        else
        {
          _zkClient.createPersistent(path, true);
        }
      }

      _zkClient.updateDataSerialized(path, new ByteArrayUpdater(updater, _serializer));
    }
    catch (Exception e)
    {
      LOG.error("Exception in updatePropertyUntilSucceed(" + key + ", " + createIfAbsent
          + ")", e);
      throw (new PropertyStoreException(e.toString()));
    }

    // update cache
    // getProperty(key);
  }
View Full Code Here

public class TestPropertyStoreException
{
  @Test (groups = {"unitTest"})
  public void testPropertyStoreException()
  {
    PropertyStoreException exception = new PropertyStoreException("msg");
    AssertJUnit.assertEquals(exception.getMessage(), "msg");
   
    exception = new PropertyStoreException();
    AssertJUnit.assertNull(exception.getMessage());
  }
View Full Code Here

TOP

Related Classes of com.linkedin.helix.store.PropertyStoreException

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.