/[de-setf-amqp]/package.lisp
ViewVC logotype

Contents of /package.lisp

Parent Directory Parent Directory | Revision Log Revision Log


Revision 3 - (show annotations)
Tue Feb 23 09:05:39 2010 UTC (4 years, 1 month ago) by janderson
File size: 10217 byte(s)
Merge commit 'remotes/github/master' into remotes/git-svn
1 ;;; -*- Mode: lisp; Syntax: ansi-common-lisp; Base: 10; Package: common-lisp-user; -*-
2
3 (in-package :cl-user)
4
5 (de.setf.utility:document :file
6 (description "This file defines the packages for the 'de.setf.amqp' library.")
7 (copyright
8 "Copyright 2010 [james anderson](mailto:james.anderson@setf.de) All Rights Reserved"
9 "'de.setf.amqp' is free software: you can redistribute it and/or modify it under the terms of version 3
10 of the GNU Affero General Public License as published by the Free Software Foundation.
11
12 'setf.amqp' is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the
13 implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
14 See the Affero General Public License for more details.
15
16 A copy of the GNU Affero General Public License should be included with 'de.setf.amqp' as `AMQP:agpl.txt`.
17 If not, see the GNU [site](http://www.gnu.org/licenses/).")
18
19 (long-description "Several packages are used
20
21 - `_` isolates macro symbols
22 - `de.setf.amqp` (`amqp`) : exports the names of protocol classes and operators.
23 - `de.setf.amqp-state` (`amqps`) : exports the channel and connection state names
24 - `de.setf.amqp.utility` (`amqp.u`) : exports operator names which are not part of the protocol
25 specifications, but should be available to an application.
26 - `de.setf.amqp.implementation` (`amqp.i`) : the package for implementation code."))
27
28
29 (unless (find-package :_)
30 (defpackage :_
31 (:use)
32 (:documentation "An isolated package for symbols in macros.")))
33
34 (modpackage :amqp
35 (:use)
36 (:nicknames :de.setf.amqp)
37 (:documentation "")
38 (:export
39 :*connection-timeout*
40 :*default-locale*
41 :*default-mechanism*
42 :*default-version*
43 :*frame-size-maximum*
44 :*log-level*
45 :*standard-port*
46 :*timestamp-epoch*
47 :+frame-end+
48 :access
49 :ack
50 :alert
51 :amqp-exception
52 :array
53 :array-p
54 :basic
55 :basic-headers
56 :basic-no-ack
57 :binary
58 :binary-1024
59 :binary-128
60 :binary-16
61 :binary-256
62 :binary-32
63 :binary-40
64 :binary-48
65 :binary-512
66 :binary-64
67 :binary-72
68 :binary-8
69 :bind
70 :bind-ok
71 :bit
72 :body
73 :cancel
74 :cancel-ok
75 :channel
76 :channel-error
77 :channel-handler
78 :channel-handlers
79 :channel-limit-reached
80 :channel-p
81 :channel.connection
82 :channel.exchange
83 :channel.queue
84 :class-class
85 :class-exchange
86 :class-headers
87 :class-id
88 :class-methods
89 :class-queue
90 :close
91 :close-ok
92 :cluster
93 :cluster
94 :command
95 :command-case
96 :command-handler
97 :command-invalid-error
98 :command-loop
99 :commit
100 :commit-ok
101 :condition
102 :connection
103 :connection-client-properties
104 :connection-error
105 :connection-forced-error
106 :connection-p
107 :connection-server-properties
108 :connection.channel
109 :connection.exchange
110 :connection.queue
111 :consume
112 :consume-ok
113 :control
114 :decimal
115 :decimal-p
116 :declare
117 :declare-ok
118 :def-handler
119 :delete
120 :delete-ok
121 :deliver
122 :dtx
123 :ensure-method
124 :ensure-object
125 :error
126 :exchange
127 :exchange-exchange
128 :field
129 :file
130 :find-protocol-class
131 :flow
132 :flow-ok
133 :frame
134 :frame-arguments
135 :frame-body-size
136 :frame-buffer
137 :frame-channel
138 :frame-class
139 :frame-class-id
140 :frame-class-id
141 :frame-cycle
142 :frame-error
143 :frame-instance
144 :frame-major-version
145 :frame-method-id
146 :frame-minor-version
147 :frame-payload
148 :frame-property-flags
149 :frame-property-list
150 :frame-protocol
151 :frame-size
152 :frame-type
153 :frame-weight
154 :get
155 :get-empty
156 :get-ok
157 :handler-bind
158 :handler-case
159 :handler-ecase
160 :header
161 :heartbeat
162 :initialize
163 :input-frame
164 :internal-error
165 :invalid-path-error
166 :iso-8859-character
167 :iso-8859-character-p
168 :link
169 :list
170 :list-p
171 :locale
172 :log
173 :log*
174 :long
175 :long-long
176 :longstr
177 :make-channel
178 :make-connection
179 :mechanism
180 :message
181 :method
182 :method-id
183 :method-name
184 :not-allowed-error
185 :not-implemented-error
186 :object
187 :oob-body
188 :oob-header
189 :oob-method
190 :open
191 :open-channel
192 :open-connection
193 :open-ok
194 :output-frame
195 :protocol-header
196 :publish
197 :purge
198 :purge-ok
199 :qos
200 :qos-ok
201 :queue
202 :queue-queue
203 :recover
204 :recover-async
205 :recover-ok
206 :redirect
207 :register-handlers
208 :reject
209 :request
210 :request
211 :request-get
212 :request-ok
213 :request-publish
214 :resource-error
215 :response
216 :return
217 :rollback
218 :rollback-ok
219 :secure
220 :secure-ok
221 :select
222 :select-ok
223 :send-ack
224 :send-cancel
225 :send-close
226 :send-open
227 :session
228 :short
229 :shortstr
230 :stage
231 :start
232 :start
233 :start-ok
234 :start-ok
235 :stream
236 :string
237 :string-16-p
238 :string-32-p
239 :string-8-p
240 :struct
241 :struct-p
242 :syntax-error
243 :table
244 :table-p
245 :test
246 :trace
247 :tune
248 :tune-ok
249 :tunnel
250 :tx
251 :unbind
252 :unbind-ok
253 :undefined-method-error
254 :unexpected-frame-error
255 :use-channel
256 :use-connection
257 :utf32-character
258 :utf32-character-p
259 :vbinary
260 :version
261 :wire-length
262 :wire-level-type
263 :with-commands
264 :with-open-channel
265 :CONTENT-TOO-LARGE-ERROR
266 :NO-CONSUMERS-ERROR
267 :CONNECTION-FORCED-ERROR
268 :INVALID-PATH-ERROR
269 :ACCESS-REFUSED-ERROR
270 :NOT-FOUND-ERROR
271 :RESOURCE-LOCKED-ERROR
272 :PRECONDITION-FAILED-ERROR
273 :FRAME-ERROR
274 :SYNTAX-ERROR
275 :COMMAND-INVALID-ERROR
276 :UNEXPECTED-FRAME-ERROR
277 :RESOURCE-ERROR
278 :NOT-ALLOWED-ERROR
279 :NOT-IMPLEMENTED-ERROR
280 :INTERNAL-ERROR
281 ))
282
283
284 (modpackage :amqp.s
285 (:documentation "The home package for state names")
286 (:nicknames :de.setf.amqp-state)
287 (:use )
288 (:export
289 :state
290 :channel-state
291 :connection-state
292 :open
293 :open-connection
294 :open-channel
295 :use
296 :use-connection
297 :use-channel
298 :body
299 :use-channel.body
300 :method
301 :use-channel.method
302 :header
303 :use-channel.header
304 :heartbeat
305 :use-channel.heartbeat
306 :close
307 :close-connection
308 :close-channel))
309
310
311 (defpackage :de.setf.amqp.utility
312 (:use )
313 (:nicknames :amqp.u)
314 (:import-from :de.setf.amqp :*log-level*)
315 (:export
316 :*log-level*
317 :*version-headers*
318 :*version*
319 :12-byte-header-input-frame
320 :12-byte-header-output-frame
321 :7-byte-header-input-frame
322 :7-byte-header-output-frame
323 :8-byte-header-input-frame
324 :8-byte-header-output-frame
325 :channel-condition
326 :channel-error
327 :channel-flow-condition
328 :channel-flow-start-condition
329 :channel-flow-stop-condition
330 :connection-error
331 :collection-empty-p
332 :collection-size
333 :class-mime-type
334 :class-properties
335 :channel-ticket
336 :channel-realm
337 :dequeue
338 :enqueue
339 :invalid-state-error
340 :method-arguments
341 :queue
342 ))
343
344 (defpackage :de.setf.amqp.implementation
345 (:nicknames :amqp.i)
346 (:use :common-lisp
347 :de.setf.utility
348 :de.setf.amqp.utility)
349 ;; don't depending on load order, this introduces conflict.
350 ;; eg, tools->xml->cl-http->quickdraw#line
351 ;; #+ccl (:use :ccl)
352 #+clozure
353 (:import-from :ccl
354 :double-float-positive-infinity
355 :double-float-negative-infinity
356 #+ccl-1.4 :double-float-nan)
357 #+sbcl
358 (:import-from :sb-ext
359 :double-float-positive-infinity
360 :double-float-negative-infinity
361 :single-float-positive-infinity
362 :single-float-negative-infinity)
363 #+sbcl
364 (:use :sb-simple-streams)
365 #+sbcl
366 (:import-from :sb-simple-streams ; need the slots
367 :buf-len
368 :buffer
369 :buffer-ptr
370 :buffpos
371 :last-char-read-size
372 :max-out-pos
373 :out-buffer
374 :outpos
375 :pending)
376 (:import-from :amqp
377 :*standard-port*
378 :*default-version*
379 :*frame-size-maximum*
380 :*connection-timeout*
381 :*default-locale*
382 :*default-mechanism*
383 :*log-level*
384 :frame-buffer
385 :command-loop
386 :command-case)
387 #+ccl
388 (:import-from :ccl
389 #:open-stream-p
390 #:stream-clear-input
391 #:stream-clear-output
392 #:stream-direction
393 #:stream-element-type
394 #:stream-eofp
395 #:stream-finish-output
396 #:stream-force-output
397 #:stream-fresh-line
398 #:stream-listen
399 #:stream-read-byte
400 #:stream-write-byte
401 #:stream-write-string
402 )
403 #+clozure
404 (:import-from :ccl
405 #:stream-write-char
406 #:stream-unread-char
407 #:stream-read-char
408 #:stream-read-char-no-hang
409 #:stream-read-line
410 #:stream-terpri
411 )
412 #+mcl
413 (:import-from :ccl
414 #:stream-close
415 #:stream-read-sequence
416 #:stream-untyi
417 #:stream-tyi
418 #:stream-tyo
419 #:stream-write-sequence
420 )
421 #+sbcl
422 (:import-from :sb-gray
423 #:open-stream-p
424 #:stream-clear-input
425 #:stream-clear-output
426 #:stream-element-type
427 #:stream-finish-output
428 #:stream-force-output
429 #:stream-fresh-line
430 #:stream-listen
431 #:stream-read-byte
432 #:stream-read-char
433 #:stream-read-char-no-hang
434 #:stream-read-sequence
435 #:stream-terpri
436 ;; #:stream-tyi
437 ;; #:stream-tyo
438 #:stream-unread-char
439 ;; #:stream-untyi
440 #:stream-write-byte
441 #:stream-write-char
442 #:stream-write-sequence
443 #:stream-write-string
444 ))
445
446
447 (defpackage :de.setf.amqp.user
448 (:nicknames :amqp-user)
449 (:use :common-lisp :puri :de.setf.amqp.utility)
450 #+mcl (:use :ccl)
451 #+mcl (:shadowing-import-from :de.setf.amqp.utility
452 :connection-error)
453 #+clozure (:use :ccl)
454 #+sbcl (:use :sb-alien :sb-debug :sb-ext :sb-gray :sb-profile))

  ViewVC Help
Powered by ViewVC 1.1.5