Paul Legato pjlegato
pjlegato
/ gist:8655414
Created
January 27, 2014 19:12
Adding event listeners to Immutant InfiniSpan caches
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (definterface CacheListenerInterface | |
| (^void eventReceived [^org.infinispan.notifications.cachelistener.event.Event event])) | |
| (deftype ^{org.infinispan.notifications.Listener {:sync true}} CacheListener [] | |
| CacheListenerInterface | |
| (^{CacheEntryCreated {}} eventReceived [this event] | |
| (println "Event received: " event))) | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (defn dev-mode? | |
| "Returns true if the app is running in dev mode." | |
| [] | |
| (let [project (registry/get :project)] | |
| (not (or (System/getenv "LEIN_NO_DEV") | |
| (->> project meta :active-profiles (not-any? #{:dev})))))) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (defn get-queue | |
| "Returns the JMS queue object with the given name, if it exists." | |
| [name] | |
| (if-let [default (registry/get "jboss.messaging.default")] | |
| (.getResource (.getManagementService default) (immutant.messaging.core/jms-name name)))) |