/*@jsxRuntime automatic @jsxImportSource react*/
const {Fragment: _Fragment, jsx: _jsx, jsxs: _jsxs} = arguments[0];
function _createMdxContent(props) {
  const _components = Object.assign({
    p: "p",
    h2: "h2",
    a: "a",
    code: "code",
    pre: "pre",
    span: "span",
    ul: "ul",
    li: "li"
  }, props.components), {Link} = _components;
  if (!Link) _missingMdxReference("Link", true);
  return _jsxs(_Fragment, {
    children: [_jsx(_components.p, {
      children: "It’s sum­mer time and we have just re­leased Vert.x 3.5.0.Beta1!"
    }), "\n", _jsxs(_components.h2, {
      id: "lets-go-rxjava2",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#lets-go-rxjava2"
      }), "Let’s go RxJava2"]
    }), "\n", _jsx(_components.p, {
      children: "First and fore­most this re­lease de­liv­ers the Rx­Java2 API with sup­port of its full range of types."
    }), "\n", _jsxs(_components.p, {
      children: ["In ad­di­tion of ", _jsx(_components.code, {
        children: "Single"
      }), ", Rx­i­fied APIs ex­pose also the", _jsx(_components.code, {
        children: "Completable"
      }), " and ", _jsx(_components.code, {
        children: "Maybe"
      }), " types"]
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-java",
        children: [_jsx(_components.span, {
          className: "hljs-comment",
          children: "// expose Handler<AsyncResult<Void>>"
        }), "\n", _jsx(_components.span, {
          className: "hljs-type",
          children: "Completable"
        }), " ", _jsx(_components.span, {
          className: "hljs-variable",
          children: "completable"
        }), " ", _jsx(_components.span, {
          className: "hljs-operator",
          children: "="
        }), " server.rxClose();\n\ncompletable.subscribe(() -> System.out.println(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"closed\""
        }), "));\n\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// expose Handler<AsyncResult<String>> where the result can be null"
        }), "\nMaybe<String> ipAddress = dnsClient.rxLookup(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"www.google.com\""
        }), ");\nipAddress.subscribe(\n  value -> System.out.println(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"resolved to \""
        }), " + value),\n  err -> err.printStackTrace(),\n  () -> System.out.println(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"does not resolve\""
        }), "));\n"]
      })
    }), "\n", _jsxs(_components.p, {
      children: ["Rx­Java aug­ments Vert.x streams with a ", _jsx(_components.code, {
        children: "toObservable()"
      }), " method, Rx­Java2 adds the ", _jsx(_components.code, {
        children: "toFlowable()"
      }), " method:"]
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-java",
        children: [_jsx(_components.span, {
          className: "hljs-comment",
          children: "// Flowable<Buffer> maps to a ReadStream<Buffer>"
        }), "\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// back-pressured stream"
        }), "\nFlowable<Buffer> flowable = asyncFile.toFlowable();\n\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// but we still can get an Observable<Buffer>"
        }), "\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// non back-pressured stream"
        }), "\nObservable<Buffer> flowable = asyncFile.toObservable();\n"]
      })
    }), "\n", _jsxs(_components.p, {
      children: ["What’s so dif­fer­ent be­tween ", _jsx(_components.code, {
        children: "Flowable"
      }), " and ", _jsx(_components.code, {
        children: "Observable"
      }), " ? the for­mer han­dles back-​pressure, i.e the\nsub­scriber can con­trol the flow of items and the later can not!!!"]
    }), "\n", _jsxs(_components.p, {
      children: ["You can read the doc­u­men­ta­tion in the beta sec­tion of the ", _jsx(Link, {
        href: "/docs/3.5.0.Beta1/vertx-rx/java2/",
        passHref: true,
        children: _jsx(_components.a, {
          href: "",
          children: "docs"
        })
      }), "\nor go straight to the ", _jsx(_components.a, {
        href: "https://github.com/vert-x3/vertx-examples/tree/3.5.0.beta1/rxjava2-examples",
        children: "ex­am­ples"
      })]
    }), "\n", _jsxs(_components.h2, {
      id: "mqtt-client",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#mqtt-client"
      }), "MQTT Client"]
    }), "\n", _jsx(_components.p, {
      children: "In Vert.x 3.4 we added the MQTT server, 3.5 com­pletes the MQTT story with the MQTT client:"
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-java",
        children: [_jsx(_components.span, {
          className: "hljs-type",
          children: "MqttClient"
        }), " ", _jsx(_components.span, {
          className: "hljs-variable",
          children: "mqttClient"
        }), " ", _jsx(_components.span, {
          className: "hljs-operator",
          children: "="
        }), " MqttClient.create(vertx,\n   ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "new"
        }), " ", _jsx(_components.span, {
          className: "hljs-title class_",
          children: "MqttClientOptions"
        }), "()\n     .setPort(BROKER_PORT)\n     .setHost(BROKER_HOST)).connect(ar ->\n  ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "if"
        }), " (ar.succeeded()) {\n    System.out.println(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"Connected to a server\""
        }), ");\n\n    mqttClient.publish(\n      MQTT_TOPIC,\n      Buffer.buffer(MQTT_MESSAGE),\n      MqttQoS.AT_MOST_ONCE,\n      ", _jsx(_components.span, {
          className: "hljs-literal",
          children: "false"
        }), ",\n      ", _jsx(_components.span, {
          className: "hljs-literal",
          children: "false"
        }), ",\n      s -> mqttClient.disconnect(d -> System.out.println(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"Disconnected from server\""
        }), ")));\n  } ", _jsx(_components.span, {
          className: "hljs-keyword",
          children: "else"
        }), " {\n    System.out.println(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"Failed to connect to a server\""
        }), ");\n    ar.cause().printStackTrace();\n  }\n});\n"]
      })
    }), "\n", _jsxs(_components.p, {
      children: ["You can find MQTT client and server ex­am­ples ", _jsx(_components.a, {
        href: "https://github.com/vert-x3/vertx-examples/tree/3.5.0.beta1/mqtt-examples",
        children: "here"
      })]
    }), "\n", _jsxs(_components.h2, {
      id: "auth-handler-chaining",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#auth-handler-chaining"
      }), "Auth handler chaining"]
    }), "\n", _jsx(_components.p, {
      children: "There are times when you want to sup­port mul­ti­ple authN/authZ mech­a­nisms in a sin­gle ap­pli­ca­tion."
    }), "\n", _jsxs(_components.p, {
      children: ["Vert.x Web sup­ports auth han­dlers ", _jsx(Link, {
        href: "/docs/3.5.0.Beta1/vertx-web/java/#_chaining_multiple_auth_handlers",
        passHref: true,
        children: _jsx(_components.a, {
          href: "",
          children: "chain­ing"
        })
      })]
    }), "\n", _jsx(_components.pre, {
      children: _jsxs(_components.code, {
        className: "hljs language-java",
        children: [_jsx(_components.span, {
          className: "hljs-type",
          children: "ChainAuthHandler"
        }), " ", _jsx(_components.span, {
          className: "hljs-variable",
          children: "chain"
        }), " ", _jsx(_components.span, {
          className: "hljs-operator",
          children: "="
        }), " ChainAuthHandler.create();\n\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// add http basic auth handler to the chain"
        }), "\nchain.append(BasicAuthHandler.create(provider));\n\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// add form redirect auth handler to the chain"
        }), "\nchain.append(RedirectAuthHandler.create(provider));\n\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// secure your route"
        }), "\nrouter.route(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"/secure/resource\""
        }), ").handler(chain);\n\n", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// your app"
        }), "\nrouter.route(", _jsx(_components.span, {
          className: "hljs-string",
          children: "\"/secure/resource\""
        }), ").handler(ctx -> {\n  ", _jsx(_components.span, {
          className: "hljs-comment",
          children: "// do something..."
        }), "\n});\n"]
      })
    }), "\n", _jsxs(_components.h2, {
      id: "finally",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#finally"
      }), "Finally"]
    }), "\n", _jsx(_components.p, {
      children: "This beta also pro­vides"
    }), "\n", _jsxs(_components.ul, {
      children: ["\n", _jsx(_components.li, {
        children: "Vert.x Con­fig stores for Vault and Con­sul"
      }), "\n", _jsx(_components.li, {
        children: "Up­grade to Hazel­cast 3.8.2"
      }), "\n"]
    }), "\n", _jsxs(_components.h2, {
      id: "use-it",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#use-it"
      }), "Use it!"]
    }), "\n", _jsxs(_components.p, {
      children: ["You can use and con­sume it in your projects from Maven or Gra­dle as usual with the ver­sion ", _jsx(_components.code, {
        children: "3.5.0.Beta1"
      }), " or read"]
    }), "\n", _jsxs(_components.ul, {
      children: ["\n", _jsxs(_components.li, {
        children: ["the ", _jsx(Link, {
          href: "/docs/index-beta.html",
          passHref: true,
          children: _jsx(_components.a, {
            href: "",
            children: "doc­u­men­ta­tion pre­view"
          })
        })]
      }), "\n", _jsxs(_components.li, {
        children: ["see the ", _jsx(_components.a, {
          href: "https://github.com/vert-x3/vertx-examples/tree/3.5.0.beta1",
          children: "ex­am­ples"
        })]
      }), "\n"]
    }), "\n", _jsx(_components.p, {
      children: "You can also down­load var­i­ous bi­na­ries from Maven Cen­tral:"
    }), "\n", _jsxs(_components.ul, {
      children: ["\n", _jsx(_components.li, {
        children: _jsx(_components.a, {
          href: "https://search.maven.org/remotecontent?filepath=io/vertx/vertx-stack-manager/3.5.0.Beta1/vertx-stack-manager-3.5.0.Beta1.tar.gz",
          children: "base dis­trib"
        })
      }), "\n", _jsx(_components.li, {
        children: _jsx(_components.a, {
          href: "https://search.maven.org/remotecontent?filepath=io/vertx/vertx-stack-manager/3.5.0.Beta1/vertx-stack-manager-3.5.0.Beta1-full.tar.gz",
          children: "full dis­trib"
        })
      }), "\n", _jsx(_components.li, {
        children: _jsx(_components.a, {
          href: "https://search.maven.org/remotecontent?filepath=io/vertx/vertx-stack-manager/3.5.0.Beta1/vertx-stack-manager-3.5.0.Beta1-docs.zip",
          children: "docs zip"
        })
      }), "\n", _jsx(_components.li, {
        children: _jsx(_components.a, {
          href: "https://search.maven.org/remotecontent?filepath=io/vertx/vertx-stack-manager/3.5.0.Beta1/vertx-stack-manager-3.5.0.Beta1-stack-scala.tar.gz",
          children: "scala dis­trib"
        })
      }), "\n"]
    }), "\n", _jsx(_components.p, {
      children: "as usual feed­back is very im­por­tant to us and one goal of this beta re­lease is to let the com­mu­nity\npro­vide early feed­back!"
    }), "\n", _jsx(_components.p, {
      children: "The final is ex­pected at the be­gin­ning of Oc­to­ber."
    }), "\n", _jsx(_components.p, {
      children: "Enjoy"
    })]
  });
}
function MDXContent(props = {}) {
  const {wrapper: MDXLayout} = props.components || ({});
  return MDXLayout ? _jsx(MDXLayout, Object.assign({}, props, {
    children: _jsx(_createMdxContent, props)
  })) : _createMdxContent(props);
}
return {
  default: MDXContent
};
function _missingMdxReference(id, component) {
  throw new Error("Expected " + (component ? "component" : "object") + " `" + id + "` to be defined: you likely forgot to import, pass, or provide it.");
}


Blog

Vert.x 3.5.0.Beta1

Next post

Introducing Vert.x MQTT client

Previous post

OpenAPI (fka Swagger) 3 support in Eclipse Vert.x now in test stage!

Blog

Vert.x 3.5.0.Beta1

Next post

Introducing Vert.x MQTT client

Previous post

OpenAPI (fka Swagger) 3 support in Eclipse Vert.x now in test stage!

Related posts

Some Rest with Vert.x

Combine vert.x and mongo to build a giant

Real-time bidding with Websockets and Vert.x