List of addThing() Examples

Examples of addThing()

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                            log.error("Could not release left-over lock for path: " + path, e);
                        }
                    }
                }
            };
            String id = entry.addThing(lock, closer);
            return new OptionalLockProjection(new LockProjection(id));
        }
        catch ( Exception e )
        {
            throw new RpcException(e);

View Full Code Here

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                    {
                        log.error("Could not close left-over leader latch for path: " + path, e);
                    }
                }
            };
            String id = entry.addThing(leaderLatch, closer);


            LeaderLatchListener listener = new LeaderLatchListener()
            {
                @Override
                public void isLeader()

View Full Code Here

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                    {
                        log.error("Could not close left-over PathChildrenCache for path: " + path, e);
                    }
                }
            };
            String id = entry.addThing(cache, closer);


            PathChildrenCacheListener listener = new PathChildrenCacheListener()
            {
                @Override
                public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws RpcException

View Full Code Here

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                    {
                        log.error("Could not close left-over NodeCache for path: " + path, e);
                    }
                }
            };
            String id = entry.addThing(cache, closer);


            NodeCacheListener listener = new NodeCacheListener()
            {
                @Override
                public void nodeChanged()

View Full Code Here

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                    {
                        log.error("Could not release left-over persistent ephemeral node for path: " + path, e);
                    }
                }
            };
            String id = entry.addThing(node, closer);
            return new PersistentEphemeralNodeProjection(id);
        }
        catch ( Exception e )
        {
            throw new RpcException(e);

View Full Code Here

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                        {
                            log.error("Could not release semaphore leases for path: " + path, e);
                        }
                    }
                };
                leaseProjections.add(new LeaseProjection(entry.addThing(lease, closer)));
            }
            return leaseProjections;
        }
        catch ( Exception e )
        {

View Full Code Here

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                    {
                        log.error("Could not close ServiceDiscovery with basePath: " + basePath, e);
                    }
                }
            };
            String id = entry.addThing(serviceDiscovery, closer);


            return new DiscoveryProjection(id);
        }
        catch ( Exception e )
        {

View Full Code Here

Examples of org.apache.curator.x.rpc.connections.CuratorEntry.addThing()

                    {
                        log.error("Could not close ServiceProvider with serviceName: " + serviceName, e);
                    }
                }
            };
            String id = entry.addThing(serviceProvider, closer);
            return new DiscoveryProviderProjection(id);
        }
        catch ( Exception e )
        {
            throw new RpcException(e);

View Full Code Here

Examples of org.nexml.model.Subset.addThing()

          // assign character objects to the subset. Here we get the full list
          List<org.nexml.model.Character> nexCharacters = xmlMatrix.getCharacters();
      
          // now we iterate over the coordinates and assign the nexml characters to the set
          for ( int i = tbStart; i <= tbStop; i += tbInc ) {
            nexSubset.addThing(nexCharacters.get(i));
          }
        }
      }      
    }

View Full Code Here

Examples of org.nexml.model.Subset.addThing()

        // assign character objects to the subset. Here we get the full list
        List<org.nexml.model.Character> xmlCharacters = xmlMatrix.getCharacters();
    
        // now we iterate over the coordinates and assign the nexml characters to the set
        for ( int i = tbStart; i <= tbStop; i += tbInc ) {
          xmlSubset.addThing(xmlCharacters.get(i));
        }
      }
    }
  }

View Full Code Here

0 1

TOP

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.