emilioriosvz

var amqp = require('amqplib')

var open = require('amqplib').connect('amqp://localhost');

const connect = (url = 'amqp://localhost') => {
  return new Promise((resolve, reject) => {
    amqp.connect(url)
      .then(conn => resolve(conn))
      .catch(err => reject(err))
  })

tsibley

{
   "query" : {
      "filtered" : {
         "query" : {
            "custom_score" : {
               "query" : {
                  "boosting" : {
                     "negative_boost" : 0.5,
                     "positive" : {
                        "bool" : {