code: public SubscriptionWorker<ObjectNode> getSubscriptionWorker(String subscriptionName, String database) {
          return getSubscriptionWorker(ObjectNode.class, subscriptionName, database);
      }
docs: It opens a subscription and starts pulling documents since a last processed document for that subscription.
  The connection options determine client and server cooperation rules like document batch sizes or a timeout in a matter of which a client
  needs to acknowledge that batch has been processed. The acknowledgment is sent after all documents are processed by subscription's handlers.
  
  There can be only a single client that is connected to a subscription.
  @param subscriptionName The name of subscription
  @param database Target database
  @return Subscription object that allows to add/remove subscription handlers.