 
   ## ACK/NACK messages
   ackMessage: (message) ->
+    return if not @channel
     fields = message.amqp.fields
     debug 'ACK', fields.routingKey, fields.deliveryTag
     # NOTE: server will only give us new message after this
     @channel.ack message.amqp, false
   nackMessage: (message) ->
+    return if not @channel
     fields = message.amqp.fields
     debug 'NACK', fields.routingKey, fields.deliveryTag
     @channel.nack message.amqp, false, false


  ## Sending/Receiving messages
  sendTo: (type, name, message, callback) ->
    # queue must exists
    data = new Buffer JSON.stringify message
    showLimit = 80



  subscribeToQueue: (queueName, handler, callback) ->
    return callback new Error 'msgflo.amqp.subscribeToQueue():  Not connected' if not @channel
    debug 'subscribe', queueName
    # queue must exists
    deserialize = (message) =>
