Java 类io.netty.handler.codec.mqtt.MqttQoS 实例源码

项目：j1st-mqtt 文件：RedisSyncSingleStorage.java

@Override
public void updateSubscription(String clientId, List<String> topicLevels, MqttQoS qos) {
    if (Topics.isTopicFilter(topicLevels)) {
        boolean b1 = hash().hset(RedisKey.subscription(clientId), String.join("/", topicLevels), String.valueOf(qos.value()));
        boolean b2 = hash().hset(RedisKey.topicFilter(topicLevels), clientId, String.valueOf(qos.value()));
        if (b1 && b2) {
            List<String> keys = new ArrayList<>();
            List<String> argv = new ArrayList<>();
            // topic filter tree
            for (int i = 0; i < topicLevels.size(); i++) {
                keys.add(RedisKey.topicFilterChild(topicLevels.subList(0, i)));
                argv.add(topicLevels.get(i));
            }
            script().eval("local length = table.getn(KEYS)\n" +
                            "for i = 1, length do\n" +
                            "   redis.call('HINCRBY', KEYS[i], ARGV[i], 1)\n" +
                            "end\n" +
                            "return redis.status_reply('OK')",
                    ScriptOutputType.STATUS, keys.toArray(new String[keys.size()]), argv.toArray(new String[argv.size()]));
        }
    } else {
        hash().hset(RedisKey.subscription(clientId), String.join("/", topicLevels), String.valueOf(qos.value()));
        hash().hset(RedisKey.topicName(topicLevels), clientId, String.valueOf(qos.value()));
    }
}

项目：various-vertx-demos 文件：Sensor.java

@Override
public void start() throws Exception {
    MqttClient client = MqttClient.create(vertx);

    client.rxConnect(PORT, HOST)
        .flatMapPublisher(ack ->
            Flowable.interval(1, TimeUnit.SECONDS)
                .flatMapSingle(l -> {
                    JsonObject payload = new JsonObject()
                        .put("uuid", id)
                        .put("data",
                            random.nextInt(100));
                    return client
                        .rxPublish("/data",
                            Buffer.buffer(payload.encode()),
                            MqttQoS.AT_MOST_ONCE, false, false);
                }))
        .subscribe();
}

项目：iot-platform 文件：SubscribeContainer.java

public static void put(String topic, String clientId, MqttQoS qos) {
    Message message = new Message();
    message.setClientId(clientId);
    message.setQoS(qos);

    LinkedList<Message> messages;
    if (!container.containsKey(topic)) {
        messages = new LinkedList<>();
        messages.add(message);
        container.put(topic, messages);
    } else {
        messages = container.get(topic);
        if (!messages.contains(message)) {
            messages.add(message);
        }
    }
}

项目：hono 文件：AbstractVertxBasedMqttProtocolAdapterTest.java

/**
 * Verifies that the adapter does not wait for a telemetry message being settled and accepted
 * by a downstream peer.
 * 
 * @param ctx The vert.x test context.
 */
@Test
public void testOnUnauthenticatedMessageDoesNotWaitForAcceptedOutcome(final TestContext ctx) {

    // GIVEN an adapter with a downstream telemetry consumer
    final Future<ProtonDelivery> outcome = Future.succeededFuture(mock(ProtonDelivery.class));
    givenATelemetrySenderForOutcome(outcome);
    MqttServer server = getMqttServer(false);
    AbstractVertxBasedMqttProtocolAdapter<ProtocolAdapterProperties> adapter = getAdapter(server);

    // WHEN a device publishes a telemetry message
    final Buffer payload = Buffer.buffer("some payload");
    final MqttEndpoint endpoint = mock(MqttEndpoint.class);
    final MqttPublishMessage messageFromDevice = mock(MqttPublishMessage.class);
    when(messageFromDevice.topicName()).thenReturn("telemetry/my-tenant/4712");
    when(messageFromDevice.qosLevel()).thenReturn(MqttQoS.AT_MOST_ONCE);
    when(messageFromDevice.payload()).thenReturn(payload);
    adapter.onUnauthenticatedMessage(endpoint, messageFromDevice).setHandler(ctx.asyncAssertSuccess());
}

项目：hono 文件：KuraProtocolAdapterTest.java

/**
 * Verifies that the adapter maps control messages with QoS 0 published from a Kura gateway to
 * the Telemetry endpoint.
 * 
 * @param ctx The helper to use for running tests on vert.x.
 */
