Skip to content

Commit

Permalink
match changes to lamina
Browse files Browse the repository at this point in the history
  • Loading branch information
ztellman committed Dec 29, 2010
1 parent 7af67d7 commit f006f68
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 55 deletions.
2 changes: 1 addition & 1 deletion src/aleph/netty.clj
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@

(defn error-stage-handler [evt]
(when (instance? ExceptionEvent evt)
(log/error (.getCause ^ExceptionEvent evt)))
(log/warn "aleph.netty" (.getCause ^ExceptionEvent evt)))
evt)

(defmacro create-netty-pipeline
Expand Down
6 changes: 4 additions & 2 deletions src/aleph/redis.clj
Original file line number Diff line number Diff line change
Expand Up @@ -20,13 +20,15 @@
(f [\"set\" \"foo\" \"bar\"] timeout?)
The function will return a result-channel representing the response. To close the
connection, use lamina.connections/close-client."
connection, use lamina.connections/close-connection."
([host]
(redis-client :utf-8 host))
([charset host]
(redis-client charset host 6379))
([charset host port]
(pipelined-client #(tcp-client {:host host :port port :frame (redis-codec charset)}))))
(client
#(tcp-client {:host host :port port :frame (redis-codec charset)})
(str "redis @ " host ":" port))))



Expand Down
52 changes: 0 additions & 52 deletions src/aleph/utils.clj

This file was deleted.

0 comments on commit f006f68

Please sign in to comment.