Permalink
Browse files

clean dynamic-extent declarations

  • Loading branch information...
1 parent 32b37e9 commit db8a756e79256622f706872ae8f6e0c75aaecc54 @lisp committed Feb 9, 2012
Showing with 13 additions and 17 deletions.
  1. +1 −1 commands.lisp
  2. +0 −1 device-level.lisp
  3. +0 −2 frames.lisp
  4. +1 −5 processing.lisp
  5. +11 −7 readmes/example-publish-get-loop.lisp
  6. +0 −1 test/test.lisp
View
@@ -598,7 +598,7 @@ messages in between sending the cancel method and receiving the cancel-ok reply.
class)))
-(def-amqp-command amqp:Publish (class &key body exchange routing-key mandatory immediate
+(def-amqp-command amqp:publish (class &key body exchange routing-key mandatory immediate
content-type content-encoding headers delivery-mode
priority correlation-id reply-to expiration message-id timestamp
type user-id)
View
@@ -1503,7 +1503,6 @@ returned.")
first, write a content header based on the properties, then write the content
according to the combined channel data type and content type. Combine the header's possibly
incomplete content type with the channel's to specify the effective encoding.")
- (declare (dynamic-extent args))
(:method ((channel amqp:channel) body &rest args)
;; configure the respective basic for the (content x element-type x content-type)
View
@@ -170,7 +170,6 @@
(:documentation "Allocate a new output frame and bind it to the
connection. The concrete frame class will depend on the connection version.
Given a channel, delegate to the respective connection.")
- (declare (dynamic-extent args))
(:method ((channel amqp:channel) &rest args)
(declare (dynamic-extent args))
@@ -187,7 +186,6 @@
(:documentation "Allocate a new input frame and bind it to the
connection. The concrete frame class will depend on the connection version.
Given a channel, delegate to the respective connection.")
- (declare (dynamic-extent args))
(:method ((channel amqp:channel) &rest args)
(declare (dynamic-extent args))
View
@@ -436,7 +436,6 @@ processing. On the other hand, it impedes streaming.
args)))
(defgeneric call-with-encoded-arguments (operator class method &rest args)
- (declare (dynamic-extent args))
(:method (op (class amqp:object) (method symbol) &rest args)
(declare (dynamic-extent args))
(apply #'call-with-encoded-arguments op class (amqp:ensure-method class method)
@@ -448,7 +447,6 @@ processing. On the other hand, it impedes streaming.
(defgeneric call-with-decoded-properties (operator class frame &rest args)
- (declare (dynamic-extent args))
(:method ((operator function) class (frame amqp:frame) &rest args)
"Given a frame, decode the properties from the data buffer and continue."
(declare (dynamic-extent args))
@@ -460,7 +458,7 @@ processing. On the other hand, it impedes streaming.
(defgeneric call-with-encoded-properties (operator class &rest args)
- (declare (dynamic-extent args)))
+ )
#+(or ) ;; this is ambiguous: is it the response or request side?
@@ -608,7 +606,6 @@ processing. On the other hand, it impedes streaming.
(:documentation "Process a decoded, read frame as a 'command'. This applies to
both method and content frames. A method is dispatched to the respective
respond-to operator.")
- (declare (dynamic-extent args))
(:method ((channel amqp:channel) (class amqp:object) (operation frame-decoder) &rest args)
;; at this point, the frame object has been reified, and any operation arguments or properties
@@ -621,7 +618,6 @@ processing. On the other hand, it impedes streaming.
channel class operation args)))
(defgeneric dynamic-process-command (dynamic-handler channel class type &rest args)
- (declare (dynamic-extent args))
(:method ((operator t) (channel t) (class t) (method amqp:method) &rest args)
"Given an unhandled method, apply its own operator, for which the initial definition
@@ -32,17 +32,17 @@
(amqp:request-declare publish-queue)
(amqp:request-declare exchange)
- (amqp:request-bind publish-queue :exchange exchange :queue publish-queue :routing-key routing-key)
-
+ (amqp:bind publish-queue :exchange exchange :queue publish-queue :routing-key routing-key)
+
(dotimes (i count)
(dolist (datum data)
- (amqp:request-publish publish-basic :exchange exchange :body datum :routing-key routing-key)
- (amqp:request-get get-basic :queue get-queue)))))
+ (amqp:request-publish publish-basic :exchange (amqp:exchange-exchange exchange) :body datum :routing-key routing-key)
+ (print (amqp:request-get get-basic :queue get-queue))))))
(defparameter *c* (make-instance 'amqp:connection :uri "amqp://guest:guest@localhost/"))
-(defparameter *ch1* (amqp:channel *c* :uri (uri "amqp:/")))
-(defparameter *ch2* (amqp:channel *c* :uri (uri "amqp:/")))
+(defparameter *ch1* (amqp:channel *c* :uri (puri:uri "amqp:/")))
+(defparameter *ch2* (amqp:channel *c* :uri (puri:uri "amqp:/")))
(publish-get-loop *ch1* *ch2* '("this is a test") 1)
@@ -61,4 +61,8 @@
;;; [20100215T155724Z00] DEBUG #<CONNECTION #x4F1C566>: open-connection: requesting version: #(65 77 81 80 1 1 0 9)/:AMQP-1-1-0-9-1.
;;; [20100215T155724Z00] DEBUG #<CONNECTION #x4F1C566>: open-connection: [ok=1], updated class to: AMQP-1-1-0-9-1:CONNECTION.
;;; even thoug an r8 broker, it accepts the connection. ?
-;;; (publish-get-loop *ch1* *ch2* '("a") 1 :log-level :debug)
+;;; (publish-get-loop *ch1* *ch2* '("a") 1 :log-level :debug)
+
+
+;;; (defparameter *c* (make-instance 'amqp:connection :uri "amqp://guest:guest@ec2-175-41-174-180.ap-southeast-1.compute.amazonaws.com/"))
+
View
@@ -675,7 +675,6 @@
;;; generic dispatch and keyword processing overhead
(defgeneric test-keywords (context1 context2 &rest args &key key1 key2 key3 key4 key5)
- (declare (dynamic-extent args))
(:method ((context1 t) (context2 null) &rest args)
(declare (dynamic-extent args))
(every #'identity args))

0 comments on commit db8a756

Please sign in to comment.