This Clojure library should serve as an idiomatic wrapper around the great JGroups 4.0.0 Java library from Bela Ban. As a feature-complete wrapper is a challenging project and time is short on our hands, this is not complete, yet.
We are not there, yet. If you would like to work with us on this project, just send a short message, we are happy about any help, with any skilllevel. For now, you can create channels which will cluster automatically with other channels. You can not pass custom settings into the channel, this is planned for version 0.1.0.
It is possible to create multiple channels, which are identified by keywords. As JGroups works with callbacks, you need to provide these callback functions upon creation of the channel in a map:
(clj-groups.channel/connect! "channel-id"
{:receive (fn [msg] (println msg)}You only need to specify the callbacks that you really want to use. Below is an example with all possible callbacks specified.
(def callbacks
{:receive
(fn [msg] (println msg) )
:get-state
(fn [output] (println output)
:set-state
(fn [input] (println input)
:view-accepted
(fn [view] (println view))
:suspect
(fn [mbr] (println mbr))
:block
(fn [] (println "Block"))
:unblock
(fn [] (println "Unblock"))})
(clj-groups.channel/connect! "channel-id"
callbacks)This will create a channel which is returned by the function. It can be accessed in further operations via the given identifier.
One of these operations is sending messages:
(let [chnl (clj-groups.channel/connect! "test-channel"
callbacks)]
(clj-groups.channel/send-message! chnl
{:target nil
:message "Heyoo"}))This will propagate the message to the participiants of the cluster 'test-channel'. It will be processed inside the receive callback.
Channels can also be closed, to detach your application from the cluster.
(clj-groups.channel/close! channel)This will close the channel.
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.