Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Cosmetics

  • Loading branch information...
commit 75a5c587384f86572be9bc5b72aa75eebf92b96c 1 parent 3ea128e
@michaelklishin michaelklishin authored
View
6 src/langohr/basic.clj
@@ -9,9 +9,9 @@
(ns langohr.basic
(:refer-clojure :exclude [get])
- (:require [langohr util])
- (:import (com.rabbitmq.client Channel AMQP AMQP$BasicProperties AMQP$BasicProperties$Builder Consumer GetResponse ReturnListener)
- (java.util Map Date)))
+ (:require langohr.util)
+ (:import [com.rabbitmq.client Channel AMQP AMQP$BasicProperties AMQP$BasicProperties$Builder Consumer GetResponse ReturnListener]
+ [java.util Map Date]))
;;
View
2  src/langohr/channel.clj
@@ -8,7 +8,7 @@
;; You must not remove this notice, or any other, from this software.
(ns langohr.channel
- (:import (com.rabbitmq.client ConnectionFactory Connection Channel AMQP$Channel$FlowOk)))
+ (:import [com.rabbitmq.client ConnectionFactory Connection Channel AMQP$Channel$FlowOk]))
;;
View
2  src/langohr/confirm.clj
@@ -8,7 +8,7 @@
;; You must not remove this notice, or any other, from this software.
(ns langohr.confirm
- (:import (com.rabbitmq.client Channel AMQP$Confirm$SelectOk ConfirmListener)))
+ (:import [com.rabbitmq.client Channel AMQP$Confirm$SelectOk ConfirmListener]))
;;
View
2  src/langohr/consumers.clj
@@ -9,7 +9,7 @@
(ns langohr.consumers
(:refer-clojure :exclude [get])
- (:import (com.rabbitmq.client Channel Consumer DefaultConsumer QueueingConsumer ShutdownSignalException Envelope AMQP$BasicProperties QueueingConsumer$Delivery))
+ (:import [com.rabbitmq.client Channel Consumer DefaultConsumer QueueingConsumer ShutdownSignalException Envelope AMQP$BasicProperties QueueingConsumer$Delivery])
(:use [langohr.basic :as lhb]))
View
4 src/langohr/core.clj
@@ -8,8 +8,8 @@
;; You must not remove this notice, or any other, from this software.
(ns langohr.core
- (:import (com.rabbitmq.client ConnectionFactory Connection Channel ShutdownListener))
- (:require [langohr.channel]))
+ (:import [com.rabbitmq.client ConnectionFactory Connection Channel ShutdownListener])
+ (:require langohr.channel))
;;
;; Defaults
View
2  src/langohr/exchange.clj
@@ -10,7 +10,7 @@
(ns langohr.exchange
"Exchanges are the entities to which messages are sent. Exchanges match and distribute messages across queues."
(:refer-clojure :exclude [declare])
- (:import (com.rabbitmq.client Channel AMQP$Exchange$DeclareOk AMQP$Exchange$DeleteOk AMQP$Exchange$BindOk)))
+ (:import [com.rabbitmq.client Channel AMQP$Exchange$DeclareOk AMQP$Exchange$DeleteOk AMQP$Exchange$BindOk]))
;;
;; API
View
4 src/langohr/queue.clj
@@ -9,8 +9,8 @@
(ns langohr.queue
(:refer-clojure :exclude [declare])
- (:import (com.rabbitmq.client Channel AMQP$Queue$DeclareOk AMQP$Queue$BindOk AMQP$Queue$UnbindOk AMQP$Queue$DeleteOk AMQP$Queue$PurgeOk)
- (java.util Map)))
+ (:import [com.rabbitmq.client Channel AMQP$Queue$DeclareOk AMQP$Queue$BindOk AMQP$Queue$UnbindOk AMQP$Queue$DeleteOk AMQP$Queue$PurgeOk]
+ java.util.Map))
;;
;; API
View
2  src/langohr/tx.clj
@@ -8,7 +8,7 @@
;; You must not remove this notice, or any other, from this software.
(ns langohr.tx
- (:import (com.rabbitmq.client Channel)))
+ (:import com.rabbitmq.client.Channel))
;;
Please sign in to comment.
Something went wrong with that request. Please try again.