/*@jsxRuntime automatic @jsxImportSource react*/
const {Fragment: _Fragment, jsx: _jsx, jsxs: _jsxs} = arguments[0];
function _createMdxContent(props) {
  const _components = Object.assign({
    p: "p",
    a: "a",
    ul: "ul",
    li: "li",
    pre: "pre",
    code: "code",
    span: "span",
    strong: "strong",
    img: "img"
  }, props.components);
  return _jsxs(_Fragment, {
    children: [_jsxs(_components.p, {
      children: ["In this ar­ti­cle, we will see how to set up the new Vert.x MQTT client. Ac­tu­ally, I have a ", _jsx(_components.a, {
        href: "https://github.com/Sammers21/vertx-mqtt-client-example",
        children: "real ex­am­ple"
      }), " so you can try it quickly."]
    }), "\n", _jsx(_components.p, {
      children: "If you are using Maven or Gra­dle, add the fol­low­ing de­pen­dency to the de­pen­den­cies sec­tion of your project de­scrip­tor to ac­cess the Vert.x MQTT client:"
    }), "\n", _jsxs(_components.ul, {
      children: ["\n", _jsx(_components.li, {
        children: "Maven (in your pom.xml):"
      }), "\n"]
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-xml",
        children: [_jsxs(_components.span, {
          className: "hljs-tag",
          children: ["<", _jsx(_components.span, {
            className: "hljs-name",
            children: "dependency"
          }), ">"]
        }), "\n    ", _jsxs(_components.span, {
          className: "hljs-tag",
          children: ["<", _jsx(_components.span, {
            className: "hljs-name",
            children: "groupId"
          }), ">"]
        }), "io.vertx", _jsxs(_components.span, {
          className: "hljs-tag",
          children: ["</", _jsx(_components.span, {
            className: "hljs-name",
            children: "groupId"
          }), ">"]
        }), "\n    ", _jsxs(_components.span, {
          className: "hljs-tag",
          children: ["<", _jsx(_components.span, {
            className: "hljs-name",
            children: "artifactId"
          }), ">"]
        }), "vertx-mqtt", _jsxs(_components.span, {
          className: "hljs-tag",
          children: ["</", _jsx(_components.span, {
            className: "hljs-name",
            children: "artifactId"
          }), ">"]
        }), "\n    ", _jsxs(_components.span, {
          className: "hljs-tag",
          children: ["<", _jsx(_components.span, {
            className: "hljs-name",
            children: "version"
          }), ">"]
        }), "3.5.0.Beta1", _jsxs(_components.span, {
          className: "hljs-tag",
          children: ["</", _jsx(_components.span, {
            className: "hljs-name",
            children: "version"
          }), ">"]
        }), "\n", _jsxs(_components.span, {
          className: "hljs-tag",
          children: ["</", _jsx(_components.span, {
            className: "hljs-name",
            children: "dependency"
          }), ">"]
        }), "\n"]
      })
    }), "\n", _jsxs(_components.ul, {
      children: ["\n", _jsx(_components.li, {
        children: "Gra­dle (in your build.gra­dle file):"
      }), "\n"]
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-groovy",
        children: ["dependencies {\n  compile ", _jsx(_components.span, {
          className: "hljs-string",
          children: "'io.vertx:vertx-mqtt:3.5.0.Beta1'"
        }), "\n}\n"]
      })
    }), "\n", _jsx(_components.p, {
      children: "Now that you’ve set up your project, you can cre­ate a sim­ple ap­pli­ca­tion which will re­ceive all mes­sages from all bro­ker chan­nels:"
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-java",
        children: ["\n", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "import"
        }), " io.vertx.core.AbstractVerticle;\n", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "import"
        }), " io.vertx.mqtt.MqttClient;\n", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "import"
        }), " io.vertx.mqtt.MqttClientOptions;\n\n", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "import"
        }), " java.io.UnsupportedEncodingException;\n\n", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "public"
        }), " ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "class"
        }), " ", _jsx(_components.span, {
          className: "hljs-title class_",
          children: "MainVerticle"
        }), " ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "extends"
        }), " ", _jsx(_components.span, {
          className: "hljs-title class_",
          children: "AbstractVerticle"
        }), " {\n\n  ", _jsx(_components.span, {
          className: "hljs-meta",
          children: "@Override"
        }), "\n  ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "public"
        }), " ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "void"
        }), " ", _jsx(_components.span, {
          className: "hljs-title function_",
          children: "start"
        }), _jsx(_components.span, {
          className: "hljs-params",
          children: "()"
        }), " {\n     ", _jsx(_components.span, {
          className: "hljs-type",
          children: "MqttClientOptions"
        }), " ", _jsx(_components.span, {
          className: "hljs-variable",
          children: "options"
        }), " ", _jsx(_components.span, {
          className: "hljs-operator",
          children: "="
        }), " ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "new"
        }), " ", _jsx(_components.span, {
          className: "hljs-title class_",
          children: "MqttClientOptions"
        }), "();\n      ", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// specify broker host"
        }), "\n      options.setHost(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"iot.eclipse.org\""
        }), ");\n      ", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// specify max size of message in bytes"
        }), "\n      options.setMaxMessageSize(", _jsx(_components.span, {
          className: "hljs-number",
          children: "100_000_000"
        }), ");\n\n    ", _jsx(_components.span, {
          className: "hljs-type",
          children: "MqttClient"
        }), " ", _jsx(_components.span, {
          className: "hljs-variable",
          children: "client"
        }), " ", _jsx(_components.span, {
          className: "hljs-operator",
          children: "="
        }), " MqttClient.create(vertx, options);\n\n    client.publishHandler(s -> {\n      ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "try"
        }), " {\n        ", _jsx(_components.span, {
          className: "hljs-type",
          children: "String"
        }), " ", _jsx(_components.span, {
          className: "hljs-variable",
          children: "message"
        }), " ", _jsx(_components.span, {
          className: "hljs-operator",
          children: "="
        }), " ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "new"
        }), " ", _jsx(_components.span, {
          className: "hljs-title class_",
          children: "String"
        }), "(s.payload().getBytes(), ", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"UTF-8\""
        }), ");\n        System.out.println(String.format(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"Receive message with content: \\\"%s\\\" from topic \\\"%s\\\"\""
        }), ", message, s.topicName()));\n      } ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "catch"
        }), " (UnsupportedEncodingException e) {\n        e.printStackTrace();\n      }\n    });\n\n    client.connect(s -> {\n      ", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// subscribe to all subtopics"
        }), "\n      client.subscribe(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"#\""
        }), ", ", _jsx(_components.span, {
          className: "hljs-number",
          children: "0"
        }), ");\n    });\n  }\n}\n"]
      })
    }), "\n", _jsxs(_components.p, {
      children: ["The ", _jsx(_components.strong, {
        children: "pub­lish­Han­dler"
      }), " is the han­dler called each time the bro­ker, lo­cated at ", _jsx(_components.code, {
        children: "iot.eclipse.org:1883"
      }), ", sends a mes­sage to you, from the top­ics you are sub­scrib­ing for."]
    }), "\n", _jsxs(_components.p, {
      children: ["But only pro­vid­ing a han­dler is not enough, you should also con­nect to the bro­ker and sub­scribe to some top­ics. For this rea­son, you should use the ", _jsx(_components.strong, {
        children: "con­nect"
      }), " method and then call ", _jsx(_components.strong, {
        children: "sub­scribe"
      }), " when the con­nec­tion es­tab­lished."]
    }), "\n", _jsxs(_components.p, {
      children: ["To de­ploy this ver­ti­cle from an ap­pli­ca­tion you should have in your ", _jsx(_components.strong, {
        children: "main"
      }), " method some­thing like that:"]
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-java",
        children: [_jsx(_components.span, {
          className: "hljs-type",
          children: "Vertx"
        }), " ", _jsx(_components.span, {
          className: "hljs-variable",
          children: "vertx"
        }), " ", _jsx(_components.span, {
          className: "hljs-operator",
          children: "="
        }), " Vertx.vertx();\nvertx.deployVerticle(MainVerticle.class.getCanonicalName());\n"]
      })
    }), "\n", _jsx(_components.p, {
      children: "When you have com­pleted all steps cor­rectly the re­sult should look like that:"
    }), "\n", _jsx(_components.p, {
      children: _jsx(_components.img, {
        src: "http://i.imgur.com/b4yYQJE.gif",
        alt: ""
      })
    }), "\n", _jsxs(_components.p, {
      children: ["As the al­ter­na­tive and rec­om­mended way to boot­strap Vert.x ap­pli­ca­tions you can use ", _jsx(_components.a, {
        href: "https://github.com/vert-x3/vertx-maven-starter",
        children: "vertx-​maven-starter"
      }), " or ", _jsx(_components.a, {
        href: "https://github.com/vert-x3/vertx-gradle-starter",
        children: "vertx-​gradle-starter"
      }), ". For com­plet­ing this guide I have used the first one. The final source code avail­able ", _jsx(_components.a, {
        href: "https://github.com/Sammers21/vertx-mqtt-client-example",
        children: "here"
      }), ". If you would like to learn more about Vert.x MQTT client API then check out the ", _jsx(_components.a, {
        href: "https://github.com/vert-x3/vertx-mqtt-client/blob/initial-work/src/main/asciidoc/java/index.adoc",
        children: "full doc­u­men­ta­tion"
      }), " and ", _jsx(_components.a, {
        href: "https://github.com/vert-x3/vertx-examples/tree/3.5.0.beta1/mqtt-examples",
        children: "more ex­am­ples"
      }), "."]
    }), "\n", _jsx(_components.p, {
      children: "Thank you for read­ing!"
    }), "\n", _jsx(_components.p, {
      children: "Cheers!"
    })]
  });
}
function MDXContent(props = {}) {
  const {wrapper: MDXLayout} = props.components || ({});
  return MDXLayout ? _jsx(MDXLayout, Object.assign({}, props, {
    children: _jsx(_createMdxContent, props)
  })) : _createMdxContent(props);
}
return {
  default: MDXContent
};


Blog

Introducing Vert.x MQTT client

Next post

An Eclipse Vert.x Gradle Plugin

Previous post

Vert.x 3.5.0.Beta1

Blog

Introducing Vert.x MQTT client

Next post

An Eclipse Vert.x Gradle Plugin

Previous post

Vert.x 3.5.0.Beta1

Related posts

TCP Client using Eclipse Vert.x, Kotlin and Gradle build

Real-time bidding with Websockets and Vert.x

Checklist for Migrating from Vert.x 2.1.x to Vert.x 3 - Part One