horpto/gist:226617ae319a4cef1e78b35df05358e3

## gistfile1.md

      
    Raw
  

              gistfile1.md
            
          
    ##assertQueue([queue, [options]])
- queue - string or '' (random name)
- options:
+ exclusive  -  если true, то очередь видна только в этом connection
+ durable - очередь не исчезает при рестарте брокера (сообщение не теряются)
+ autoDelete - удалить очередь, когда число консьюмеров станет 0
+ arguments - брокер-специфик расширения
+ messageTtl (0<= n < 2^32) миллисекунды
+ expires (0 < n < 2^32) - уничтожить очередь после n мс не использования
+ deadLetterExchange (string) - exchange в который попадает сообщение  deadLetterRoutingKey
+ maxLength - максимальная число сообщений в очереди
+ maxPriority - сделать очередь с приоритетами
##bindQueue(queue, source, pattern, [args])
- queue - имя очереди
- source - имя очереди
- pattern - routingKey
##assertExchange(exchange, type, [options])
- exchange - имя
- type - direct | fanout | topic
- options:
+ durable - пережить рестарт
+ internal - сообщение не может
+ autoDelete
+ alternateExchange
+ arguments
##publish(exchange, routingKey, content, [options])
- exchange - имя
- routingKey
- content - Buffer - контент
- options:
+ expiration
+ userId
+ CC
+ priority
+ persistent - deliveryMode
+ deliveryMode - 1 - не персистент, 2 - персистент
+ mandatory - вернуть, если нет очереди
+ BCC - like CC, but not send to consumers
    + immediate
    + contentType
    + contentEncoding
    + headers - 
    + correlationId - матч реквесты
    + replyTo - имя для очереди
    + messageId
    + timestamp
    + type - тип
    + appId - ид аппликухи, посылающей мессагу    

##consume(queue, function(msg) {...}, [options])
- queue - имя очереди
- Функция (msg)
- options:
+ consumerTag - string
+ noLocal - rabbit ignore it.
+ noAck - не ждать ack
+ exclusive
+ priority
+ arguments
 msg:
    + content - Buffer - контент
    + fields - 
        deliveryTag
        consumerTag
        exchange
        routingKey
        redelivered
        redelivered
    + properties

##bindExchange(destination, source, pattern, [args]) - Bind an exchange to another exchange.
- destination - exchange name
- source - exchange name
- pattern - direct | fanout | topic
##sendToQueue(queue, content, [options])  послать сообщение в очередь минуя роутинг
- queue - имя очереди
- content - список
- options - опции такие же как для #publish