Package io.zenoh.query

Class Querier

  • All Implemented Interfaces:
    io.zenoh.session.SessionDeclaration , java.lang.AutoCloseable 
    
public final class Querier
 implements SessionDeclaration, AutoCloseable

    A querier that allows to send queries to a Queryable.

    Queriers are automatically undeclared when dropped.

    Example:

    try (Session session = Zenoh.open(config)) {
    QuerierOptions options = new QuerierOptions();
    options.setTarget(QueryTarget.BEST_MATCHING);
    Querier querier = session.declareQuerier(selector.getKeyExpr(), options);
    //...
    Querier.GetOptions options = new Querier.GetOptions();
    options.setPayload(ZBytes.from("Example payload"));
    querier.get(reply -> {...}, options);
}