{
  "name": "rabbitmq",
  "versions": {
    "0.0.2": {
      "name": "rabbitmq",
      "version": "0.0.2",
      "dependencies": {
        "should": "3.1.4",
        "amqplib": "0.1.3",
        "underscore": "1.6.0"
      },
      "bugs": {
        "url": "https://github.com/KealPub/node-rabbit-lite/issues",
        "email": "me@eivanov.net"
      },
      "repository": {
        "type": "git",
        "url": "https://github.com/KealPub/node-rabbit-lite"
      },
      "description": "Модуль для легкой и удобной работы с RabbitMQ Базируется на модуле https://github.com/squaremo/amqp.node",
      "homepage": "https://github.com/KealPub/node-rabbit-lite",
      "_id": "rabbitmq@0.0.2",
      "dist": {
        "shasum": "6a11e913f89a67b462c696b931a55e8ec546e4c6",
        "tarball": "https://devops.nuvaprod.software/verdaccio/rabbitmq/-/rabbitmq-0.0.2.tgz",
        "integrity": "sha512-BI1C4A5kOMDEnz7KVg3zJwE60qvjD8ee6lTHqZMUC1hfwMiPOaW/MTw+jLj8AfksrjrLCtSUKL7GXwKcqm6TKw==",
        "signatures": [
          {
            "keyid": "SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA",
            "sig": "MEYCIQCImGWu5MRYYhXQs95X2Pm+hERZQ7RC+pQq5wtibBQtNgIhAN2Xg7EfqDJp9e5e5yqWzSxDCrGX9Y7rqN9bYHy0ekBs"
          }
        ]
      },
      "_from": "node-rabbit.git/",
      "_npmVersion": "1.3.21",
      "_npmUser": {
        "name": "kealman",
        "email": "me@eivanov.net"
      },
      "maintainers": [
        {
          "name": "kealman",
          "email": "me@eivanov.net"
        }
      ],
      "contributors": []
    }
  },
  "time": {
    "modified": "2022-06-25T09:00:11.471Z",
    "created": "2014-04-09T18:56:17.497Z",
    "0.0.1": "2014-04-09T18:56:17.497Z",
    "0.0.2": "2014-04-09T19:05:48.397Z"
  },
  "users": {},
  "dist-tags": {
    "0.0.2": "0.0.2",
    "latest": "0.0.2"
  },
  "_rev": "7-41e4a65f98654ac2",
  "_id": "rabbitmq",
  "readme": "# Node Rabbit\n\nМодуль для легкой и удобной работы с RabbitMQ\nБазируется на модуле https://github.com/squaremo/amqp.node\n\nНа данный момент работа ведется только с дефолтной ('') точкой обмена\n\n### Install\n\n`npm install git+ssh://git@github.com:KealPub/node-rabbit-lite.git`\n\n### Example\n\n```javascript\n    var RabbitMQ = require(\"rabbitmq\").createConnect(\"amqp://rabbit-mq-host\").RabbitMQ;\n\n    var testQueue = new RabbitMQ(\"test.queue\");\n\n    testQueue.subscribe(function(message){\n        console.log(message);\n    }, function(){\n        testQueue.publish({test: \"test\"});\n    });\n\n```\n\n# API\n\n### createConnect(host)\nСоздает подключение до Rabbit. Используется метод `connect` из amqp.node\nПодробнее: http://squaremo.github.io/amqp.node/doc/channel_api.html#toc_1\n\n## RabbitMQ\n\n### new RabbitMQ(name, [options], [connect])\nСоздание обработчика очереди. `name` строка имени очереди с которой будет происходить работа.\n\n`options` объект опций очереди, применятеся для `assertQueue`, подробней можно прочитать тут: http://squaremo.github.io/amqp.node/doc/channel_api.html#toc_16\n\nПо умолчанию выставленно `durable: true` `autoDelete: true`.\n\n`connect` кастомный объект канала: http://squaremo.github.io/amqp.node/doc/channel_api.html#toc_10\n\nПо умолчанию используется общий для всех\n\n### RabbitMQ#subscribe(messageHandler, [callback], [needAck])\nПодписка на очередь.\n\n`messageHandler` является функцией, которая принимает аргумент `message`. `message` - Объект `new Message()`. Отрабатывает при поступлении нового сообщения в очередь.\n\n`callback` - функция, которая отрабатывает при успешной подписки на очередь.\n\n`needAck` - Boolean, указывает на то, нужно ли очереди дожидаться подтверждения принятия сообщения.\n\n### RabbitMQ#unsubscribe()\nОтписывается от текущей очереди\n\n### RabbitMQ#publish(message, [options])\nПубликует сообщение в очередь.\nИспользует метод `sendToQueue` библиотеки amqp.node\n\n`message` - сообщение для публикации, может быть как объектом (автоматически сконвертится в JSON), так и любым другим типом, с которым работает `Buffer`\n\n`options` - объект опций при публикации, передается в `sendToQueue`, подробнее http://squaremo.github.io/amqp.node/doc/channel_api.html#toc_27\n\n### RabbitMQ#getConnect()\nВозвращает объект канала\n\n### RabbitMQ#connected()\nВозвращает открыто ли подключение до Rabbit. true или false.\n\n## Message\n\n### new Message(message, [connect], [needAck])\nСоздание объекта сообщения.\n`message` - Объект сообщения из библиотеки amqp.node  (http://squaremo.github.io/amqp.node/doc/channel_api.html#toc_29)\n\n`connect` - Объект кастомного канала (то же что и в RabbitMQ)\n\n`needAck` - Boolean, следует ли подтвержать получение этого сообщения\n\n### Message.message\nТело сообщения\n\n### Message.properties\nДополнительные заголовки сообщения (см. документацию к протоколу AMQP)\n\n### Message#acked()\nПодтверждение получения сообщения\n\n### Message#reply(message)\nОтвет на сообщение, если в заголовке сообщения указан параметр `replyTo` (см. документацию к `RabbitMQ#publish()`). Если необходимо, автоматически подтверждает прием сообщения (`ack`)\n\n### Event \"reply\"\nСрабатывет при ответе на сообщение.\n\n__Example__:\n```javascript\n    //...\n    message.on(\"reply\", function(){\n        console.log(\"Reply!\")\n    });\n\n    message.reply(\"I'am reply\");\n```\n\nTODO:\n* Реализовать методы управления очередью, такие как удаление, изменение параметров и т.д.\n* Сделать возможность мульти канального подключения\n* Сделать работу с разными точками обмена",
  "_attachments": {}
}
