Package com.alibaba.wasp.fserver

Examples of com.alibaba.wasp.fserver.Leases$LeaseStillHeldException


   *          configuration
   */
  public MessageBroker(OnlineEntityGroups service, Configuration conf) {
    this.service = service;
    this.conf = conf;
    this.leases = new Leases(conf.getInt(FConstants.THREAD_WAKE_FREQUENCY,
        10 * 1000));
    this.subscriberLeaseTimeoutPeriod = conf.getInt(
        FConstants.WASP_FSEVER_SUBSCRIBER_TIMEOUT_PERIOD,
        FConstants.DEFAULT_WASP_FSEVER_SUBSCRIBER_TIMEOUT_PERIOD);
    this.renew = new RenewRunnable();
View Full Code Here


    super();
    this.server = server;
    this.connection = FConnectionManager.getConnection(server
        .getConfiguration());
    this.twoPhaseCommit = TwoPhaseCommit.getInstance(server.getActionManager());
    this.leases = new Leases(server.getConfiguration().getInt(
        FConstants.THREAD_WAKE_FREQUENCY,
        FConstants.DEFAULT_THREAD_WAKE_FREQUENCY));
    this.sessionLeaseTimeoutPeriod = this.server.getConfiguration().getInt(
        FConstants.WASP_CLIENT_SESSION_TIMEOUT_PERIOD,
        FConstants.DEFAULT_WASP_CLIENT_SESSION_TIMEOUT_PERIOD);
View Full Code Here

TOP

Related Classes of com.alibaba.wasp.fserver.Leases$LeaseStillHeldException

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.