@Test
public void testGetDownstreamMessageMapsKuraControlMessagesToTelemetryApi(final TestContext ctx) {

    // GIVEN an adapter configured to use the standard topic.control-prefix $EDC
    // and a custom control message content type
    config.setCtrlMsgContentType("control-msg");

    // WHEN a message is published to a topic with the Kura $EDC prefix as endpoint
    final MqttPublishMessage message = newMessage(MqttQoS.AT_MOST_ONCE, "$EDC/my-scope/4711");
    final Async determineAddressSuccess = ctx.async();
    Future<Message> msgTracker = adapter.getDownstreamMessage(message).map(msg -> {
        determineAddressSuccess.complete();
        return msg;
    });

    // THEN the message is forwarded to the telemetry API
    // and has the custom control message content type
    determineAddressSuccess.await(2000);
    assertMessageProperties(msgTracker.result(), config.getCtrlMsgContentType(),
            TelemetryConstants.TELEMETRY_ENDPOINT, "my-scope", "4711");
}

项目：hono 文件：KuraProtocolAdapterTest.java

/**
 * Verifies that the adapter recognizes control messages published to a topic with a custom control prefix.
 * 
 * @param ctx The helper to use for running tests on vert.x.
 */
@Test
public void testGetDownstreamMessageRecognizesControlMessagesWithCustomControlPrefix(final TestContext ctx) {

    // GIVEN an adapter configured to use a custom topic.control-prefix
    config.setControlPrefix("bumlux");

    // WHEN a message is published to a topic with the custom prefix as endpoint
    final MqttPublishMessage message = newMessage(MqttQoS.AT_MOST_ONCE, "bumlux/my-scope/4711");
    final Async determineAddressSuccess = ctx.async();
    Future<Message> msgTracker = adapter.getDownstreamMessage(message).map(msg -> {
        determineAddressSuccess.complete();
        return msg;
    });

    // THEN the message is recognized as a control message and forwarded to the event API
    determineAddressSuccess.await(2000);
    assertMessageProperties(msgTracker.result(), config.getCtrlMsgContentType(),
            TelemetryConstants.TELEMETRY_ENDPOINT, "my-scope", "4711");
}

项目：hono 文件：KuraProtocolAdapterTest.java

/**
 * Verifies that the adapter forwards data messages with QoS 0 published from a Kura gateway to
 * the Telemetry endpoint.
 * 
 * @param ctx The helper to use for running tests on vert.x.
 */
@Test
public void testGetDownstreamMessageMapsKuraDataMessagesToTelemetryApi(final TestContext ctx) {

    // GIVEN an adapter configured with a custom data message content type
    config.setDataMsgContentType("data-msg");

    // WHEN a message is published to an application topic with QoS 0
    final MqttPublishMessage message = newMessage(MqttQoS.AT_MOST_ONCE, "my-scope/4711");
    final Async determineAddressSuccess = ctx.async();
    Future<Message> msgTracker = adapter.getDownstreamMessage(message).map(msg -> {
        determineAddressSuccess.complete();
        return msg;
    });

    // THEN the message is forwarded to the telemetry API
    // and has the configured data message content type
    determineAddressSuccess.await(2000);
    assertMessageProperties(msgTracker.result(), config.getDataMsgContentType(),
            TelemetryConstants.TELEMETRY_ENDPOINT, "my-scope", "4711");
}

项目：hono 文件：KuraProtocolAdapterTest.java

/**
 * Verifies that the adapter forwards application messages with QoS 1 published from a Kura gateway to
 * the Event endpoint.
 * 
 * @param ctx The helper to use for running tests on vert.x.
 */
@Test
public void testGetDownstreamMessageMapsKuraDataMessagesToEventApi(final TestContext ctx) {

    // GIVEN an adapter

    // WHEN a message is published to an application topic with QoS 1
    final MqttPublishMessage message = newMessage(MqttQoS.AT_LEAST_ONCE, "my-scope/4711");
    final Async determineAddressSuccess = ctx.async();
    Future<Message> msgTracker = adapter.getDownstreamMessage(message).map(msg -> {
        determineAddressSuccess.complete();
        return msg;
    });

    // THEN the message is forwarded to the event API
    determineAddressSuccess.await(2000);
    assertMessageProperties(msgTracker.result(), config.getDataMsgContentType(),
            EventConstants.EVENT_ENDPOINT, "my-scope", "4711");
}