本文整理了Java中org.projectodd.wunderboss.Options.getInt()方法的一些代码示例，展示了Options.getInt()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Options.getInt()方法的具体详情如下：
包路径：org.projectodd.wunderboss.Options
类名称：Options
方法名：getInt

Options.getInt介绍

暂无

代码示例

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-scheduling

public QuartzScheduling(String name, Options<CreateOption> options) {
  this.name = name;
  this.numThreads = options.getInt(CreateOption.NUM_THREADS);
}

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-core

public Integer getInt(T key) {
  return getInt(key, null);
}

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-messaging

public synchronized MessageHandlerGroup start() throws Exception {
  if (!this.started) {
    Integer option = this.options.getInt(ListenOption.CONCURRENCY);
    int concurrency = option != null ? option : this.destination.defaultConcurrency();
    log.info("Starting listener for '" + this.destination.name() + "' concurrency=" + concurrency);
    while(concurrency-- > 0) {
      listeners.add(createListener(this.handler, this.codecs, this.destination,
                     this.context, this.options));
    }
    this.started = true;
  }
  return this;
}

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-caching

void evict() {
  builder.eviction()
    .strategy(EvictionStrategy.valueOf(options.getString(Caching.CreateOption.EVICTION).toUpperCase()))
    .maxEntries(options.getInt(Caching.CreateOption.MAX_ENTRIES));
}
void expire() {

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-messaging-hornetq

protected ConnectionFactory createRemoteConnectionFactory(final Options<CreateContextOption> options) {
  //TODO: possibly cache the remote cf's?
  Map<String, Object> transportOpts = new HashMap<>();
  transportOpts.put("host", options.getString(CreateContextOption.HOST));
  transportOpts.put("port", options.getInt(CreateContextOption.PORT));
  if (REMOTE_TYPE_WILDFLY.equals(options.getString(CreateContextOption.REMOTE_TYPE))) {
    transportOpts.put("http-upgrade-enabled", true);
  }
  TransportConfiguration config =
      new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyConnectorFactory",
                    transportOpts);
  HornetQConnectionFactory hornetQcf = HornetQJMSClient
      .createConnectionFactoryWithoutHA(options.has(CreateContextOption.XA) ?
                           JMSFactoryType.XA_CF :
                           JMSFactoryType.CF,
                       config);
  hornetQcf.setReconnectAttempts(options.getInt(CreateContextOption.RECONNECT_ATTEMPTS));
  hornetQcf.setRetryInterval(options.getLong(CreateContextOption.RECONNECT_RETRY_INTERVAL));
  hornetQcf.setRetryIntervalMultiplier(options.getDouble(CreateContextOption.RECONNECT_RETRY_INTERVAL_MULTIPLIER));
  hornetQcf.setMaxRetryInterval(options.getLong(CreateContextOption.RECONNECT_MAX_RETRY_INTERVAL));
  // We have to cast for HornetQ 2.3 - the factory object that is returned is both a HornetQConnectionFactory
  // and a javax.jms.ConnectionFactory, but HornetQConnectionFactory doesn't implement j.j.ConnectionFactory.
  // With HornetQ 2.4, this cast is redundant.
  return (ConnectionFactory)hornetQcf;
}

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-scheduling

protected Trigger initTrigger(String name, Options<ScheduleOption> opts) {
  TriggerBuilder<Trigger> builder = TriggerBuilder.newTrigger()
      .withIdentity(name, name());
  if (opts.has(AT)) {
    builder.startAt(opts.getDate(AT));
  } else if (opts.has(IN)) {
    builder.startAt(new java.util.Date(System.currentTimeMillis() + opts.getLong(IN)));
  } else {
    builder.startNow();
  }
  if (opts.has(UNTIL)) {
    builder.endAt(opts.getDate(UNTIL));
  }
  if (opts.has(CRON)) {
    builder.withSchedule(CronScheduleBuilder.cronSchedule(opts.getString(CRON)));
  } else if (opts.has(EVERY)) {
    SimpleScheduleBuilder schedule =
        SimpleScheduleBuilder.simpleSchedule()
            .withIntervalInMilliseconds(opts.getInt(EVERY));
    if (opts.has(LIMIT)) {
      schedule.withRepeatCount(opts.getInt(LIMIT) - 1);
    } else {
      schedule.repeatForever();
    }
    builder.withSchedule(schedule);
  }
  return builder.build();
}

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-messaging

opts.getBoolean(PublishOption.PERSISTENT) ?
             DeliveryMode.PERSISTENT : DeliveryMode.NON_PERSISTENT,
         opts.getInt(PublishOption.PRIORITY),
         opts.getLong(PublishOption.TTL, producer.getTimeToLive()));
} finally {

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-messaging

@Override
  public Reply onMessage(Message msg, Context context) throws Exception {
    Reply result = handler.onMessage(msg, context);
    Options<MessageOpOption> replyOptions = new Options<>();
    replyOptions.put(PublishOption.TTL, opts.getInt(RespondOption.TTL));
    replyOptions.put(PublishOption.CONTEXT, context);
    replyOptions.put(PublishOption.PROPERTIES, result.properties());
    ((ReplyableMessage)msg).reply(result.content(), codecs.forContentType(msg.contentType()), replyOptions);
    return null;
  }
};

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-messaging

@Override
public Message receive(Codecs codecs, Map<MessageOpOption, Object> options) throws Exception {
  Options<MessageOpOption> opts = new Options<>(options);
  int timeout = opts.getInt(ReceiveOption.TIMEOUT);
  JMSSpecificContext context = context(opts.get(MessageOpOption.CONTEXT));
  Session jmsSession = context.jmsSession();

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-web-undertow

private void configure(Options<CreateOption> options) {
  autoStart = options.getBoolean(CreateOption.AUTO_START);
  Undertow.Builder builder = (Undertow.Builder) options.get(CreateOption.CONFIGURATION);
  if (builder != null) {
    undertow = builder
      .setHandler(Handlers.header(pathology.handler(), Headers.SERVER_STRING, "undertow"))
      .build();
  } else {
    int port = options.getInt(CreateOption.PORT);
    String host = options.getString(CreateOption.HOST);
    undertow = Undertow.builder()
      .addHttpListener(port, host)
      .setHandler(Handlers.header(pathology.handler(), Headers.SERVER_STRING, "undertow"))
      .build();
  }
}