         @sequence += 1
         
         record =
-          sequence: seq
-          directive: 'subscribe'
+          seq: seq
+          action: 'subscribe'
           channel: channel
         
         @sock.send JSON.stringify(record)

        @sequence += 1
        
        record =
          sequence: seq
          directive: 'publish'
          channel: channel
          message: message
        
        @sock.send JSON.stringify(record)
        .then =>

        @sequence += 1
        
        record =
          seq: seq
          action: 'unsubscribe'
          channel: channel
        
        @sock.send JSON.stringify(record)
