         cb err, res?.rows?.map (row) -> row.node
 
 
-LOST_TRANSACTION_TIMEOUT = 10 * 1000
+LOST_TRANSACTION_TIMEOUT = 60 * 1000
 
 ##
 # Wraps the postgres-js transaction with our model operations.

        ], cb

    getNodeListeners: (node, cb) ->
        @db.query "SELECT DISTINCT listener FROM subscriptions WHERE node = $1 AND listener IS NOT NULL"
        , [node]
        , (err, res) ->
            cb err, res?.rows?.map((row) -> row.listener)

        @db.query "SELECT \"user\", node, subscription FROM subscriptions WHERE \"user\"=$1 OR listener=$1 ORDER BY updated DESC", [ actor ], (err, res) ->
            cb err, res?.rows

    getPending: (node, cb) ->
        db = @db
        async.waterfall [(cb2) ->
