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

QoS.valueOf介绍

暂无

代码示例

代码示例来源：origin: org.apache.activemq/activemq-all

protected void restoreDurableSubs(List<SubscriptionInfo> subs) {
  try {
    for (SubscriptionInfo sub : subs) {
      String name = sub.getSubcriptionName();
      String[] split = name.split(":", 2);
      QoS qoS = QoS.valueOf(split[0]);
      onSubscribe(new Topic(split[1], qoS));
      // mark this durable subscription as restored by Broker
      restoredDurableSubs.add(MQTTProtocolSupport.convertMQTTToActiveMQ(split[1]));
    }
  } catch (IOException e) {
    LOG.warn("Could not restore the MQTT durable subs.", e);
  }
}

代码示例来源：origin: org.apache.activemq/activemq-mqtt

protected void restoreDurableSubs(List<SubscriptionInfo> subs) {
  try {
    for (SubscriptionInfo sub : subs) {
      String name = sub.getSubcriptionName();
      String[] split = name.split(":", 2);
      QoS qoS = QoS.valueOf(split[0]);
      onSubscribe(new Topic(split[1], qoS));
      // mark this durable subscription as restored by Broker
      restoredDurableSubs.add(MQTTProtocolSupport.convertMQTTToActiveMQ(split[1]));
    }
  } catch (IOException e) {
    LOG.warn("Could not restore the MQTT durable subs.", e);
  }
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

protected void restoreDurableSubs(List<SubscriptionInfo> subs) {
  try {
    for (SubscriptionInfo sub : subs) {
      String name = sub.getSubcriptionName();
      String[] split = name.split(":", 2);
      QoS qoS = QoS.valueOf(split[0]);
      onSubscribe(new Topic(split[1], qoS));
      // mark this durable subscription as restored by Broker
      restoredDurableSubs.add(MQTTProtocolSupport.convertMQTTToActiveMQ(split[1]));
    }
  } catch (IOException e) {
    LOG.warn("Could not restore the MQTT durable subs.", e);
  }
}

代码示例来源：origin: PerfCake/PerfCake

@Override
public Serializable doSend(Message message, MeasurementUnit measurementUnit) throws Exception {
 String response = null;
 mqttConnection.publish(topicName, message.getPayload().toString().getBytes(Utils.getDefaultEncoding()), QoS.valueOf(qos.toUpperCase()), false);
 if (isResponseExpected) {
   mqttResponse = mqttResponseConnection.receive();
   if (mqttResponse != null) {
    response = new String(mqttResponse.getPayload(), Utils.getDefaultEncoding());
   }
 }
 return response;
}

代码示例来源：origin: org.apache.activemq/activemq-all

private void restoreDurableQueue(List<ActiveMQQueue> queues) {
  try {
    for (ActiveMQQueue queue : queues) {
      String name = queue.getPhysicalName().substring(VIRTUALTOPIC_CONSUMER_PREFIX.length());
      StringTokenizer tokenizer = new StringTokenizer(name);
      tokenizer.nextToken(":.");
      String qosString = tokenizer.nextToken();
      tokenizer.nextToken();
      String topicName = convertActiveMQToMQTT(tokenizer.nextToken("").substring(1));
      QoS qoS = QoS.valueOf(qosString);
      LOG.trace("Restoring queue subscription: {}:{}", topicName, qoS);
      ConsumerInfo consumerInfo = new ConsumerInfo(getNextConsumerId());
      consumerInfo.setDestination(queue);
      consumerInfo.setPrefetchSize(ActiveMQPrefetchPolicy.DEFAULT_QUEUE_PREFETCH);
      if (protocol.getActiveMQSubscriptionPrefetch() > 0) {
        consumerInfo.setPrefetchSize(protocol.getActiveMQSubscriptionPrefetch());
      }
      consumerInfo.setRetroactive(true);
      consumerInfo.setDispatchAsync(true);
      doSubscribe(consumerInfo, topicName, qoS);
      // mark this durable subscription as restored by Broker
      restoredQueues.add(queue);
    }
  } catch (IOException e) {
    LOG.warn("Could not restore the MQTT queue subscriptions.", e);
  }
}

代码示例来源：origin: org.apache.activemq/activemq-mqtt

private void restoreDurableQueue(List<ActiveMQQueue> queues) {
  try {
    for (ActiveMQQueue queue : queues) {
      String name = queue.getPhysicalName().substring(VIRTUALTOPIC_CONSUMER_PREFIX.length());
      StringTokenizer tokenizer = new StringTokenizer(name);
      tokenizer.nextToken(":.");
      String qosString = tokenizer.nextToken();
      tokenizer.nextToken();
      String topicName = convertActiveMQToMQTT(tokenizer.nextToken("").substring(1));
      QoS qoS = QoS.valueOf(qosString);
      LOG.trace("Restoring queue subscription: {}:{}", topicName, qoS);
      ConsumerInfo consumerInfo = new ConsumerInfo(getNextConsumerId());
      consumerInfo.setDestination(queue);
      consumerInfo.setPrefetchSize(ActiveMQPrefetchPolicy.DEFAULT_QUEUE_PREFETCH);
      if (protocol.getActiveMQSubscriptionPrefetch() > 0) {
        consumerInfo.setPrefetchSize(protocol.getActiveMQSubscriptionPrefetch());
      }
      consumerInfo.setRetroactive(true);
      consumerInfo.setDispatchAsync(true);
      doSubscribe(consumerInfo, topicName, qoS);
      // mark this durable subscription as restored by Broker
      restoredQueues.add(queue);
    }
  } catch (IOException e) {
    LOG.warn("Could not restore the MQTT queue subscriptions.", e);
  }
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

private void restoreDurableQueue(List<ActiveMQQueue> queues) {
  try {
    for (ActiveMQQueue queue : queues) {
      String name = queue.getPhysicalName().substring(VIRTUALTOPIC_CONSUMER_PREFIX.length());
      StringTokenizer tokenizer = new StringTokenizer(name);
      tokenizer.nextToken(":.");
      String qosString = tokenizer.nextToken();
      tokenizer.nextToken();
      String topicName = convertActiveMQToMQTT(tokenizer.nextToken("").substring(1));
      QoS qoS = QoS.valueOf(qosString);
      LOG.trace("Restoring queue subscription: {}:{}", topicName, qoS);
      ConsumerInfo consumerInfo = new ConsumerInfo(getNextConsumerId());
      consumerInfo.setDestination(queue);
      consumerInfo.setPrefetchSize(ActiveMQPrefetchPolicy.DEFAULT_QUEUE_PREFETCH);
      if (protocol.getActiveMQSubscriptionPrefetch() > 0) {
        consumerInfo.setPrefetchSize(protocol.getActiveMQSubscriptionPrefetch());
      }
      consumerInfo.setRetroactive(true);
      consumerInfo.setDispatchAsync(true);
      doSubscribe(consumerInfo, topicName, qoS);
      // mark this durable subscription as restored by Broker
      restoredQueues.add(queue);
    }
  } catch (IOException e) {
    LOG.warn("Could not restore the MQTT queue subscriptions.", e);
  }
}

代码示例来源：origin: PerfCake/PerfCake

mqttResponseConnection = mqttConnection;
final Topic[] responseTopic = { new Topic(responseTopicName, QoS.valueOf(responseQos)) };
mqttResponseConnection.subscribe(responseTopic);

代码示例来源：origin: apache/activemq-artemis

connection.connect();
connection.publish(topic, topic.getBytes(), QoS.EXACTLY_ONCE, true);
connection.subscribe(new Topic[]{new Topic(topic, QoS.valueOf(topic))});