The cl-bunny Reference Manual

Table of Contents

Next: , Previous: , Up: (dir)   [Contents][Index]

The cl-bunny Reference Manual

This is the cl-bunny Reference Manual, version 0.4.5, generated automatically by Declt version 2.3 "Robert April" on Tue Feb 20 07:54:48 2018 GMT+0.


Next: , Previous: , Up: Top   [Contents][Index]

1 Introduction

CL-BUNNY Build Status Coverage Status

CL-BUNNY is a RabbitMQ client. CL-BUNNY is based on IOLib and inspired by bunny and pika. Please use with caution - work in progress, error-handling not so descriptive, API is not always stable. Contributions are greatly appreciated!

Installation Notes

CL-BUNNY as well as some of its dependencies are not included in Quicklisp:

Examples

Foreword

To run examples you need to have RabbitMQ installed on localhost with

If you are new to RabbitMQ you may find the following links useful:

Hello World!

(defun hello-world ()
  (with-connection ()
    (with-channel ()
      (let ((x (exchange.default)))
        (->
          (queue.declare :name "cl-bunny.examples.hello-world" :auto-delete t)
          (subscribe (lambda (message)
                       (log:info "Received ~a"
                                 (message-body-string message)))))
        (publish x "Hello world!" :routing-key "cl-bunny.examples.hello-world"))
      (sleep 1))))

Error handling

(with-connection ()
  (with-channel ()
    (handler-case
        (channel.open)
      (connection-closed-error () (print "Can't open already opened channel")))))
-->
<WARN> [17:10:39] bunny iolib-threaded.lisp (channel.receive threaded-iolib-connection amqp-method-connection-close) -
 Connection closed by server: AMQP-ERROR-CHANNEL-ERROR[504, CHANNEL_ERROR - second 'channel.open' seen] in response to AMQP-METHOD-CHANNEL-OPEN
"Can't open already opened channel"
"Can't open already opened channel"

Headers Exchange

(with-connection ()
  (with-channel ()
    (let* ((x (exchange.headers "headers" :auto-delete t))
           (q1 (->
                 (queue.declare :exclusive t)
                 (queue.bind x :arguments '(("os" . "linux")
                                            ("cores" . 8)
                                            ("x-match" . "all")))))
           (q2 (->
                 (queue.declare :exclusive t)
                 (queue.bind x :arguments '(("os" . "osx")
                                            ("cores" . 4)
                                            ("x-match" . "any"))))))
      (subscribe q1 (lambda (message)
                      (log:info "~a received ~a" q1 (message-body-string message))))


      (subscribe q2 (lambda (message)
                      (log:info "~a received ~a" q2 (message-body-string message))))

      (publish x "8 cores/Linux" :properties '(:headers (("os" . "linux")
                                                       ("cores" . 8))))
      (publish x "8 cores/Linux" :properties '(:headers (("os" . "linux")
                                                       ("cores" . 8))))
      (publish x "8 cores/OS X"  :properties '(:headers (("os" . "osx")
                                                       ("cores" . 8))))
      (publish x "4 cores/Linux" :properties '(:headers (("os" . "linux")
                                                       ("cores" . 4))))

      (log:info "Waiting...")
      (sleep 3)
      (log:info "Disconnecting"))))

Mandatory messages

(with-connection ()
  (with-channel ()
    (let* ((x (exchange.default))
           (q (queue.declare :exclusive t)))

      (setf (exchange-on-return-callback x)
            (lambda (returned-message)
              (log:info "Got returned message ~a" (message-body-string returned-message))))

      (subscribe q (lambda (message)                       
                     (log:info "~a received ~a" q (message-body-string message))))

      (publish x "This will NOT be returned" :mandatory t :routing-key q)
      (publish x "This will be returned" :mandatory t
                                         :routing-key (format nil "wefvvtrw~a" (random 10)))        

      (log:info "Waiting...")
      (sleep 3)
      (log:info "Disconnecting"))))

More?

More examples can be found here

Special Thanks To

Copyright

Copyright (c) 2015,2016 Ilya Khaprov ilya.khaprov@publitechs.com and CONTRIBUTORS

CL-BUNNY uses a shared copyright model: each contributor holds copyright over their contributions to CL-BUNNY. The project versioning records all such contribution and copyright details.

If a contributor wants to further mark their specific copyright on a particular contribution, they should indicate their copyright solely in the commit message of the change when it is committed. Do not include copyright notices in files for this purpose.

License

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all
copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
SOFTWARE.

By contributing to the project, you agree to the license and copyright terms therein and release your contribution under these terms.


Next: , Previous: , Up: Top   [Contents][Index]

2 Systems

The main system appears first, followed by any subsystem dependency.


Previous: , Up: Systems   [Contents][Index]

2.1 cl-bunny

Maintainer

Ilya Khaprov <ilya.khaprov@publitechs.com>

Author

Ilya Khaprov <ilya.khaprov@publitechs.com>

License

MIT

Description

High-level interface for cl-rabbit

Version

0.4.5

Dependencies
Source

cl-bunny.asd (file)

Component

src (module)


Next: , Previous: , Up: Top   [Contents][Index]

3 Modules

Modules are listed depth-first from the system components tree.


Next: , Previous: , Up: Modules   [Contents][Index]

3.1 cl-bunny/src

Parent

cl-bunny (system)

Location

src/

Components

Next: , Previous: , Up: Modules   [Contents][Index]

3.2 cl-bunny/src/support

Dependency

package.lisp (file)

Parent

src (module)

Location

src/support/

Components

Next: , Previous: , Up: Modules   [Contents][Index]

3.3 cl-bunny/src/transport

Dependency

properties-and-headers.lisp (file)

Parent

src (module)

Location

src/transport/

Component

iolib-transport.lisp (file)


Next: , Previous: , Up: Modules   [Contents][Index]

3.4 cl-bunny/src/io

Dependency

transport (module)

Parent

src (module)

Location

src/io/

Components

Next: , Previous: , Up: Modules   [Contents][Index]

3.5 cl-bunny/src/base

Dependency

io (module)

Parent

src (module)

Location

src/base/

Components

Previous: , Up: Modules   [Contents][Index]

3.6 cl-bunny/src/connection

Dependency

base (module)

Parent

src (module)

Location

src/connection/

Components

Next: , Previous: , Up: Top   [Contents][Index]

4 Files

Files are sorted by type and then listed depth-first from the systems components trees.


Previous: , Up: Files   [Contents][Index]

4.1 Lisp


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.1 cl-bunny.asd

Location

cl-bunny.asd

Systems

cl-bunny (system)

Packages

cl-bunny.system


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.2 cl-bunny/src/package.lisp

Parent

src (module)

Location

src/package.lisp

Packages

cl-bunny


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.3 cl-bunny/src/support/pipe.lisp

Parent

support (module)

Location

src/support/pipe.lisp

Exported Definitions

-> (macro)


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.4 cl-bunny/src/support/int-allocator.lisp

Dependency

pipe.lisp (file)

Parent

support (module)

Location

src/support/int-allocator.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.5 cl-bunny/src/support/channel-id-allocator.lisp

Dependency

int-allocator.lisp (file)

Parent

support (module)

Location

src/support/channel-id-allocator.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.6 cl-bunny/src/support/promise.lisp

Dependency

channel-id-allocator.lisp (file)

Parent

support (module)

Location

src/support/promise.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.7 cl-bunny/src/support/sync-promise.lisp

Dependency

promise.lisp (file)

Parent

support (module)

Location

src/support/sync-promise.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.8 cl-bunny/src/support/async-promise.lisp

Dependency

sync-promise.lisp (file)

Parent

support (module)

Location

src/support/async-promise.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.9 cl-bunny/src/support/bunny-event.lisp

Dependency

async-promise.lisp (file)

Parent

support (module)

Location

src/support/bunny-event.lisp

Exported Definitions

*event-executor* (special variable)

Internal Definitions

bunny-event (class)


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.10 cl-bunny/src/conditions.lisp

Dependency

support (module)

Parent

src (module)

Location

src/conditions.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.11 cl-bunny/src/properties-and-headers.lisp

Dependency

conditions.lisp (file)

Parent

src (module)

Location

src/properties-and-headers.lisp

Exported Definitions
Internal Definitions

header-value (function)


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.12 cl-bunny/src/transport/iolib-transport.lisp

Parent

transport (module)

Location

src/transport/iolib-transport.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.13 cl-bunny/src/io/frame-and-payload-parser.lisp

Parent

io (module)

Location

src/io/frame-and-payload-parser.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.14 cl-bunny/src/io/output-frame-queue.lisp

Dependency

frame-and-payload-parser.lisp (file)

Parent

io (module)

Location

src/io/output-frame-queue.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.15 cl-bunny/src/base/channel-base.lisp

Parent

base (module)

Location

src/base/channel-base.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.16 cl-bunny/src/base/connection-base.lisp

Dependency

channel-base.lisp (file)

Parent

base (module)

Location

src/base/connection-base.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.17 cl-bunny/src/base/threaded-connection.lisp

Dependency

connection-base.lisp (file)

Parent

base (module)

Location

src/base/threaded-connection.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.18 cl-bunny/src/connection/spec.lisp

Parent

connection (module)

Location

src/connection/spec.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.19 cl-bunny/src/connection/pool.lisp

Dependency

spec.lisp (file)

Parent

connection (module)

Location

src/connection/pool.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.20 cl-bunny/src/connection/iolib-connection.lisp

Dependency

pool.lisp (file)

Parent

connection (module)

Location

src/connection/iolib-connection.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.21 cl-bunny/src/connection/iolib-threaded.lisp

Dependency

iolib-connection.lisp (file)

Parent

connection (module)

Location

src/connection/iolib-threaded.lisp

Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.22 cl-bunny/src/channel.lisp

Dependency

connection (module)

Parent

src (module)

Location

src/channel.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.23 cl-bunny/src/message.lisp

Dependency

channel.lisp (file)

Parent

src (module)

Location

src/message.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.24 cl-bunny/src/queue.lisp

Dependency

message.lisp (file)

Parent

src (module)

Location

src/queue.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.25 cl-bunny/src/exchange.lisp

Dependency

queue.lisp (file)

Parent

src (module)

Location

src/exchange.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.26 cl-bunny/src/consumer.lisp

Dependency

exchange.lisp (file)

Parent

src (module)

Location

src/consumer.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.27 cl-bunny/src/basic.lisp

Dependency

consumer.lisp (file)

Parent

src (module)

Location

src/basic.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.28 cl-bunny/src/confirm.lisp

Dependency

basic.lisp (file)

Parent

src (module)

Location

src/confirm.lisp

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.29 cl-bunny/src/tx.lisp

Dependency

confirm.lisp (file)

Parent

src (module)

Location

src/tx.lisp

Exported Definitions
Internal Definitions

tx-channel (class)


Previous: , Up: Lisp files   [Contents][Index]

4.1.30 cl-bunny/src/printer.lisp

Dependency

tx.lisp (file)

Parent

src (module)

Location

src/printer.lisp

Internal Definitions

Next: , Previous: , Up: Top   [Contents][Index]

5 Packages

Packages are listed by definition order.


Next: , Previous: , Up: Packages   [Contents][Index]

5.1 cl-bunny.system

Source

cl-bunny.asd

Use List

Previous: , Up: Packages   [Contents][Index]

5.2 cl-bunny

Source

package.lisp (file)

Nickname

bunny

Use List
Exported Definitions
Internal Definitions

Next: , Previous: , Up: Top   [Contents][Index]

6 Definitions

Definitions are sorted by export status, category, package, and then by lexicographic order.


Next: , Previous: , Up: Definitions   [Contents][Index]

6.1 Exported definitions


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.1 Special variables

Special Variable: *channel*

Current AMQP channel

Package

cl-bunny

Source

channel.lisp (file)

Special Variable: *connection*

Current AMQP connection

Package

cl-bunny

Source

connection-base.lisp (file)

Special Variable: *connection-type*
Package

cl-bunny

Source

connection-base.lisp (file)

Special Variable: *connections-pool*
Package

cl-bunny

Source

pool.lisp (file)

Special Variable: *event-executor*
Package

cl-bunny

Source

bunny-event.lisp (file)

Special Variable: *force-timeout*
Package

cl-bunny

Source

sync-promise.lisp (file)

Special Variable: *notification-lambda*

If not NIL expected to be lambda (lambda) -> bb:promise.

Package

cl-bunny

Source

connection-base.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.2 Macros

Macro: -> &body FORMS
Package

cl-bunny

Source

pipe.lisp (file)

Macro: with-channel PARAMS &body BODY
Package

cl-bunny

Source

channel.lisp (file)

Macro: with-connection PARAMS &body BODY
Package

cl-bunny

Source

connection-base.lisp (file)

Macro: with-consumers (&rest CONSUMERS) &body BODY
Package

cl-bunny

Source

consumer.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.3 Functions

Function: channel-on-error &optional CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: channel-on-return &optional CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.close REPLY-CODE CLASS-ID METHOD-ID &key REPLY-TEXT CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.confirm &optional CHANNEL
Package

cl-bunny

Source

confirm.lisp (file)

Function: channel.flow ACTIVE &key CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.new &key ON-ERROR CONNECTION CHANNEL-ID
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.new.open &key ON-ERROR CONNECTION CHANNEL-ID
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.open &optional CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.send CHANNEL METHOD &optional SYNC-CALLBACK
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.tx &optional CHANNEL
Package

cl-bunny

Source

tx.lisp (file)

Function: channel.wait-confirms &key CHANNEL TIMEOUT
Package

cl-bunny

Source

confirm.lisp (file)

Function: connection-channel-max &optional CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection-frame-max &optional CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection-heartbeat &optional CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection-on-blocked &optional CONNECTION
Package

cl-bunny

Source

iolib-connection.lisp (file)

Function: connection-on-close &optional CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection-on-unblocked &optional CONNECTION
Package

cl-bunny

Source

iolib-connection.lisp (file)

Function: connection-open-p &optional CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection-server-properties &optional CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection-spec-channel-max INSTANCE
Function: (setf connection-spec-channel-max) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-frame-max INSTANCE
Function: (setf connection-spec-frame-max) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-heartbeat-interval INSTANCE
Function: (setf connection-spec-heartbeat-interval) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-host INSTANCE
Function: (setf connection-spec-host) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-login INSTANCE
Function: (setf connection-spec-login) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-password INSTANCE
Function: (setf connection-spec-password) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-port INSTANCE
Function: (setf connection-spec-port) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-use-ipv6-p INSTANCE
Function: (setf connection-spec-use-ipv6-p) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-use-tls-p INSTANCE
Function: (setf connection-spec-use-tls-p) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-vhost INSTANCE
Function: (setf connection-spec-vhost) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection.close &key CONNECTION TIMEOUT
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection.consume &key CONNECTION TIMEOUT ONE-SHOT
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection.new &optional SPEC &key HEARTBEAT POOL-TAG
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection.open &optional CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connections-pool.add CONNECTION &key POOL
Package

cl-bunny

Source

pool.lisp (file)

Function: connections-pool.find-or-run TAG SPEC &key POOL
Package

cl-bunny

Source

pool.lisp (file)

Function: connections-pool.get SPEC &key POOL
Package

cl-bunny

Source

pool.lisp (file)

Function: connections-pool.remove CONNECTION-OR-TAG &key POOL
Package

cl-bunny

Source

pool.lisp (file)

Function: consume &key CHANNEL TIMEOUT ONE-SHOT
Package

cl-bunny

Source

consumer.lisp (file)

Function: exchange.bind DESTINATION SOURCE &key ROUTING-KEY NOWAIT ARGUMENTS CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.declare EXCHANGE &key TYPE PASSIVE DURABLE AUTO-DELETE INTERNAL NOWAIT ARGUMENTS CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.default &optional CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.delete EXCHANGE &key IF-UNUSED NOWAIT CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.direct &optional EXCHANGE &rest ARGS &key PASSIVE DURABLE AUTO-DELETE INTERNAL ARGUMENTS CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.exists-p NAME
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.fanout &optional EXCHANGE &rest ARGS &key PASSIVE DURABLE AUTO-DELETE INTERNAL ARGUMENTS CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.headers &optional EXCHANGE &rest ARGS &key PASSIVE DURABLE AUTO-DELETE INTERNAL ARGUMENTS CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.match ()
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.topic &optional EXCHANGE &rest ARGS &key PASSIVE DURABLE AUTO-DELETE INTERNAL ARGUMENTS CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: exchange.unbind DESTINATION SOURCE &key ROUTING-KEY NOWAIT ARGUMENTS CHANNEL
Package

cl-bunny

Source

exchange.lisp (file)

Function: message-app-id MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-body-string MESSAGE &optional ENCODING
Package

cl-bunny

Source

message.lisp (file)

Function: message-cluster-id MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-content-encoding MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-content-type MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-correlation-id MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-expiration MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-header-value MESSAGE NAME
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-headers MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-message-id MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-persistent-p MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-priority MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-reply-to MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-timestamp MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-type MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message-user-id MESSAGE
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: message.ack MESSAGE &key MULTIPLE CHANNEL
Package

cl-bunny

Source

message.lisp (file)

Function: message.nack MESSAGE &key MULTIPLE REQUEUE CHANNEL
Package

cl-bunny

Source

message.lisp (file)

Function: publish EXCHANGE CONTENT &key ROUTING-KEY MANDATORY IMMEDIATE CHANNEL PROPERTIES NOWAIT
Package

cl-bunny

Source

basic.lisp (file)

Function: qos &key PREFETCH-SIZE PREFETCH-COUNT GLOBAL CHANNEL
Package

cl-bunny

Source

basic.lisp (file)

Function: queue.bind QUEUE EXCHANGE &key ROUTING-KEY NOWAIT ARGUMENTS CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.consumer-count QUEUE &key CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.declare &key NAME PASSIVE DURABLE EXCLUSIVE AUTO-DELETE NOWAIT ARGUMENTS CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.declare-temp &key AUTO-DELETE NOWAIT ARGUMENTS CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.delete &optional QUEUE &key IF-UNUSED IF-EMPTY NOWAIT CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.exists-p NAME
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.get &optional QUEUE &key NO-ACK CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.message-count QUEUE &key CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.peek &optional QUEUE
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.purge QUEUE &key NOWAIT CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.put QUEUE CONTENT &key MANDATORY IMMEDIATE CHANNEL PROPERTIES NOWAIT
Package

cl-bunny

Source

queue.lisp (file)

Function: queue.unbind QUEUE EXCHANGE &key ROUTING-KEY ARGUMENTS CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: subscribe QUEUE FN &key TYPE ON-CANCEL CONSUMER-TAG NO-LOCAL NO-ACK NOWAIT EXCLUSIVE ARGUMENTS CHANNEL
Package

cl-bunny

Source

consumer.lisp (file)

Function: subscribe-sync QUEUE &key ON-CANCEL CONSUMER-TAG NO-LOCAL NO-ACK EXCLUSIVE ARGUMENTS CHANNEL
Package

cl-bunny

Source

consumer.lisp (file)

Function: tx.commit &optional CHANNEL
Package

cl-bunny

Source

tx.lisp (file)

Function: tx.rollback &optional CHANNEL
Package

cl-bunny

Source

tx.lisp (file)

Function: unsubscribe CONSUMER &key NOWAIT
Package

cl-bunny

Source

consumer.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.4 Generic functions

Generic Function: channel-connection OBJECT
Package

cl-bunny

Methods
Method: channel-connection (CONNECTION connection)
Source

channel.lisp (file)

Method: channel-connection (CHANNEL-BASE channel-base)

automatically generated reader method

Source

channel-base.lisp (file)

Generic Function: channel-id OBJECT
Package

cl-bunny

Methods
Method: channel-id (CHANNEL fixnum)
Source

connection-base.lisp (file)

Method: channel-id (CHANNEL connection)
Source

connection-base.lisp (file)

Method: channel-id (CHANNEL-BASE channel-base)

automatically generated reader method

Source

channel-base.lisp (file)

Generic Function: channel-open-p &optional CHANNEL
Package

cl-bunny

Methods
Method: channel-open-p &optional CHANNEL
Source

channel.lisp (file)

Generic Function: connection-spec OBJECT
Package

cl-bunny

Methods
Method: connection-spec (CONNECTION connection)

automatically generated reader method

Source

connection-base.lisp (file)

Generic Function: error-connection CONDITION
Package

cl-bunny

Methods
Method: error-connection (CONDITION server-error)
Source

conditions.lisp (file)

Method: error-connection (CONDITION connection-closed-error)
Source

conditions.lisp (file)

Generic Function: exchange-on-return OBJECT
Generic Function: (setf exchange-on-return) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: exchange-on-return (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Method: (setf exchange-on-return) NEW-VALUE (EXCHANGE exchange)

automatically generated writer method

Source

exchange.lisp (file)

Generic Function: message-body OBJECT
Package

cl-bunny

Methods
Method: message-body (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-channel OBJECT
Package

cl-bunny

Methods
Method: message-channel (TAG integer)
Source

message.lisp (file)

Method: message-channel (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-consumer OBJECT
Package

cl-bunny

Methods
Method: message-consumer (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-consumer-tag OBJECT
Package

cl-bunny

Methods
Method: message-consumer-tag (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-delivery-tag OBJECT
Package

cl-bunny

Methods
Method: message-delivery-tag (TAG integer)
Source

message.lisp (file)

Method: message-delivery-tag (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-exchange OBJECT
Package

cl-bunny

Methods
Method: message-exchange (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-properties OBJECT
Package

cl-bunny

Methods
Method: message-properties (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-redelivered-p OBJECT
Package

cl-bunny

Methods
Method: message-redelivered-p (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: message-routing-key OBJECT
Package

cl-bunny

Methods
Method: message-routing-key (MESSAGE message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: queue-arguments OBJECT
Package

cl-bunny

Methods
Method: queue-arguments (QUEUE queue)

automatically generated reader method

Source

queue.lisp (file)

Generic Function: queue-auto-delete-p OBJECT
Package

cl-bunny

Methods
Method: queue-auto-delete-p (QUEUE queue)

automatically generated reader method

Source

queue.lisp (file)

Generic Function: queue-durable-p OBJECT
Package

cl-bunny

Methods
Method: queue-durable-p (QUEUE queue)

automatically generated reader method

Source

queue.lisp (file)

Generic Function: queue-exclusive-p OBJECT
Package

cl-bunny

Methods
Method: queue-exclusive-p (QUEUE queue)

automatically generated reader method

Source

queue.lisp (file)

Generic Function: queue-name OBJECT
Package

cl-bunny

Methods
Method: queue-name (QUEUE string)
Source

queue.lisp (file)

Method: queue-name (QUEUE queue)

automatically generated reader method

Source

queue.lisp (file)

Generic Function: queue-server-named-p OBJECT
Package

cl-bunny

Methods
Method: queue-server-named-p (QUEUE queue)

automatically generated reader method

Source

queue.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.5 Conditions

Condition: authentication-error ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

server-error (condition)

Condition: channel-closed-error ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error-base (condition)

Direct methods

error-channel (method)

Direct slots
Slot: channel
Initargs

:channel

Readers

error-channel (generic function)

Condition: connection-closed-error ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error-base (condition)

Direct methods

error-connection (method)

Direct slots
Slot: connection
Initargs

:connection

Readers

error-connection (generic function)

Condition: network-error ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

transport-error (condition)

Condition: sync-promise-timeout ()
Package

cl-bunny

Source

sync-promise.lisp (file)

Direct superclasses

error (condition)

Condition: transport-error ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

amqp-protocol-error (condition)

Direct subclasses

network-error (condition)

Direct methods

transport-error-description (method)

Direct slots
Slot: description
Initargs

:description

Initform

(quote "")

Readers

transport-error-description (generic function)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.6 Structures

Structure: connection-spec ()
Package

cl-bunny

Source

spec.lisp (file)

Direct superclasses

structure-object (structure)

Direct methods
Direct slots
Slot: host
Type

string

Initform

"localhost"

Readers

connection-spec-host (function)

Writers

(setf connection-spec-host) (function)

Slot: port
Type

fixnum

Initform

5672

Readers

connection-spec-port (function)

Writers

(setf connection-spec-port) (function)

Slot: vhost
Type

string

Initform

"/"

Readers

connection-spec-vhost (function)

Writers

(setf connection-spec-vhost) (function)

Slot: login
Type

string

Initform

"guest"

Readers

connection-spec-login (function)

Writers

(setf connection-spec-login) (function)

Slot: password
Type

string

Initform

"guest"

Readers

connection-spec-password (function)

Writers

(setf connection-spec-password) (function)

Slot: use-tls-p
Type

boolean

Readers

connection-spec-use-tls-p (function)

Writers

(setf connection-spec-use-tls-p) (function)

Slot: use-ipv6-p
Type

boolean

Readers

connection-spec-use-ipv6-p (function)

Writers

(setf connection-spec-use-ipv6-p) (function)

Slot: channel-max
Type

(unsigned-byte 32)

Initform

cl-bunny::+channel-max+

Readers

connection-spec-channel-max (function)

Writers

(setf connection-spec-channel-max) (function)

Slot: frame-max
Type

(unsigned-byte 32)

Initform

cl-bunny::+frame-max+

Readers

connection-spec-frame-max (function)

Writers

(setf connection-spec-frame-max) (function)

Slot: heartbeat-interval
Type

(unsigned-byte 32)

Initform

cl-bunny::+heartbeat-interval+

Readers

connection-spec-heartbeat-interval (function)

Writers

(setf connection-spec-heartbeat-interval) (function)

Slot: tls-cert
Type

(or null pathname string (nibbles:octet-vector))

Readers

connection-spec-tls-cert (function)

Writers

(setf connection-spec-tls-cert) (function)

Slot: tls-key
Type

(or null pathname string (nibbles:octet-vector))

Readers

connection-spec-tls-key (function)

Writers

(setf connection-spec-tls-key) (function)

Slot: tls-ca
Type

(or null pathname string (nibbles:octet-vector))

Readers

connection-spec-tls-ca (function)

Writers

(setf connection-spec-tls-ca) (function)

Slot: tls-verify-peer
Type

boolean

Initform

t

Readers

connection-spec-tls-verify-peer (function)

Writers

(setf connection-spec-tls-verify-peer) (function)

Slot: tls-verify-hostname
Type

boolean

Initform

t

Readers

connection-spec-tls-verify-hostname (function)

Writers

(setf connection-spec-tls-verify-hostname) (function)


Previous: , Up: Exported definitions   [Contents][Index]

6.1.7 Classes

Class: connections-pool-base ()
Package

cl-bunny

Source

pool.lisp (file)

Direct superclasses

standard-object (class)

Direct subclasses

eq-connections-pool (class)

Class: eq-connections-pool ()
Package

cl-bunny

Source

pool.lisp (file)

Direct superclasses

connections-pool-base (class)

Direct methods
Direct slots
Slot: storage
Initform

(make-hash-table :test (function equal))

Readers

connections-pool-storage (generic function)

Slot: lock
Initform

(bordeaux-threads:make-recursive-lock "cl-bunny connections pool lock")

Readers

connections-pool-lock (generic function)


Previous: , Up: Definitions   [Contents][Index]

6.2 Internal definitions


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.1 Constants

Constant: +channel-max+
Package

cl-bunny

Source

spec.lisp (file)

Constant: +consume-receive-timeout+
Package

cl-bunny

Source

consumer.lisp (file)

Constant: +frame-max+
Package

cl-bunny

Source

spec.lisp (file)

Constant: +heartbeat-interval+
Package

cl-bunny

Source

spec.lisp (file)

Constant: +sync-promise-no-values+
Package

cl-bunny

Source

sync-promise.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.2 Special variables

Special Variable: *debug-connection*
Package

cl-bunny

Source

connection-base.lisp (file)

Special Variable: *event-base*
Package

cl-bunny

Source

iolib-transport.lisp (file)

Special Variable: *ignore-unknown-consumer-tags*
Package

cl-bunny

Source

consumer.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.3 Macros

Macro: channel.send% CHANNEL METHOD &body BODY
Package

cl-bunny

Source

channel.lisp (file)

Macro: channel.send-with-callback% CHANNEL METHOD &body BODY
Package

cl-bunny

Source

channel.lisp (file)

Macro: execute-in-connection-thread (&optional CONNECTION) &body BODY
Package

cl-bunny

Source

threaded-connection.lisp (file)

Macro: promise.resolve PROMISE &body VALUES
Package

cl-bunny

Source

promise.lisp (file)

Macro: send-to-connection-thread (&optional CONNECTION) &body BODY
Package

cl-bunny

Source

threaded-connection.lisp (file)

Macro: with-connection-close-on-socket-error CONNECTION &body BODY
Package

cl-bunny

Source

iolib-transport.lisp (file)

Macro: with-sync-promise-lock PROMISE &body BODY
Package

cl-bunny

Source

sync-promise.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.4 Functions

Function: add-consumer CHANNEL QUEUE TAG TYPE ON-MESSAGE ON-CANCEL
Package

cl-bunny

Source

consumer.lisp (file)

Function: channel-consume-message CHANNEL MESSAGE &key RETURN
Package

cl-bunny

Source

consumer.lisp (file)

Function: channel-id-allocated-p CHANNEL-ID-ALLOCATOR CHANNEL-ID
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: channel-id-allocator-int-allocator INSTANCE
Function: (setf channel-id-allocator-int-allocator) VALUE INSTANCE
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: channel-id-allocator-mutex INSTANCE
Function: (setf channel-id-allocator-mutex) VALUE INSTANCE
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: channel-id-allocator-p OBJECT
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: channel.close-ok% CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.flow-ok ACTIVE &key CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.receive-frame CHANNEL FRAME
Package

cl-bunny

Source

channel.lisp (file)

Function: channel.safe-close REPLY-CODE CLASS-ID METHOD-ID &key REPLY-TEXT CHANNEL
Package

cl-bunny

Source

channel.lisp (file)

Function: check-boolean-parameter PARAMS NAME DEFAULT
Package

cl-bunny

Source

spec.lisp (file)

Function: check-connection-alive CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: check-connection-string-credentials USERINFO
Package

cl-bunny

Source

spec.lisp (file)

Function: check-connection-string-host HOST
Package

cl-bunny

Source

spec.lisp (file)

Function: check-connection-string-port SCHEME PORT
Package

cl-bunny

Source

spec.lisp (file)

Function: check-connection-string-scheme SCHEME
Package

cl-bunny

Source

spec.lisp (file)

Function: check-connection-string-vhost VHOST
Package

cl-bunny

Source

spec.lisp (file)

Function: check-uint-parameter PARAMS NAME
Package

cl-bunny

Source

spec.lisp (file)

Function: check-vhost-single-segment VHOST
Package

cl-bunny

Source

spec.lisp (file)

Function: close-method-to-error CHANNEL METHOD
Package

cl-bunny

Source

conditions.lisp (file)

Function: connection-spec-p OBJECT
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-tls-ca INSTANCE
Function: (setf connection-spec-tls-ca) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-tls-cert INSTANCE
Function: (setf connection-spec-tls-cert) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-tls-key INSTANCE
Function: (setf connection-spec-tls-key) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-tls-verify-hostname INSTANCE
Function: (setf connection-spec-tls-verify-hostname) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection-spec-tls-verify-peer INSTANCE
Function: (setf connection-spec-tls-verify-peer) VALUE INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: connection.deregister-channel CHANNEL
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection.get-channel CHANNEL-ID &key CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection.register-channel CHANNEL
Package

cl-bunny

Source

connection-base.lisp (file)

Function: connection.send% CONNECTION METHOD
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: consumer-event-type CHANNEL CONSUMER-TYPE
Package

cl-bunny

Source

consumer.lisp (file)

Function: copy-channel-id-allocator INSTANCE
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: copy-connection-spec INSTANCE
Package

cl-bunny

Source

spec.lisp (file)

Function: copy-fap-parser INSTANCE
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: copy-int-allocator INSTANCE
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: copy-output-frame-queue INSTANCE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: deregister-exchange CHANNEL EXCHANGE
Package

cl-bunny

Source

channel.lisp (file)

Function: dispatch-consumed-message CHANNEL MESSAGE
Package

cl-bunny

Source

consumer.lisp (file)

Function: dispatch-consumer-cancel CHANNEL BASIC-CANCEL
Package

cl-bunny

Source

consumer.lisp (file)

Function: enqueue-frame CONNECTION FRAME
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: execute-consumer CONSUMER MESSAGE
Package

cl-bunny

Source

consumer.lisp (file)

Function: fap-parser-advance FAP-PARSER
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-advance-end FAP-PARSER READ
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-buffer INSTANCE
Function: (setf fap-parser-buffer) VALUE INSTANCE
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-buffer-index INSTANCE
Function: (setf fap-parser-buffer-index) VALUE INSTANCE
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-end-index INSTANCE
Function: (setf fap-parser-end-index) VALUE INSTANCE
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-frame INSTANCE
Function: (setf fap-parser-frame) VALUE INSTANCE
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-p OBJECT
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-parser INSTANCE
Function: (setf fap-parser-parser) VALUE INSTANCE
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: fap-parser-payload-parser INSTANCE
Function: (setf fap-parser-payload-parser) VALUE INSTANCE
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: find-consumer CHANNEL CONSUMER-TAG
Package

cl-bunny

Source

consumer.lisp (file)

Function: find-message-consumer CHANNEL MESSAGE
Package

cl-bunny

Source

consumer.lisp (file)

Function: get-connection-type SPEC
Package

cl-bunny

Source

connection-base.lisp (file)

Function: get-customized-connection-parameters SPEC
Package

cl-bunny

Source

spec.lisp (file)

Function: get-frame-bytes FRAME
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: get-registered-exchange CHANNEL NAME
Package

cl-bunny

Source

channel.lisp (file)

Function: header-value HEADERS NAME
Package

cl-bunny

Source

properties-and-headers.lisp (file)

Function: install-main-readers CONNECTION
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: int-allocator-allocate INT-ALLOCATOR
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-allocate% ()
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-allocated-p INT-ALLOCATOR VALUE
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-bits INSTANCE
Function: (setf int-allocator-bits) VALUE INSTANCE
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-isset% ()
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-max INSTANCE
Function: (setf int-allocator-max) VALUE INSTANCE
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-min INSTANCE
Function: (setf int-allocator-min) VALUE INSTANCE
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-p OBJECT
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-release INT-ALLOCATOR ALLOCATED
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-set% ()
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: int-allocator-unset% ()
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: make-async-promise NOTIFY-LAMBDA
Package

cl-bunny

Source

async-promise.lisp (file)

Function: make-channel-id-allocator &key (INT-ALLOCATOR INT-ALLOCATOR) (MUTEX MUTEX)
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: make-confirm-message CONTENT PROPERTIES EXCHANGE CHANNEL DELIVERY-TAG NOWAIT
Package

cl-bunny

Source

confirm.lisp (file)

Function: make-connection-spec% &key (HOST HOST) (PORT PORT) (VHOST VHOST) (LOGIN LOGIN) (PASSWORD PASSWORD) (USE-TLS-P USE-TLS-P) (USE-IPV6-P USE-IPV6-P) (CHANNEL-MAX CHANNEL-MAX) (FRAME-MAX FRAME-MAX) (HEARTBEAT-INTERVAL HEARTBEAT-INTERVAL) (TLS-CERT TLS-CERT) (TLS-KEY TLS-KEY) (TLS-CA TLS-CA) (TLS-VERIFY-PEER TLS-VERIFY-PEER) (TLS-VERIFY-HOSTNAME TLS-VERIFY-HOSTNAME)
Package

cl-bunny

Source

spec.lisp (file)

Function: make-fap-parser ()
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: make-fap-parser% &key (BUFFER BUFFER) (BUFFER-INDEX BUFFER-INDEX) (END-INDEX END-INDEX) (FRAME FRAME) (PARSER PARSER) (PAYLOAD-PARSER PAYLOAD-PARSER)
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Function: make-int-allocator &key MIN MAX
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: make-int-allocator% &key (BITS BITS) (MIN MIN) (MAX MAX)
Package

cl-bunny

Source

int-allocator.lisp (file)

Function: make-output-frame-queue &key (QUEUE QUEUE) (CURRENT-FRAME-BYTES CURRENT-FRAME-BYTES) (CURRENT-FRAME-POSITION CURRENT-FRAME-POSITION) (STATE STATE)
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: make-promise ()
Package

cl-bunny

Source

promise.lisp (file)

Function: make-sync-promise ()
Package

cl-bunny

Source

sync-promise.lisp (file)

Function: maybe-install-heartbeat-timer CONNECTION
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: maybe-unescape-component VALUE
Package

cl-bunny

Source

spec.lisp (file)

Function: new-channel-id-allocator MAX-CHANNELS
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: next-channel-id CHANNEL-ID-ALLOCATOR
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: notify-confirm-message-waiter MESSAGE ACKED
Package

cl-bunny

Source

confirm.lisp (file)

Function: notify-sync-promise-resolved PROMISE
Package

cl-bunny

Source

sync-promise.lisp (file)

Function: open-socket-and-say-hello CONNECTION
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: output-frame-queue-count OF-QUEUE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: output-frame-queue-current-frame-bytes INSTANCE
Function: (setf output-frame-queue-current-frame-bytes) VALUE INSTANCE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: output-frame-queue-current-frame-position INSTANCE
Function: (setf output-frame-queue-current-frame-position) VALUE INSTANCE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: output-frame-queue-p OBJECT
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: output-frame-queue-pop OF-QUEUE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: output-frame-queue-push OF-QUEUE FRAME
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: output-frame-queue-queue INSTANCE
Function: (setf output-frame-queue-queue) VALUE INSTANCE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: output-frame-queue-state INSTANCE
Function: (setf output-frame-queue-state) VALUE INSTANCE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: parse-boolean RAW-VALUE
Package

cl-bunny

Source

spec.lisp (file)

Function: parse-user-info USERINFO
Package

cl-bunny

Source

spec.lisp (file)

Function: parse-with-channel-params PARAMS
Package

cl-bunny

Source

channel.lisp (file)

Function: parse-with-channel-params-list PARAMS
Package

cl-bunny

Source

channel.lisp (file)

Function: parse-with-connection-params PARAMS
Package

cl-bunny

Source

connection-base.lisp (file)

Function: parse-with-connection-params-list PARAMS
Package

cl-bunny

Source

connection-base.lisp (file)

Function: perform-handshake CONNECTION CALLBACK
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: promise.force PROMISE &key TIMEOUT

Block until promise rejected/resolved or timeout expired.
If promise rejected respective error will be thrown in calling thread. If promise resolved returns respective values
If timeout expires throws THREADED-PROMISE-TIMEOUT

Package

cl-bunny

Source

sync-promise.lisp (file)

Function: promise.force% PROMISE

Actually return/throw

Package

cl-bunny

Source

sync-promise.lisp (file)

Function: queue.status QUEUE &key CHANNEL
Package

cl-bunny

Source

queue.lisp (file)

Function: read-frames CONNECTION
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: register-exchange CHANNEL EXCHANGE
Package

cl-bunny

Source

channel.lisp (file)

Function: release-channel-id CHANNEL-ID-ALLOCATOR CHANNEL-ID
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Function: remove-consumer CHANNEL CONSUMER-TAG
Package

cl-bunny

Source

consumer.lisp (file)

Function: render-connection-parameters SPEC STREAM
Package

cl-bunny

Source

spec.lisp (file)

Function: render-host SPEC STREAM
Package

cl-bunny

Source

spec.lisp (file)

Function: render-port SPEC STREAM
Package

cl-bunny

Source

spec.lisp (file)

Function: render-scheme SPEC STREAM
Package

cl-bunny

Source

spec.lisp (file)

Function: render-userinfo SPEC STREAM
Package

cl-bunny

Source

spec.lisp (file)

Function: render-vhost SPEC STREAM
Package

cl-bunny

Source

spec.lisp (file)

Function: send-queued-frames CONNECTION OF-QUEUE
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Function: setup-execute-in-connection-lambda CONNECTION
Package

cl-bunny

Source

threaded-connection.lisp (file)

Function: shutdown-connection CONNECTION
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: socket-readable SOCKET
Package

cl-bunny

Source

iolib-transport.lisp (file)

Function: socket-writeable SOCKET
Package

cl-bunny

Source

iolib-transport.lisp (file)

Function: socket.check SOCKET
Package

cl-bunny

Source

iolib-transport.lisp (file)

Function: sync-promise-rejected-p PROMISE
Package

cl-bunny

Source

sync-promise.lisp (file)

Function: sync-promise-resolved-or-rejected-p PROMISE
Package

cl-bunny

Source

sync-promise.lisp (file)

Function: sync-promise-resolved-p PROMISE
Package

cl-bunny

Source

sync-promise.lisp (file)

Function: validate-host HOST
Package

cl-bunny

Source

spec.lisp (file)

Function: validate-server-auth-mechanisms CONNECTION-START
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: validate-server-protocol-version CONNECTION-START
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Function: wrap-async-on-cancel-with-channel ON-CANCEL CHANNEL
Package

cl-bunny

Source

consumer.lisp (file)

Function: wrap-async-subscribe-with-channel FN CHANNEL
Package

cl-bunny

Source

consumer.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.5 Generic functions

Generic Function: async-promise-notify-lambda OBJECT
Package

cl-bunny

Methods
Method: async-promise-notify-lambda (ASYNC-PROMISE async-promise)

automatically generated reader method

Source

async-promise.lisp (file)

Generic Function: channel-consumers OBJECT
Package

cl-bunny

Methods
Method: channel-consumers (CHANNEL channel)

automatically generated reader method

Source

channel.lisp (file)

Generic Function: channel-exchanges OBJECT
Package

cl-bunny

Methods
Method: channel-exchanges (CHANNEL channel)

automatically generated reader method

Source

channel.lisp (file)

Generic Function: channel-expected-reply OBJECT
Generic Function: (setf channel-expected-reply) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: channel-expected-reply (CHANNEL-BASE channel-base)

automatically generated reader method

Source

channel-base.lisp (file)

Method: (setf channel-expected-reply) NEW-VALUE (CHANNEL-BASE channel-base)

automatically generated writer method

Source

channel-base.lisp (file)

Generic Function: channel-mailbox OBJECT
Package

cl-bunny

Methods
Method: channel-mailbox (CHANNEL channel)

automatically generated reader method

Source

channel.lisp (file)

Generic Function: channel-method-assembler OBJECT
Package

cl-bunny

Methods
Method: channel-method-assembler (CHANNEL-BASE channel-base)

automatically generated reader method

Source

channel-base.lisp (file)

Generic Function: channel-mode OBJECT
Package

cl-bunny

Methods
Method: channel-mode (CHANNEL channel)

automatically generated reader method

Source

channel.lisp (file)

Generic Function: channel-on-error% OBJECT
Generic Function: (setf channel-on-error%) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: channel-on-error% (CHANNEL channel)

automatically generated reader method

Source

channel.lisp (file)

Method: (setf channel-on-error%) NEW-VALUE (CHANNEL channel)

automatically generated writer method

Source

channel.lisp (file)

Generic Function: channel-on-return% OBJECT
Generic Function: (setf channel-on-return%) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: channel-on-return% (CHANNEL channel)

automatically generated reader method

Source

channel.lisp (file)

Method: (setf channel-on-return%) NEW-VALUE (CHANNEL channel)

automatically generated writer method

Source

channel.lisp (file)

Generic Function: channel-open-p% CHANNEL
Package

cl-bunny

Source

channel-base.lisp (file)

Writer

(setf channel-open-p%) (generic function)

Methods
Method: channel-open-p% (CONNECTION connection)
Source

channel.lisp (file)

Method: channel-open-p% (CHANNEL channel-base)
Generic Function: (setf channel-open-p%) VALUE CHANNEL
Package

cl-bunny

Reader

channel-open-p% (generic function)

Methods
Method: (setf channel-open-p%) VALUE CHANNEL
Source

channel-base.lisp (file)

Generic Function: channel-state OBJECT
Generic Function: (setf channel-state) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: channel-state (CHANNEL-BASE channel-base)

automatically generated reader method

Source

channel-base.lisp (file)

Method: (setf channel-state) NEW-VALUE (CHANNEL-BASE channel-base)

automatically generated writer method

Source

channel-base.lisp (file)

Generic Function: channel-unconfirmed-set OBJECT
Generic Function: (setf channel-unconfirmed-set) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: channel-unconfirmed-set (CONFIRM-CHANNEL confirm-channel)

automatically generated reader method

Source

confirm.lisp (file)

Method: (setf channel-unconfirmed-set) NEW-VALUE (CONFIRM-CHANNEL confirm-channel)

automatically generated writer method

Source

confirm.lisp (file)

Generic Function: channel.publish CHANNEL CONTENT EXCHANGE &key NOWAIT ROUTING-KEY MANDATORY IMMEDIATE PROPERTIES &allow-other-keys
Package

cl-bunny

Methods
Method: channel.publish (CHANNEL confirm-channel) CONTENT EXCHANGE &key NOWAIT ROUTING-KEY MANDATORY IMMEDIATE PROPERTIES &allow-other-keys
Source

confirm.lisp (file)

Method: channel.publish CHANNEL CONTENT EXCHANGE &key ROUTING-KEY MANDATORY IMMEDIATE PROPERTIES &allow-other-keys
Source

channel.lisp (file)

Generic Function: channel.receive CHANNEL METHOD
Package

cl-bunny

Source

channel-base.lisp (file)

Methods
Method: channel.receive (CHANNEL confirm-channel) (METHOD amqp-method-basic-ack)
Source

confirm.lisp (file)

Method: channel.receive CHANNEL (METHOD amqp-method-basic-cancel)
Source

consumer.lisp (file)

Method: channel.receive CHANNEL (METHOD amqp-method-basic-deliver)
Source

consumer.lisp (file)

Method: channel.receive CHANNEL (METHOD amqp-method-basic-return)
Source

exchange.lisp (file)

Method: channel.receive CHANNEL (METHOD amqp-method-channel-close)
Source

channel.lisp (file)

Method: channel.receive CHANNEL METHOD
Source

channel.lisp (file)

Method: channel.receive (CONNECTION threaded-iolib-connection) (METHOD amqp-method-connection-close)
Source

iolib-threaded.lisp (file)

Method: channel.receive (CONNECTION threaded-iolib-connection) (METHOD amqp-method-connection-close-ok)
Source

iolib-threaded.lisp (file)

Method: channel.receive (CONNECTION threaded-iolib-connection) (METHOD amqp-method-connection-unblocked)
Source

iolib-threaded.lisp (file)

Method: channel.receive (CONNECTION threaded-iolib-connection) (METHOD amqp-method-connection-blocked)
Source

iolib-threaded.lisp (file)

Generic Function: channel.wait-confirms% CHANNEL TIMEOUT
Package

cl-bunny

Methods
Method: channel.wait-confirms% (CHANNEL confirm-channel) TIMEOUT
Source

confirm.lisp (file)

Generic Function: check-connection-parameters PARAMS
Package

cl-bunny

Methods
Method: check-connection-parameters (PARAMS string)
Source

spec.lisp (file)

Method: check-connection-parameters (PARAMS (eql nil))
Source

spec.lisp (file)

Generic Function: close-connection-with-error CONNECTION ERROR
Package

cl-bunny

Methods
Method: close-connection-with-error (CONNECTION threaded-iolib-connection) ERROR
Source

iolib-threaded.lisp (file)

Generic Function: confirm-channel-condition-var OBJECT
Package

cl-bunny

Methods
Method: confirm-channel-condition-var (CONFIRM-CHANNEL confirm-channel)

automatically generated reader method

Source

confirm.lisp (file)

Generic Function: confirm-channel-counter OBJECT
Generic Function: (setf confirm-channel-counter) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: confirm-channel-counter (CONFIRM-CHANNEL confirm-channel)

automatically generated reader method

Source

confirm.lisp (file)

Method: (setf confirm-channel-counter) NEW-VALUE (CONFIRM-CHANNEL confirm-channel)

automatically generated writer method

Source

confirm.lisp (file)

Generic Function: confirm-channel-lock OBJECT
Package

cl-bunny

Methods
Method: confirm-channel-lock (CONFIRM-CHANNEL confirm-channel)

automatically generated reader method

Source

confirm.lisp (file)

Generic Function: confirm-message-nowait OBJECT
Package

cl-bunny

Methods
Method: confirm-message-nowait (CONFIRM-MESSAGE confirm-message)

automatically generated reader method

Source

confirm.lisp (file)

Generic Function: confirm-message-promise OBJECT
Package

cl-bunny

Methods
Method: confirm-message-promise (CONFIRM-MESSAGE confirm-message)

automatically generated reader method

Source

confirm.lisp (file)

Generic Function: connection-channel-id-allocator OBJECT
Package

cl-bunny

Methods
Method: connection-channel-id-allocator (CONNECTION connection)

automatically generated reader method

Source

connection-base.lisp (file)

Generic Function: connection-channel-max% CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Writer

(setf connection-channel-max%) (generic function)

Methods
Method: connection-channel-max% (CONNECTION connection)

automatically generated reader method

Generic Function: (setf connection-channel-max%) NEW-VALUE OBJECT
Package

cl-bunny

Reader

connection-channel-max% (generic function)

Methods
Method: (setf connection-channel-max%) NEW-VALUE (CONNECTION connection)

automatically generated writer method

Source

connection-base.lisp (file)

Generic Function: connection-channels OBJECT
Package

cl-bunny

Methods
Method: connection-channels (CONNECTION connection)

automatically generated reader method

Source

connection-base.lisp (file)

Generic Function: connection-control-mailbox OBJECT
Package

cl-bunny

Methods
Method: connection-control-mailbox (THREADED-CONNECTION threaded-connection)

automatically generated reader method

Source

threaded-connection.lisp (file)

Generic Function: connection-event-base OBJECT
Package

cl-bunny

Methods
Method: connection-event-base (CONNECTION connection)

automatically generated reader method

Source

connection-base.lisp (file)

Generic Function: connection-frame-max% CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Writer

(setf connection-frame-max%) (generic function)

Methods
Method: connection-frame-max% (CONNECTION connection)

automatically generated reader method

Generic Function: (setf connection-frame-max%) NEW-VALUE OBJECT
Package

cl-bunny

Reader

connection-frame-max% (generic function)

Methods
Method: (setf connection-frame-max%) NEW-VALUE (CONNECTION connection)

automatically generated writer method

Source

connection-base.lisp (file)

Generic Function: connection-heartbeat% CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Writer

(setf connection-heartbeat%) (generic function)

Methods
Method: connection-heartbeat% (CONNECTION connection)

automatically generated reader method

Generic Function: (setf connection-heartbeat%) NEW-VALUE OBJECT
Package

cl-bunny

Reader

connection-heartbeat% (generic function)

Methods
Method: (setf connection-heartbeat%) NEW-VALUE (CONNECTION connection)

automatically generated writer method

Source

connection-base.lisp (file)

Generic Function: connection-init CONNECTION
Package

cl-bunny

Source

threaded-connection.lisp (file)

Generic Function: connection-lambda OBJECT
Package

cl-bunny

Methods
Method: connection-lambda (THREADED-CONNECTION threaded-connection)

automatically generated reader method

Source

threaded-connection.lisp (file)

Generic Function: connection-last-client-activity OBJECT
Generic Function: (setf connection-last-client-activity) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-last-client-activity (IOLIB-CONNECTION iolib-connection)

automatically generated reader method

Source

iolib-connection.lisp (file)

Method: (setf connection-last-client-activity) NEW-VALUE (IOLIB-CONNECTION iolib-connection)

automatically generated writer method

Source

iolib-connection.lisp (file)

Generic Function: connection-last-server-activity OBJECT
Generic Function: (setf connection-last-server-activity) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-last-server-activity (IOLIB-CONNECTION iolib-connection)

automatically generated reader method

Source

iolib-connection.lisp (file)

Method: (setf connection-last-server-activity) NEW-VALUE (IOLIB-CONNECTION iolib-connection)

automatically generated writer method

Source

iolib-connection.lisp (file)

Generic Function: connection-loop CONNECTION
Package

cl-bunny

Source

threaded-connection.lisp (file)

Methods
Method: connection-loop (CONNECTION threaded-iolib-connection)
Source

iolib-threaded.lisp (file)

Generic Function: connection-on-blocked% OBJECT
Generic Function: (setf connection-on-blocked%) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-on-blocked% (IOLIB-CONNECTION iolib-connection)

automatically generated reader method

Source

iolib-connection.lisp (file)

Method: (setf connection-on-blocked%) NEW-VALUE (IOLIB-CONNECTION iolib-connection)

automatically generated writer method

Source

iolib-connection.lisp (file)

Generic Function: connection-on-close% OBJECT
Generic Function: (setf connection-on-close%) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-on-close% (CONNECTION connection)

automatically generated reader method

Source

connection-base.lisp (file)

Method: (setf connection-on-close%) NEW-VALUE (CONNECTION connection)

automatically generated writer method

Source

connection-base.lisp (file)

Generic Function: connection-on-error% OBJECT
Generic Function: (setf connection-on-error%) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-on-error% (CONNECTION connection)

automatically generated reader method

Source

connection-base.lisp (file)

Method: (setf connection-on-error%) NEW-VALUE (CONNECTION connection)

automatically generated writer method

Source

connection-base.lisp (file)

Generic Function: connection-on-unblocked% OBJECT
Generic Function: (setf connection-on-unblocked%) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-on-unblocked% (IOLIB-CONNECTION iolib-connection)

automatically generated reader method

Source

iolib-connection.lisp (file)

Method: (setf connection-on-unblocked%) NEW-VALUE (IOLIB-CONNECTION iolib-connection)

automatically generated writer method

Source

iolib-connection.lisp (file)

Generic Function: connection-open-p% CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: connection-open-p% (CONNECTION threaded-iolib-connection)
Source

iolib-threaded.lisp (file)

Method: connection-open-p% (CONNECTION threaded-connection)
Source

threaded-connection.lisp (file)

Method: connection-open-p% (CONNECTION connection)
Generic Function: connection-open-promise OBJECT
Package

cl-bunny

Methods
Method: connection-open-promise (THREADED-IOLIB-CONNECTION threaded-iolib-connection)

automatically generated reader method

Source

iolib-threaded.lisp (file)

Generic Function: connection-pool OBJECT
Generic Function: (setf connection-pool) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-pool (CONNECTION-IN-POOL connection-in-pool)

automatically generated reader method

Source

pool.lisp (file)

Method: (setf connection-pool) NEW-VALUE (CONNECTION-IN-POOL connection-in-pool)

automatically generated writer method

Source

pool.lisp (file)

Generic Function: connection-pool-tag OBJECT
Generic Function: (setf connection-pool-tag) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-pool-tag (CONNECTION-IN-POOL connection-in-pool)

automatically generated reader method

Source

pool.lisp (file)

Method: (setf connection-pool-tag) NEW-VALUE (CONNECTION-IN-POOL connection-in-pool)

automatically generated writer method

Source

pool.lisp (file)

Generic Function: connection-server-properties% CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Generic Function: connection-socket OBJECT
Generic Function: (setf connection-socket) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: connection-socket (IOLIB-TRANSPORT iolib-transport)

automatically generated reader method

Source

iolib-transport.lisp (file)

Method: (setf connection-socket) NEW-VALUE (IOLIB-TRANSPORT iolib-transport)

automatically generated writer method

Source

iolib-transport.lisp (file)

Generic Function: connection-state-lock OBJECT
Package

cl-bunny

Methods
Method: connection-state-lock (THREADED-CONNECTION threaded-connection)

automatically generated reader method

Source

threaded-connection.lisp (file)

Generic Function: connection-thread OBJECT
Package

cl-bunny

Methods
Method: connection-thread (THREADED-CONNECTION threaded-connection)

automatically generated reader method

Source

threaded-connection.lisp (file)

Generic Function: connection.close% CONNECTION TIMEOUT
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: connection.close% (CONNECTION threaded-iolib-connection) TIMEOUT
Source

iolib-threaded.lisp (file)

Generic Function: connection.consume% CONNECTION TIMEOUT ONE-SHOT
Package

cl-bunny

Source

connection-base.lisp (file)

Generic Function: connection.init CONNECTION
Package

cl-bunny

Methods
Method: connection.init (CONNECTION threaded-iolib-connection)
Source

iolib-threaded.lisp (file)

Generic Function: connection.new% CONNECTION-TYPE SPEC POOL-TAG
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: connection.new% (TYPE (eql threaded-iolib-connection)) SPEC POOL-TAG
Source

iolib-threaded.lisp (file)

Method: connection.new% (TYPE (eql iolib-connection)) SPEC POOL-TAG
Source

iolib-threaded.lisp (file)

Generic Function: connection.open% CONNECTION
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: connection.open% (CONNECTION threaded-connection)
Source

threaded-connection.lisp (file)

Method: connection.open% (CONNECTION connection)
Generic Function: connection.receive CONNECTION METHOD
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: connection.receive (CONNECTION connection) (METHOD amqp-method-connection-unblocked)
Method: connection.receive (CONNECTION connection) (METHOD amqp-method-connection-blocked)
Method: connection.receive (CONNECTION connection) (METHOD amqp-method-connection-close)
Generic Function: connection.send CONNECTION CHANNEL METHOD
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: connection.send (CONNECTION iolib-connection) CHANNEL METHOD
Source

iolib-threaded.lisp (file)

Generic Function: connections-pool-lock OBJECT
Package

cl-bunny

Methods
Method: connections-pool-lock (EQ-CONNECTIONS-POOL eq-connections-pool)

automatically generated reader method

Source

pool.lisp (file)

Generic Function: connections-pool-storage OBJECT
Package

cl-bunny

Methods
Method: connections-pool-storage (EQ-CONNECTIONS-POOL eq-connections-pool)

automatically generated reader method

Source

pool.lisp (file)

Generic Function: connections-pool.add% POOL CONNECTION
Package

cl-bunny

Source

pool.lisp (file)

Methods
Method: connections-pool.add% (POOL eq-connections-pool) CONNECTION
Generic Function: connections-pool.find-or-run% POOL TAG SPEC
Package

cl-bunny

Source

pool.lisp (file)

Methods
Method: connections-pool.find-or-run% (POOL eq-connections-pool) TAG SPEC
Generic Function: connections-pool.get% POOL SPEC
Package

cl-bunny

Source

pool.lisp (file)

Methods
Method: connections-pool.get% (POOL eq-connections-pool) SPEC
Generic Function: connections-pool.remove% POOL CONNECTION
Package

cl-bunny

Source

pool.lisp (file)

Methods
Method: connections-pool.remove% (POOL eq-connections-pool) TAG
Method: connections-pool.remove% (POOL eq-connections-pool) (CONNECTION connection-in-pool)
Generic Function: consumer-channel OBJECT
Package

cl-bunny

Methods
Method: consumer-channel (CONSUMER consumer)

automatically generated reader method

Source

consumer.lisp (file)

Generic Function: consumer-on-cancel OBJECT
Package

cl-bunny

Methods
Method: consumer-on-cancel (CONSUMER consumer)

automatically generated reader method

Source

consumer.lisp (file)

Generic Function: consumer-on-message OBJECT
Package

cl-bunny

Methods
Method: consumer-on-message (CONSUMER consumer)

automatically generated reader method

Source

consumer.lisp (file)

Generic Function: consumer-queue OBJECT
Package

cl-bunny

Methods
Method: consumer-queue (CONSUMER consumer)

automatically generated reader method

Source

consumer.lisp (file)

Generic Function: consumer-tag OBJECT
Package

cl-bunny

Methods
Method: consumer-tag (CONSUMER consumer)

automatically generated reader method

Source

consumer.lisp (file)

Generic Function: consumer-type OBJECT
Package

cl-bunny

Methods
Method: consumer-type (CONSUMER consumer)

automatically generated reader method

Source

consumer.lisp (file)

Generic Function: deregister-channel CONNECTION CHANNEL
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: deregister-channel (CONNECTION connection) CHANNEL
Generic Function: error-channel CONDITION
Package

cl-bunny

Methods
Method: error-channel (CONDITION channel-closed-error)
Source

conditions.lisp (file)

Method: error-channel (CONDITION channel-consumer-already-added)
Source

conditions.lisp (file)

Method: error-channel (CONDITION channel-already-open)
Source

conditions.lisp (file)

Generic Function: error-consumer-tag CONDITION
Package

cl-bunny

Methods
Method: error-consumer-tag (CONDITION channel-consumer-already-added)
Source

conditions.lisp (file)

Generic Function: error-message CONDITION
Package

cl-bunny

Methods
Method: error-message (CONDITION unknown-consumer-error)
Source

conditions.lisp (file)

Generic Function: exchange-arguments OBJECT
Package

cl-bunny

Methods
Method: exchange-arguments (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Generic Function: exchange-auto-delete-p OBJECT
Package

cl-bunny

Methods
Method: exchange-auto-delete-p (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Generic Function: exchange-channel OBJECT
Package

cl-bunny

Methods
Method: exchange-channel (EXCHANGE string)
Source

exchange.lisp (file)

Method: exchange-channel (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Generic Function: exchange-durable-p OBJECT
Package

cl-bunny

Methods
Method: exchange-durable-p (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Generic Function: exchange-internal-p OBJECT
Package

cl-bunny

Methods
Method: exchange-internal-p (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Generic Function: exchange-name OBJECT
Package

cl-bunny

Methods
Method: exchange-name (EXCHANGE string)
Source

exchange.lisp (file)

Method: exchange-name (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Generic Function: exchange-type OBJECT
Package

cl-bunny

Methods
Method: exchange-type (EXCHANGE string)
Source

exchange.lisp (file)

Method: exchange-type (EXCHANGE exchange)

automatically generated reader method

Source

exchange.lisp (file)

Generic Function: execute-on-connection-thread CONNECTION CHANNEL LAMBDA
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: execute-on-connection-thread (CONNECTION connection) CHANNEL LAMBDA

Single-thread sync connection

Generic Function: get-channel CONNECTION CHANNEL-ID
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: get-channel (CONNECTION connection) CHANNEL-ID
Generic Function: make-connection-spec RAW
Package

cl-bunny

Methods
Method: make-connection-spec (SPEC connection-spec)
Source

spec.lisp (file)

Method: make-connection-spec (RAW list)
Source

spec.lisp (file)

Method: make-connection-spec (RAW string)
Source

spec.lisp (file)

Generic Function: normalize-properties PROPERTIES
Package

cl-bunny

Methods
Method: normalize-properties (PROPERTIES amqp-basic-class-properties)
Source

channel.lisp (file)

Method: normalize-properties (PROPERTIES list)
Source

channel.lisp (file)

Generic Function: print-amqp-object OBJECT STREAM
Package

cl-bunny

Source

printer.lisp (file)

Methods
Method: print-amqp-object (MESSAGE message) STREAM
Method: print-amqp-object (POOL eq-connections-pool) STREAM
Source

pool.lisp (file)

Method: print-amqp-object (SPEC connection-spec) STREAM
Source

spec.lisp (file)

Generic Function: promise-finished-p PROMISE
Package

cl-bunny

Source

promise.lisp (file)

Methods
Method: promise-finished-p (PROMISE async-promise)
Source

async-promise.lisp (file)

Method: promise-finished-p (PROMISE sync-promise)
Source

sync-promise.lisp (file)

Method: promise-finished-p PROMISE
Generic Function: promise.reject PROMISE ERROR
Package

cl-bunny

Source

promise.lisp (file)

Methods
Method: promise.reject (PROMISE async-promise) ERROR
Source

async-promise.lisp (file)

Method: promise.reject (PROMISE sync-promise) ERROR
Source

sync-promise.lisp (file)

Method: promise.reject (PROMISE promise) ERROR
Generic Function: promise.resolve% PROMISE VALUES
Package

cl-bunny

Source

promise.lisp (file)

Methods
Method: promise.resolve% (PROMISE async-promise) VALUES
Source

async-promise.lisp (file)

Method: promise.resolve% (PROMISE sync-promise) VALUES
Source

sync-promise.lisp (file)

Method: promise.resolve% (PROMISE promise) VALUES
Generic Function: receive-from CONNECTION &key BUFFER START
Package

cl-bunny

Source

iolib-transport.lisp (file)

Methods
Method: receive-from (CONNECTION iolib-connection) &key BUFFER START around
Source

iolib-threaded.lisp (file)

Method: receive-from (CONNECTION iolib-transport) &key BUFFER START
Generic Function: register-channel CONNECTION CHANNEL
Package

cl-bunny

Source

connection-base.lisp (file)

Methods
Method: register-channel (CONNECTION connection) CHANNEL
Generic Function: reply-to QUEUE
Package

cl-bunny

Methods
Method: reply-to (QUEUE queue)
Source

queue.lisp (file)

Method: reply-to (QUEUE string)
Source

queue.lisp (file)

Generic Function: returned-message-reply-code OBJECT
Package

cl-bunny

Methods
Method: returned-message-reply-code (RETURNED-MESSAGE returned-message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: returned-message-reply-text OBJECT
Package

cl-bunny

Methods
Method: returned-message-reply-text (RETURNED-MESSAGE returned-message)

automatically generated reader method

Source

message.lisp (file)

Generic Function: routing-key ROUTING-KEY
Package

cl-bunny

Methods
Method: routing-key (ROUTING-KEY queue)
Source

basic.lisp (file)

Method: routing-key (ROUTING-KEY string)
Source

basic.lisp (file)

Generic Function: send-to CONNECTION BUFFER &key START END
Package

cl-bunny

Source

iolib-transport.lisp (file)

Methods
Method: send-to (CONNECTION iolib-connection) BUFFER &key START END after
Source

iolib-threaded.lisp (file)

Method: send-to (CONNECTION iolib-transport) BUFFER &key START END
Generic Function: snyc-promise-mutex OBJECT
Package

cl-bunny

Methods
Method: snyc-promise-mutex (SYNC-PROMISE sync-promise)

automatically generated reader method

Source

sync-promise.lisp (file)

Generic Function: sync-promise-condition-var OBJECT
Package

cl-bunny

Methods
Method: sync-promise-condition-var (SYNC-PROMISE sync-promise)

automatically generated reader method

Source

sync-promise.lisp (file)

Generic Function: sync-promise-error OBJECT
Generic Function: (setf sync-promise-error) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: sync-promise-error (SYNC-PROMISE sync-promise)

automatically generated reader method

Source

sync-promise.lisp (file)

Method: (setf sync-promise-error) NEW-VALUE (SYNC-PROMISE sync-promise)

automatically generated writer method

Source

sync-promise.lisp (file)

Generic Function: sync-promise-forced-p OBJECT
Generic Function: (setf sync-promise-forced-p) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: sync-promise-forced-p (SYNC-PROMISE sync-promise)

automatically generated reader method

Source

sync-promise.lisp (file)

Method: (setf sync-promise-forced-p) NEW-VALUE (SYNC-PROMISE sync-promise)

automatically generated writer method

Source

sync-promise.lisp (file)

Generic Function: sync-promise-values OBJECT
Generic Function: (setf sync-promise-values) NEW-VALUE OBJECT
Package

cl-bunny

Methods
Method: sync-promise-values (SYNC-PROMISE sync-promise)

automatically generated reader method

Source

sync-promise.lisp (file)

Method: (setf sync-promise-values) NEW-VALUE (SYNC-PROMISE sync-promise)

automatically generated writer method

Source

sync-promise.lisp (file)

Generic Function: transport-error-description CONDITION
Package

cl-bunny

Methods
Method: transport-error-description (CONDITION transport-error)
Source

conditions.lisp (file)

Generic Function: transport.open CONNECTION ADDRESS PORT
Package

cl-bunny

Methods
Method: transport.open (CONNECTION iolib-transport) ADDRESS PORT
Source

iolib-transport.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.6 Conditions

Condition: channel-already-open ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error-base (condition)

Direct methods

error-channel (method)

Direct slots
Slot: channel
Initargs

:channel

Readers

error-channel (generic function)

Condition: channel-consumer-already-added ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error-base (condition)

Direct methods
Direct slots
Slot: channel
Initargs

:channel

Readers

error-channel (generic function)

Slot: consumer-tag
Initargs

:consumer-tag

Readers

error-consumer-tag (generic function)

Condition: error-base ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error (condition)

Direct subclasses
Condition: server-error ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error-base (condition)

Direct subclasses

authentication-error (condition)

Direct methods

error-connection (method)

Direct slots
Slot: connection
Initargs

:connection

Readers

error-connection (generic function)

Condition: stop-connection ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error (condition)

Condition: sync-promise-timeout-not-supported ()
Package

cl-bunny

Source

sync-promise.lisp (file)

Direct superclasses

error (condition)

Condition: unknown-consumer-error ()
Package

cl-bunny

Source

conditions.lisp (file)

Direct superclasses

error-base (condition)

Direct methods

error-message (method)

Direct slots
Slot: message
Initargs

:message

Readers

error-message (generic function)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.7 Structures

Structure: channel-id-allocator ()
Package

cl-bunny

Source

channel-id-allocator.lisp (file)

Direct superclasses

structure-object (structure)

Direct slots
Slot: int-allocator
Readers

channel-id-allocator-int-allocator (function)

Writers

(setf channel-id-allocator-int-allocator) (function)

Slot: mutex
Readers

channel-id-allocator-mutex (function)

Writers

(setf channel-id-allocator-mutex) (function)

Structure: fap-parser ()
Package

cl-bunny

Source

frame-and-payload-parser.lisp (file)

Direct superclasses

structure-object (structure)

Direct slots
Slot: buffer
Readers

fap-parser-buffer (function)

Writers

(setf fap-parser-buffer) (function)

Slot: buffer-index
Readers

fap-parser-buffer-index (function)

Writers

(setf fap-parser-buffer-index) (function)

Slot: end-index
Readers

fap-parser-end-index (function)

Writers

(setf fap-parser-end-index) (function)

Slot: frame
Readers

fap-parser-frame (function)

Writers

(setf fap-parser-frame) (function)

Slot: parser
Readers

fap-parser-parser (function)

Writers

(setf fap-parser-parser) (function)

Slot: payload-parser
Readers

fap-parser-payload-parser (function)

Writers

(setf fap-parser-payload-parser) (function)

Structure: int-allocator ()
Package

cl-bunny

Source

int-allocator.lisp (file)

Direct superclasses

structure-object (structure)

Direct slots
Slot: bits
Readers

int-allocator-bits (function)

Writers

(setf int-allocator-bits) (function)

Slot: min
Readers

int-allocator-min (function)

Writers

(setf int-allocator-min) (function)

Slot: max
Readers

int-allocator-max (function)

Writers

(setf int-allocator-max) (function)

Structure: output-frame-queue ()
Package

cl-bunny

Source

output-frame-queue.lisp (file)

Direct superclasses

structure-object (structure)

Direct slots
Slot: queue
Type

lparallel.raw-queue:raw-queue

Initform

(lparallel.raw-queue:make-raw-queue 10)

Readers

output-frame-queue-queue (function)

Writers

(setf output-frame-queue-queue) (function)

Slot: current-frame-bytes
Readers

output-frame-queue-current-frame-bytes (function)

Writers

(setf output-frame-queue-current-frame-bytes) (function)

Slot: current-frame-position
Initform

0

Readers

output-frame-queue-current-frame-position (function)

Writers

(setf output-frame-queue-current-frame-position) (function)

Slot: state
Initform

:idle

Readers

output-frame-queue-state (function)

Writers

(setf output-frame-queue-state) (function)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.8 Classes

Class: async-consumer-event ()
Package

cl-bunny

Source

consumer.lisp (file)

Direct superclasses
  • pooled-executor (class)
  • single-thread-sink (class)
Class: async-promise ()
Package

cl-bunny

Source

async-promise.lisp (file)

Direct superclasses

promise (class)

Direct methods
Direct slots
Slot: notify-lambda
Initargs

:notify-lambda

Readers

async-promise-notify-lambda (generic function)

Slot: private-resolved
Class: bunny-event ()
Package

cl-bunny

Source

bunny-event.lisp (file)

Direct superclasses
  • pooled-executor (class)
  • multi-thread-sink (class)
Direct methods

invoke-event-handlers (method)

Class: channel ()
Package

cl-bunny

Source

channel.lisp (file)

Direct superclasses

channel-base (class)

Direct subclasses
Direct methods
Direct slots
Slot: mailbox
Type

safe-queue:mailbox

Initargs

:mailbox

Initform

(safe-queue:make-mailbox :name "amqp channel mailbox")

Readers

channel-mailbox (generic function)

Slot: exchanges
Type

hash-table

Initform

(make-hash-table :test (function equal))

Readers

channel-exchanges (generic function)

Slot: consumers
Type

hash-table

Initform

(make-hash-table :test (function equal))

Readers

channel-consumers (generic function)

Slot: mode
Type

cl-bunny::channel-mode

Initargs

:mode

Initform

:default

Readers

channel-mode (generic function)

Slot: on-error
Type

function

Initargs

:on-error

Initform

(make-instance (quote cl-bunny::bunny-event))

Readers

channel-on-error% (generic function)

Writers

(setf channel-on-error%) (generic function)

Slot: on-return
Type

function

Initform

(make-instance (quote cl-bunny::bunny-event))

Readers

channel-on-return% (generic function)

Writers

(setf channel-on-return%) (generic function)

Class: channel-base ()
Package

cl-bunny

Source

channel-base.lisp (file)

Direct superclasses

standard-object (class)

Direct subclasses
Direct methods
Direct slots
Slot: connection
Type

cl-bunny::connection

Initargs

:connection

Readers

channel-connection (generic function)

Slot: channel-id
Type

fixnum

Initargs

:id

Readers

channel-id (generic function)

Slot: state
Initform

:closed

Readers

channel-state (generic function)

Writers

(setf channel-state) (generic function)

Slot: expected-reply
Readers

channel-expected-reply (generic function)

Writers

(setf channel-expected-reply) (generic function)

Slot: method-assembler
Initargs

:method-assembler

Readers

channel-method-assembler (generic function)

Class: confirm-channel ()
Package

cl-bunny

Source

confirm.lisp (file)

Direct superclasses

channel (class)

Direct methods
Direct slots
Slot: counter
Type

fixnum

Initform

1

Readers

confirm-channel-counter (generic function)

Writers

(setf confirm-channel-counter) (generic function)

Slot: unconfirmed-set
Initform

(make-hash-table :test (quote eql))

Readers

channel-unconfirmed-set (generic function)

Writers

(setf channel-unconfirmed-set) (generic function)

Slot: lock
Initform

(bordeaux-threads:make-lock)

Readers

confirm-channel-lock (generic function)

Slot: condition-var
Initform

(bordeaux-threads:make-condition-variable)

Readers

confirm-channel-condition-var (generic function)

Class: confirm-message ()
Package

cl-bunny

Source

confirm.lisp (file)

Direct superclasses

message (class)

Direct methods
Direct slots
Slot: nowait
Initargs

:nowait

Readers

confirm-message-nowait (generic function)

Slot: promise
Initargs

:promise

Readers

confirm-message-promise (generic function)

Class: connection ()
Package

cl-bunny

Source

connection-base.lisp (file)

Direct superclasses
Direct subclasses
Direct methods
Direct slots
Slot: spec
Initargs

:spec

Readers

connection-spec (generic function)

Slot: channel-id-allocator
Type

cl-bunny::channel-id-allocator

Readers

connection-channel-id-allocator (generic function)

Slot: channels
Type

hash-table

Initform

(make-hash-table :synchronized t)

Readers

connection-channels (generic function)

Slot: event-base
Initargs

:event-base

Readers

connection-event-base (generic function)

Slot: channel-max
Initform

cl-bunny::+channel-max+

Readers

connection-channel-max% (generic function)

Writers

(setf connection-channel-max%) (generic function)

Slot: frame-max
Initform

cl-bunny::+frame-max+

Readers

connection-frame-max% (generic function)

Writers

(setf connection-frame-max%) (generic function)

Slot: heartbeat
Initform

cl-bunny::+heartbeat-interval+

Readers

connection-heartbeat% (generic function)

Writers

(setf connection-heartbeat%) (generic function)

Slot: on-close
Initargs

:on-close

Initform

(make-instance (quote cl-bunny::bunny-event))

Readers

connection-on-close% (generic function)

Writers

(setf connection-on-close%) (generic function)

Slot: on-error
Initargs

:on-error

Initform

(make-instance (quote cl-bunny::bunny-event))

Readers

connection-on-error% (generic function)

Writers

(setf connection-on-error%) (generic function)

Class: connection-in-pool ()
Package

cl-bunny

Source

pool.lisp (file)

Direct superclasses

standard-object (class)

Direct subclasses

connection (class)

Direct methods
Direct slots
Slot: pool-tag
Initargs

:pool-tag

Readers

connection-pool-tag (generic function)

Writers

(setf connection-pool-tag) (generic function)

Slot: pool
Readers

connection-pool (generic function)

Writers

(setf connection-pool) (generic function)

Class: consumer ()
Package

cl-bunny

Source

consumer.lisp (file)

Direct superclasses

standard-object (class)

Direct methods
Direct slots
Slot: channel
Type

cl-bunny::channel

Initargs

:channel

Readers

consumer-channel (generic function)

Slot: queue
Type

cl-bunny::queue

Initargs

:queue

Readers

consumer-queue (generic function)

Slot: type
Type

(or :sync :async)

Initargs

:type

Initform

:sync

Readers

consumer-type (generic function)

Slot: tag
Type

string

Initargs

:tag

Readers

consumer-tag (generic function)

Slot: on-message
Type

function

Initargs

:on-message

Readers

consumer-on-message (generic function)

Slot: on-cancel
Type

function

Initargs

:on-cancel

Readers

consumer-on-cancel (generic function)

Class: exchange ()
Package

cl-bunny

Source

exchange.lisp (file)

Direct superclasses

standard-object (class)

Direct methods
Direct slots
Slot: channel
Type

cl-bunny::channel

Initargs

:channel

Readers

exchange-channel (generic function)

Slot: name
Type

string

Initargs

:name

Readers

exchange-name (generic function)

Slot: type
Type

string

Initargs

:type

Initform

"direct"

Readers

exchange-type (generic function)

Slot: durable
Initargs

:durable

Readers

exchange-durable-p (generic function)

Slot: auto-delete
Initargs

:auto-delete

Readers

exchange-auto-delete-p (generic function)

Slot: internal
Initargs

:internal

Readers

exchange-internal-p (generic function)

Slot: arguments
Initargs

:arguments

Readers

exchange-arguments (generic function)

Slot: on-return
Type

function

Initform

(make-instance (quote cl-bunny::bunny-event))

Readers

exchange-on-return (generic function)

Writers

(setf exchange-on-return) (generic function)

Class: iolib-connection ()
Package

cl-bunny

Source

iolib-connection.lisp (file)

Direct superclasses
Direct subclasses

threaded-iolib-connection (class)

Direct methods
Direct slots
Slot: read-buffer
Initform

(nibbles:make-octet-vector 4096)

Slot: rb-index
Slot: rb-end
Slot: last-client-activity
Readers

connection-last-client-activity (generic function)

Writers

(setf connection-last-client-activity) (generic function)

Slot: last-server-activity
Readers

connection-last-server-activity (generic function)

Writers

(setf connection-last-server-activity) (generic function)

Slot: of-queue
Initform

(cl-bunny::make-output-frame-queue)

Slot: fap-parser
Initform

(cl-bunny::make-fap-parser)

Slot: heartbeat-frame
Initform

(make-instance (quote cl-amqp:heartbeat-frame))

Slot: on-blocked
Initargs

:on-close

Initform

(make-instance (quote cl-bunny::bunny-event))

Readers

connection-on-blocked% (generic function)

Writers

(setf connection-on-blocked%) (generic function)

Slot: on-unblocked
Initargs

:on-close

Initform

(make-instance (quote cl-bunny::bunny-event))

Readers

connection-on-unblocked% (generic function)

Writers

(setf connection-on-unblocked%) (generic function)

Class: iolib-transport ()
Package

cl-bunny

Source

iolib-transport.lisp (file)

Direct superclasses

standard-object (class)

Direct subclasses

iolib-connection (class)

Direct methods
Direct slots
Slot: socket
Readers

connection-socket (generic function)

Writers

(setf connection-socket) (generic function)

Class: message ()
Package

cl-bunny

Source

message.lisp (file)

Direct superclasses

standard-object (class)

Direct subclasses
Direct methods
Direct slots
Slot: channel
Type

cl-bunny::channel

Initargs

:channel

Readers

message-channel (generic function)

Slot: consumer-tag
Type

string

Initargs

:consumer-tag

Readers

message-consumer-tag (generic function)

Slot: consumer
Type

cl-bunny::consumer

Initargs

:consumer

Readers

message-consumer (generic function)

Slot: delivery-tag
Type

integer

Initargs

:delivery-tag

Readers

message-delivery-tag (generic function)

Slot: redelivered
Type

boolean

Initargs

:redelivered

Readers

message-redelivered-p (generic function)

Slot: exchange
Type

string

Initargs

:exchange

Readers

message-exchange (generic function)

Slot: routing-key
Type

string

Initargs

:routing-key

Readers

message-routing-key (generic function)

Slot: properties
Type

cl-amqp:amqp-basic-class-properties

Initargs

:properties

Readers

message-properties (generic function)

Slot: body
Type

(simple-array (unsigned-byte 8) (*))

Initargs

:body

Readers

message-body (generic function)

Class: promise ()
Package

cl-bunny

Source

promise.lisp (file)

Direct superclasses

promise (class)

Direct subclasses

async-promise (class)

Direct methods
Class: queue ()
Package

cl-bunny

Source

queue.lisp (file)

Direct superclasses

standard-object (class)

Direct methods
Direct slots
Slot: name
Type

string

Initargs

:name

Readers

queue-name (generic function)

Slot: server-named
Type

boolean

Initargs

:server-named

Readers

queue-server-named-p (generic function)

Slot: durable
Initargs

:durable

Readers

queue-durable-p (generic function)

Slot: exclusive
Initargs

:exclusive

Readers

queue-exclusive-p (generic function)

Slot: auto-delete
Initargs

:auto-delete

Readers

queue-auto-delete-p (generic function)

Slot: arguments
Initargs

:arguments

Readers

queue-arguments (generic function)

Slot: mailbox
Type

safe-queue:mailbox

Initargs

:mailbox

Initform

(safe-queue:make-mailbox :name "amqp queue mailbox")

Class: returned-message ()
Package

cl-bunny

Source

message.lisp (file)

Direct superclasses

message (class)

Direct methods
Direct slots
Slot: reply-code
Type

fixnum

Initargs

:reply-code

Readers

returned-message-reply-code (generic function)

Slot: reply-text
Type

string

Initargs

:reply-text

Readers

returned-message-reply-text (generic function)

Class: sync-consumer-event ()
Package

cl-bunny

Source

consumer.lisp (file)

Direct superclasses
  • serial-executor (class)
  • single-thread-sink (class)
Class: sync-promise ()
Package

cl-bunny

Source

sync-promise.lisp (file)

Direct superclasses

standard-object (class)

Direct methods
Direct slots
Slot: mutex
Initform

(bordeaux-threads:make-lock "cl-bunny threaded promise mutex")

Readers

snyc-promise-mutex (generic function)

Slot: condition-var
Initform

(bordeaux-threads:make-condition-variable :name "cl-bunny threaded condition variable")

Readers

sync-promise-condition-var (generic function)

Slot: values
Readers

sync-promise-values (generic function)

Writers

(setf sync-promise-values) (generic function)

Slot: error
Readers

sync-promise-error (generic function)

Writers

(setf sync-promise-error) (generic function)

Slot: forced-p
Readers

sync-promise-forced-p (generic function)

Writers

(setf sync-promise-forced-p) (generic function)

Class: threaded-connection ()
Package

cl-bunny

Source

threaded-connection.lisp (file)

Direct superclasses

connection (class)

Direct subclasses

threaded-iolib-connection (class)

Direct methods
Direct slots
Slot: control-fd
Slot: control-mailbox
Readers

connection-control-mailbox (generic function)

Slot: state-lock
Initform

(bordeaux-threads:make-recursive-lock)

Readers

connection-state-lock (generic function)

Slot: execute-in-connection-lambda
Readers

connection-lambda (generic function)

Slot: on-connect-promise
Slot: connection-thread
Readers

connection-thread (generic function)

Class: threaded-iolib-connection ()
Package

cl-bunny

Source

iolib-threaded.lisp (file)

Direct superclasses
Direct methods
Direct slots
Slot: connection-open-promise
Initargs

:open-promise

Readers

connection-open-promise (generic function)

Class: tx-channel ()
Package

cl-bunny

Source

tx.lisp (file)

Direct superclasses

channel (class)


Previous: , Up: Internal definitions   [Contents][Index]

6.2.9 Types

Type: channel-mode ()
Package

cl-bunny

Source

channel.lisp (file)


Previous: , Up: Top   [Contents][Index]

Appendix A Indexes


Next: , Previous: , Up: Indexes   [Contents][Index]

A.1 Concepts

Jump to:   C   F   L   M  
Index Entry  Section

C
cl-bunny.asd: The cl-bunny<dot>asd file
cl-bunny/src: The cl-bunny/src module
cl-bunny/src/base: The cl-bunny/src/base module
cl-bunny/src/base/channel-base.lisp: The cl-bunny/src/base/channel-base<dot>lisp file
cl-bunny/src/base/connection-base.lisp: The cl-bunny/src/base/connection-base<dot>lisp file
cl-bunny/src/base/threaded-connection.lisp: The cl-bunny/src/base/threaded-connection<dot>lisp file
cl-bunny/src/basic.lisp: The cl-bunny/src/basic<dot>lisp file
cl-bunny/src/channel.lisp: The cl-bunny/src/channel<dot>lisp file
cl-bunny/src/conditions.lisp: The cl-bunny/src/conditions<dot>lisp file
cl-bunny/src/confirm.lisp: The cl-bunny/src/confirm<dot>lisp file
cl-bunny/src/connection: The cl-bunny/src/connection module
cl-bunny/src/connection/iolib-connection.lisp: The cl-bunny/src/connection/iolib-connection<dot>lisp file
cl-bunny/src/connection/iolib-threaded.lisp: The cl-bunny/src/connection/iolib-threaded<dot>lisp file
cl-bunny/src/connection/pool.lisp: The cl-bunny/src/connection/pool<dot>lisp file
cl-bunny/src/connection/spec.lisp: The cl-bunny/src/connection/spec<dot>lisp file
cl-bunny/src/consumer.lisp: The cl-bunny/src/consumer<dot>lisp file
cl-bunny/src/exchange.lisp: The cl-bunny/src/exchange<dot>lisp file
cl-bunny/src/io: The cl-bunny/src/io module
cl-bunny/src/io/frame-and-payload-parser.lisp: The cl-bunny/src/io/frame-and-payload-parser<dot>lisp file
cl-bunny/src/io/output-frame-queue.lisp: The cl-bunny/src/io/output-frame-queue<dot>lisp file
cl-bunny/src/message.lisp: The cl-bunny/src/message<dot>lisp file
cl-bunny/src/package.lisp: The cl-bunny/src/package<dot>lisp file
cl-bunny/src/printer.lisp: The cl-bunny/src/printer<dot>lisp file
cl-bunny/src/properties-and-headers.lisp: The cl-bunny/src/properties-and-headers<dot>lisp file
cl-bunny/src/queue.lisp: The cl-bunny/src/queue<dot>lisp file
cl-bunny/src/support: The cl-bunny/src/support module
cl-bunny/src/support/async-promise.lisp: The cl-bunny/src/support/async-promise<dot>lisp file
cl-bunny/src/support/bunny-event.lisp: The cl-bunny/src/support/bunny-event<dot>lisp file
cl-bunny/src/support/channel-id-allocator.lisp: The cl-bunny/src/support/channel-id-allocator<dot>lisp file
cl-bunny/src/support/int-allocator.lisp: The cl-bunny/src/support/int-allocator<dot>lisp file
cl-bunny/src/support/pipe.lisp: The cl-bunny/src/support/pipe<dot>lisp file
cl-bunny/src/support/promise.lisp: The cl-bunny/src/support/promise<dot>lisp file
cl-bunny/src/support/sync-promise.lisp: The cl-bunny/src/support/sync-promise<dot>lisp file
cl-bunny/src/transport: The cl-bunny/src/transport module
cl-bunny/src/transport/iolib-transport.lisp: The cl-bunny/src/transport/iolib-transport<dot>lisp file
cl-bunny/src/tx.lisp: The cl-bunny/src/tx<dot>lisp file

F
File, Lisp, cl-bunny.asd: The cl-bunny<dot>asd file
File, Lisp, cl-bunny/src/base/channel-base.lisp: The cl-bunny/src/base/channel-base<dot>lisp file
File, Lisp, cl-bunny/src/base/connection-base.lisp: The cl-bunny/src/base/connection-base<dot>lisp file
File, Lisp, cl-bunny/src/base/threaded-connection.lisp: The cl-bunny/src/base/threaded-connection<dot>lisp file
File, Lisp, cl-bunny/src/basic.lisp: The cl-bunny/src/basic<dot>lisp file
File, Lisp, cl-bunny/src/channel.lisp: The cl-bunny/src/channel<dot>lisp file
File, Lisp, cl-bunny/src/conditions.lisp: The cl-bunny/src/conditions<dot>lisp file
File, Lisp, cl-bunny/src/confirm.lisp: The cl-bunny/src/confirm<dot>lisp file
File, Lisp, cl-bunny/src/connection/iolib-connection.lisp: The cl-bunny/src/connection/iolib-connection<dot>lisp file
File, Lisp, cl-bunny/src/connection/iolib-threaded.lisp: The cl-bunny/src/connection/iolib-threaded<dot>lisp file
File, Lisp, cl-bunny/src/connection/pool.lisp: The cl-bunny/src/connection/pool<dot>lisp file
File, Lisp, cl-bunny/src/connection/spec.lisp: The cl-bunny/src/connection/spec<dot>lisp file
File, Lisp, cl-bunny/src/consumer.lisp: The cl-bunny/src/consumer<dot>lisp file
File, Lisp, cl-bunny/src/exchange.lisp: The cl-bunny/src/exchange<dot>lisp file
File, Lisp, cl-bunny/src/io/frame-and-payload-parser.lisp: The cl-bunny/src/io/frame-and-payload-parser<dot>lisp file
File, Lisp, cl-bunny/src/io/output-frame-queue.lisp: The cl-bunny/src/io/output-frame-queue<dot>lisp file
File, Lisp, cl-bunny/src/message.lisp: The cl-bunny/src/message<dot>lisp file
File, Lisp, cl-bunny/src/package.lisp: The cl-bunny/src/package<dot>lisp file
File, Lisp, cl-bunny/src/printer.lisp: The cl-bunny/src/printer<dot>lisp file
File, Lisp, cl-bunny/src/properties-and-headers.lisp: The cl-bunny/src/properties-and-headers<dot>lisp file
File, Lisp, cl-bunny/src/queue.lisp: The cl-bunny/src/queue<dot>lisp file
File, Lisp, cl-bunny/src/support/async-promise.lisp: The cl-bunny/src/support/async-promise<dot>lisp file
File, Lisp, cl-bunny/src/support/bunny-event.lisp: The cl-bunny/src/support/bunny-event<dot>lisp file
File, Lisp, cl-bunny/src/support/channel-id-allocator.lisp: The cl-bunny/src/support/channel-id-allocator<dot>lisp file
File, Lisp, cl-bunny/src/support/int-allocator.lisp: The cl-bunny/src/support/int-allocator<dot>lisp file
File, Lisp, cl-bunny/src/support/pipe.lisp: The cl-bunny/src/support/pipe<dot>lisp file
File, Lisp, cl-bunny/src/support/promise.lisp: The cl-bunny/src/support/promise<dot>lisp file
File, Lisp, cl-bunny/src/support/sync-promise.lisp: The cl-bunny/src/support/sync-promise<dot>lisp file
File, Lisp, cl-bunny/src/transport/iolib-transport.lisp: The cl-bunny/src/transport/iolib-transport<dot>lisp file
File, Lisp, cl-bunny/src/tx.lisp: The cl-bunny/src/tx<dot>lisp file

L
Lisp File, cl-bunny.asd: The cl-bunny<dot>asd file
Lisp File, cl-bunny/src/base/channel-base.lisp: The cl-bunny/src/base/channel-base<dot>lisp file
Lisp File, cl-bunny/src/base/connection-base.lisp: The cl-bunny/src/base/connection-base<dot>lisp file
Lisp File, cl-bunny/src/base/threaded-connection.lisp: The cl-bunny/src/base/threaded-connection<dot>lisp file
Lisp File, cl-bunny/src/basic.lisp: The cl-bunny/src/basic<dot>lisp file
Lisp File, cl-bunny/src/channel.lisp: The cl-bunny/src/channel<dot>lisp file
Lisp File, cl-bunny/src/conditions.lisp: The cl-bunny/src/conditions<dot>lisp file
Lisp File, cl-bunny/src/confirm.lisp: The cl-bunny/src/confirm<dot>lisp file
Lisp File, cl-bunny/src/connection/iolib-connection.lisp: The cl-bunny/src/connection/iolib-connection<dot>lisp file
Lisp File, cl-bunny/src/connection/iolib-threaded.lisp: The cl-bunny/src/connection/iolib-threaded<dot>lisp file
Lisp File, cl-bunny/src/connection/pool.lisp: The cl-bunny/src/connection/pool<dot>lisp file
Lisp File, cl-bunny/src/connection/spec.lisp: The cl-bunny/src/connection/spec<dot>lisp file
Lisp File, cl-bunny/src/consumer.lisp: The cl-bunny/src/consumer<dot>lisp file
Lisp File, cl-bunny/src/exchange.lisp: The cl-bunny/src/exchange<dot>lisp file
Lisp File, cl-bunny/src/io/frame-and-payload-parser.lisp: The cl-bunny/src/io/frame-and-payload-parser<dot>lisp file
Lisp File, cl-bunny/src/io/output-frame-queue.lisp: The cl-bunny/src/io/output-frame-queue<dot>lisp file
Lisp File, cl-bunny/src/message.lisp: The cl-bunny/src/message<dot>lisp file
Lisp File, cl-bunny/src/package.lisp: The cl-bunny/src/package<dot>lisp file
Lisp File, cl-bunny/src/printer.lisp: The cl-bunny/src/printer<dot>lisp file
Lisp File, cl-bunny/src/properties-and-headers.lisp: The cl-bunny/src/properties-and-headers<dot>lisp file
Lisp File, cl-bunny/src/queue.lisp: The cl-bunny/src/queue<dot>lisp file
Lisp File, cl-bunny/src/support/async-promise.lisp: The cl-bunny/src/support/async-promise<dot>lisp file
Lisp File, cl-bunny/src/support/bunny-event.lisp: The cl-bunny/src/support/bunny-event<dot>lisp file
Lisp File, cl-bunny/src/support/channel-id-allocator.lisp: The cl-bunny/src/support/channel-id-allocator<dot>lisp file
Lisp File, cl-bunny/src/support/int-allocator.lisp: The cl-bunny/src/support/int-allocator<dot>lisp file
Lisp File, cl-bunny/src/support/pipe.lisp: The cl-bunny/src/support/pipe<dot>lisp file
Lisp File, cl-bunny/src/support/promise.lisp: The cl-bunny/src/support/promise<dot>lisp file
Lisp File, cl-bunny/src/support/sync-promise.lisp: The cl-bunny/src/support/sync-promise<dot>lisp file
Lisp File, cl-bunny/src/transport/iolib-transport.lisp: The cl-bunny/src/transport/iolib-transport<dot>lisp file
Lisp File, cl-bunny/src/tx.lisp: The cl-bunny/src/tx<dot>lisp file

M
Module, cl-bunny/src: The cl-bunny/src module
Module, cl-bunny/src/base: The cl-bunny/src/base module
Module, cl-bunny/src/connection: The cl-bunny/src/connection module
Module, cl-bunny/src/io: The cl-bunny/src/io module
Module, cl-bunny/src/support: The cl-bunny/src/support module
Module, cl-bunny/src/transport: The cl-bunny/src/transport module

Jump to:   C   F   L   M  

Next: , Previous: , Up: Indexes   [Contents][Index]

A.2 Functions

Jump to:   (   -  
A   C   D   E   F   G   H   I   M   N   O   P   Q   R   S   T   U   V   W  
Index Entry  Section

(
(setf channel-expected-reply): Internal generic functions
(setf channel-expected-reply): Internal generic functions
(setf channel-id-allocator-int-allocator): Internal functions
(setf channel-id-allocator-mutex): Internal functions
(setf channel-on-error%): Internal generic functions
(setf channel-on-error%): Internal generic functions
(setf channel-on-return%): Internal generic functions
(setf channel-on-return%): Internal generic functions
(setf channel-open-p%): Internal generic functions
(setf channel-open-p%): Internal generic functions
(setf channel-state): Internal generic functions
(setf channel-state): Internal generic functions
(setf channel-unconfirmed-set): Internal generic functions
(setf channel-unconfirmed-set): Internal generic functions
(setf confirm-channel-counter): Internal generic functions
(setf confirm-channel-counter): Internal generic functions
(setf connection-channel-max%): Internal generic functions
(setf connection-channel-max%): Internal generic functions
(setf connection-frame-max%): Internal generic functions
(setf connection-frame-max%): Internal generic functions
(setf connection-heartbeat%): Internal generic functions
(setf connection-heartbeat%): Internal generic functions
(setf connection-last-client-activity): Internal generic functions
(setf connection-last-client-activity): Internal generic functions
(setf connection-last-server-activity): Internal generic functions
(setf connection-last-server-activity): Internal generic functions
(setf connection-on-blocked%): Internal generic functions
(setf connection-on-blocked%): Internal generic functions
(setf connection-on-close%): Internal generic functions
(setf connection-on-close%): Internal generic functions
(setf connection-on-error%): Internal generic functions
(setf connection-on-error%): Internal generic functions
(setf connection-on-unblocked%): Internal generic functions
(setf connection-on-unblocked%): Internal generic functions
(setf connection-pool): Internal generic functions
(setf connection-pool): Internal generic functions
(setf connection-pool-tag): Internal generic functions
(setf connection-pool-tag): Internal generic functions
(setf connection-socket): Internal generic functions
(setf connection-socket): Internal generic functions
(setf connection-spec-channel-max): Exported functions
(setf connection-spec-frame-max): Exported functions
(setf connection-spec-heartbeat-interval): Exported functions
(setf connection-spec-host): Exported functions
(setf connection-spec-login): Exported functions
(setf connection-spec-password): Exported functions
(setf connection-spec-port): Exported functions
(setf connection-spec-tls-ca): Internal functions
(setf connection-spec-tls-cert): Internal functions
(setf connection-spec-tls-key): Internal functions
(setf connection-spec-tls-verify-hostname): Internal functions
(setf connection-spec-tls-verify-peer): Internal functions
(setf connection-spec-use-ipv6-p): Exported functions
(setf connection-spec-use-tls-p): Exported functions
(setf connection-spec-vhost): Exported functions
(setf exchange-on-return): Exported generic functions
(setf exchange-on-return): Exported generic functions
(setf fap-parser-buffer): Internal functions
(setf fap-parser-buffer-index): Internal functions
(setf fap-parser-end-index): Internal functions
(setf fap-parser-frame): Internal functions
(setf fap-parser-parser): Internal functions
(setf fap-parser-payload-parser): Internal functions
(setf int-allocator-bits): Internal functions
(setf int-allocator-max): Internal functions
(setf int-allocator-min): Internal functions
(setf output-frame-queue-current-frame-bytes): Internal functions
(setf output-frame-queue-current-frame-position): Internal functions
(setf output-frame-queue-queue): Internal functions
(setf output-frame-queue-state): Internal functions
(setf sync-promise-error): Internal generic functions
(setf sync-promise-error): Internal generic functions
(setf sync-promise-forced-p): Internal generic functions
(setf sync-promise-forced-p): Internal generic functions
(setf sync-promise-values): Internal generic functions
(setf sync-promise-values): Internal generic functions

-
->: Exported macros

A
add-consumer: Internal functions
async-promise-notify-lambda: Internal generic functions
async-promise-notify-lambda: Internal generic functions

C
channel-connection: Exported generic functions
channel-connection: Exported generic functions
channel-connection: Exported generic functions
channel-consume-message: Internal functions
channel-consumers: Internal generic functions
channel-consumers: Internal generic functions
channel-exchanges: Internal generic functions
channel-exchanges: Internal generic functions
channel-expected-reply: Internal generic functions
channel-expected-reply: Internal generic functions
channel-id: Exported generic functions
channel-id: Exported generic functions
channel-id: Exported generic functions
channel-id: Exported generic functions
channel-id-allocated-p: Internal functions
channel-id-allocator-int-allocator: Internal functions
channel-id-allocator-mutex: Internal functions
channel-id-allocator-p: Internal functions
channel-mailbox: Internal generic functions
channel-mailbox: Internal generic functions
channel-method-assembler: Internal generic functions
channel-method-assembler: Internal generic functions
channel-mode: Internal generic functions
channel-mode: Internal generic functions
channel-on-error: Exported functions
channel-on-error%: Internal generic functions
channel-on-error%: Internal generic functions
channel-on-return: Exported functions
channel-on-return%: Internal generic functions
channel-on-return%: Internal generic functions
channel-open-p: Exported generic functions
channel-open-p: Exported generic functions
channel-open-p%: Internal generic functions
channel-open-p%: Internal generic functions
channel-open-p%: Internal generic functions
channel-state: Internal generic functions
channel-state: Internal generic functions
channel-unconfirmed-set: Internal generic functions
channel-unconfirmed-set: Internal generic functions
channel.close: Exported functions
channel.close-ok%: Internal functions
channel.confirm: Exported functions
channel.flow: Exported functions
channel.flow-ok: Internal functions
channel.new: Exported functions
channel.new.open: Exported functions
channel.open: Exported functions
channel.publish: Internal generic functions
channel.publish: Internal generic functions
channel.publish: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive: Internal generic functions
channel.receive-frame: Internal functions
channel.safe-close: Internal functions
channel.send: Exported functions
channel.send%: Internal macros
channel.send-with-callback%: Internal macros
channel.tx: Exported functions
channel.wait-confirms: Exported functions
channel.wait-confirms%: Internal generic functions
channel.wait-confirms%: Internal generic functions
check-boolean-parameter: Internal functions
check-connection-alive: Internal functions
check-connection-parameters: Internal generic functions
check-connection-parameters: Internal generic functions
check-connection-parameters: Internal generic functions
check-connection-string-credentials: Internal functions
check-connection-string-host: Internal functions
check-connection-string-port: Internal functions
check-connection-string-scheme: Internal functions
check-connection-string-vhost: Internal functions
check-uint-parameter: Internal functions
check-vhost-single-segment: Internal functions
close-connection-with-error: Internal generic functions
close-connection-with-error: Internal generic functions
close-method-to-error: Internal functions
confirm-channel-condition-var: Internal generic functions
confirm-channel-condition-var: Internal generic functions
confirm-channel-counter: Internal generic functions
confirm-channel-counter: Internal generic functions
confirm-channel-lock: Internal generic functions
confirm-channel-lock: Internal generic functions
confirm-message-nowait: Internal generic functions
confirm-message-nowait: Internal generic functions
confirm-message-promise: Internal generic functions
confirm-message-promise: Internal generic functions
connection-channel-id-allocator: Internal generic functions
connection-channel-id-allocator: Internal generic functions
connection-channel-max: Exported functions
connection-channel-max%: Internal generic functions
connection-channel-max%: Internal generic functions
connection-channels: Internal generic functions
connection-channels: Internal generic functions
connection-control-mailbox: Internal generic functions
connection-control-mailbox: Internal generic functions
connection-event-base: Internal generic functions
connection-event-base: Internal generic functions
connection-frame-max: Exported functions
connection-frame-max%: Internal generic functions
connection-frame-max%: Internal generic functions
connection-heartbeat: Exported functions
connection-heartbeat%: Internal generic functions
connection-heartbeat%: Internal generic functions
connection-init: Internal generic functions
connection-lambda: Internal generic functions
connection-lambda: Internal generic functions
connection-last-client-activity: Internal generic functions
connection-last-client-activity: Internal generic functions
connection-last-server-activity: Internal generic functions
connection-last-server-activity: Internal generic functions
connection-loop: Internal generic functions
connection-loop: Internal generic functions
connection-on-blocked: Exported functions
connection-on-blocked%: Internal generic functions
connection-on-blocked%: Internal generic functions
connection-on-close: Exported functions
connection-on-close%: Internal generic functions
connection-on-close%: Internal generic functions
connection-on-error%: Internal generic functions
connection-on-error%: Internal generic functions
connection-on-unblocked: Exported functions
connection-on-unblocked%: Internal generic functions
connection-on-unblocked%: Internal generic functions
connection-open-p: Exported functions
connection-open-p%: Internal generic functions
connection-open-p%: Internal generic functions
connection-open-p%: Internal generic functions
connection-open-p%: Internal generic functions
connection-open-promise: Internal generic functions
connection-open-promise: Internal generic functions
connection-pool: Internal generic functions
connection-pool: Internal generic functions
connection-pool-tag: Internal generic functions
connection-pool-tag: Internal generic functions
connection-server-properties: Exported functions
connection-server-properties%: Internal generic functions
connection-socket: Internal generic functions
connection-socket: Internal generic functions
connection-spec: Exported generic functions
connection-spec: Exported generic functions
connection-spec-channel-max: Exported functions
connection-spec-frame-max: Exported functions
connection-spec-heartbeat-interval: Exported functions
connection-spec-host: Exported functions
connection-spec-login: Exported functions
connection-spec-p: Internal functions
connection-spec-password: Exported functions
connection-spec-port: Exported functions
connection-spec-tls-ca: Internal functions
connection-spec-tls-cert: Internal functions
connection-spec-tls-key: Internal functions
connection-spec-tls-verify-hostname: Internal functions
connection-spec-tls-verify-peer: Internal functions
connection-spec-use-ipv6-p: Exported functions
connection-spec-use-tls-p: Exported functions
connection-spec-vhost: Exported functions
connection-state-lock: Internal generic functions
connection-state-lock: Internal generic functions
connection-thread: Internal generic functions
connection-thread: Internal generic functions
connection.close: Exported functions
connection.close%: Internal generic functions
connection.close%: Internal generic functions
connection.consume: Exported functions
connection.consume%: Internal generic functions
connection.deregister-channel: Internal functions
connection.get-channel: Internal functions
connection.init: Internal generic functions
connection.init: Internal generic functions
connection.new: Exported functions
connection.new%: Internal generic functions
connection.new%: Internal generic functions
connection.new%: Internal generic functions
connection.open: Exported functions
connection.open%: Internal generic functions
connection.open%: Internal generic functions
connection.open%: Internal generic functions
connection.receive: Internal generic functions
connection.receive: Internal generic functions
connection.receive: Internal generic functions
connection.receive: Internal generic functions
connection.register-channel: Internal functions
connection.send: Internal generic functions
connection.send: Internal generic functions
connection.send%: Internal functions
connections-pool-lock: Internal generic functions
connections-pool-lock: Internal generic functions
connections-pool-storage: Internal generic functions
connections-pool-storage: Internal generic functions
connections-pool.add: Exported functions
connections-pool.add%: Internal generic functions
connections-pool.add%: Internal generic functions
connections-pool.find-or-run: Exported functions
connections-pool.find-or-run%: Internal generic functions
connections-pool.find-or-run%: Internal generic functions
connections-pool.get: Exported functions
connections-pool.get%: Internal generic functions
connections-pool.get%: Internal generic functions
connections-pool.remove: Exported functions
connections-pool.remove%: Internal generic functions
connections-pool.remove%: Internal generic functions
connections-pool.remove%: Internal generic functions
consume: Exported functions
consumer-channel: Internal generic functions
consumer-channel: Internal generic functions
consumer-event-type: Internal functions
consumer-on-cancel: Internal generic functions
consumer-on-cancel: Internal generic functions
consumer-on-message: Internal generic functions
consumer-on-message: Internal generic functions
consumer-queue: Internal generic functions
consumer-queue: Internal generic functions
consumer-tag: Internal generic functions
consumer-tag: Internal generic functions
consumer-type: Internal generic functions
consumer-type: Internal generic functions
copy-channel-id-allocator: Internal functions
copy-connection-spec: Internal functions
copy-fap-parser: Internal functions
copy-int-allocator: Internal functions
copy-output-frame-queue: Internal functions

D
deregister-channel: Internal generic functions
deregister-channel: Internal generic functions
deregister-exchange: Internal functions
dispatch-consumed-message: Internal functions
dispatch-consumer-cancel: Internal functions

E
enqueue-frame: Internal functions
error-channel: Internal generic functions
error-channel: Internal generic functions
error-channel: Internal generic functions
error-channel: Internal generic functions
error-connection: Exported generic functions
error-connection: Exported generic functions
error-connection: Exported generic functions
error-consumer-tag: Internal generic functions
error-consumer-tag: Internal generic functions
error-message: Internal generic functions
error-message: Internal generic functions
exchange-arguments: Internal generic functions
exchange-arguments: Internal generic functions
exchange-auto-delete-p: Internal generic functions
exchange-auto-delete-p: Internal generic functions
exchange-channel: Internal generic functions
exchange-channel: Internal generic functions
exchange-channel: Internal generic functions
exchange-durable-p: Internal generic functions
exchange-durable-p: Internal generic functions
exchange-internal-p: Internal generic functions
exchange-internal-p: Internal generic functions
exchange-name: Internal generic functions
exchange-name: Internal generic functions
exchange-name: Internal generic functions
exchange-on-return: Exported generic functions
exchange-on-return: Exported generic functions
exchange-type: Internal generic functions
exchange-type: Internal generic functions
exchange-type: Internal generic functions
exchange.bind: Exported functions
exchange.declare: Exported functions
exchange.default: Exported functions
exchange.delete: Exported functions
exchange.direct: Exported functions
exchange.exists-p: Exported functions
exchange.fanout: Exported functions
exchange.headers: Exported functions
exchange.match: Exported functions
exchange.topic: Exported functions
exchange.unbind: Exported functions
execute-consumer: Internal functions
execute-in-connection-thread: Internal macros
execute-on-connection-thread: Internal generic functions
execute-on-connection-thread: Internal generic functions

F
fap-parser-advance: Internal functions
fap-parser-advance-end: Internal functions
fap-parser-buffer: Internal functions
fap-parser-buffer-index: Internal functions
fap-parser-end-index: Internal functions
fap-parser-frame: Internal functions
fap-parser-p: Internal functions
fap-parser-parser: Internal functions
fap-parser-payload-parser: Internal functions
find-consumer: Internal functions
find-message-consumer: Internal functions
Function, (setf channel-id-allocator-int-allocator): Internal functions
Function, (setf channel-id-allocator-mutex): Internal functions
Function, (setf connection-spec-channel-max): Exported functions
Function, (setf connection-spec-frame-max): Exported functions
Function, (setf connection-spec-heartbeat-interval): Exported functions
Function, (setf connection-spec-host): Exported functions
Function, (setf connection-spec-login): Exported functions
Function, (setf connection-spec-password): Exported functions
Function, (setf connection-spec-port): Exported functions
Function, (setf connection-spec-tls-ca): Internal functions
Function, (setf connection-spec-tls-cert): Internal functions
Function, (setf connection-spec-tls-key): Internal functions
Function, (setf connection-spec-tls-verify-hostname): Internal functions
Function, (setf connection-spec-tls-verify-peer): Internal functions
Function, (setf connection-spec-use-ipv6-p): Exported functions
Function, (setf connection-spec-use-tls-p): Exported functions
Function, (setf connection-spec-vhost): Exported functions
Function, (setf fap-parser-buffer): Internal functions
Function, (setf fap-parser-buffer-index): Internal functions
Function, (setf fap-parser-end-index): Internal functions
Function, (setf fap-parser-frame): Internal functions
Function, (setf fap-parser-parser): Internal functions
Function, (setf fap-parser-payload-parser): Internal functions
Function, (setf int-allocator-bits): Internal functions
Function, (setf int-allocator-max): Internal functions
Function, (setf int-allocator-min): Internal functions
Function, (setf output-frame-queue-current-frame-bytes): Internal functions
Function, (setf output-frame-queue-current-frame-position): Internal functions
Function, (setf output-frame-queue-queue): Internal functions
Function, (setf output-frame-queue-state): Internal functions
Function, add-consumer: Internal functions
Function, channel-consume-message: Internal functions
Function, channel-id-allocated-p: Internal functions
Function, channel-id-allocator-int-allocator: Internal functions
Function, channel-id-allocator-mutex: Internal functions
Function, channel-id-allocator-p: Internal functions
Function, channel-on-error: Exported functions
Function, channel-on-return: Exported functions
Function, channel.close: Exported functions
Function, channel.close-ok%: Internal functions
Function, channel.confirm: Exported functions
Function, channel.flow: Exported functions
Function, channel.flow-ok: Internal functions
Function, channel.new: Exported functions
Function, channel.new.open: Exported functions
Function, channel.open: Exported functions
Function, channel.receive-frame: Internal functions
Function, channel.safe-close: Internal functions
Function, channel.send: Exported functions
Function, channel.tx: Exported functions
Function, channel.wait-confirms: Exported functions
Function, check-boolean-parameter: Internal functions
Function, check-connection-alive: Internal functions
Function, check-connection-string-credentials: Internal functions
Function, check-connection-string-host: Internal functions
Function, check-connection-string-port: Internal functions
Function, check-connection-string-scheme: Internal functions
Function, check-connection-string-vhost: Internal functions
Function, check-uint-parameter: Internal functions
Function, check-vhost-single-segment: Internal functions
Function, close-method-to-error: Internal functions
Function, connection-channel-max: Exported functions
Function, connection-frame-max: Exported functions
Function, connection-heartbeat: Exported functions
Function, connection-on-blocked: Exported functions
Function, connection-on-close: Exported functions
Function, connection-on-unblocked: Exported functions
Function, connection-open-p: Exported functions
Function, connection-server-properties: Exported functions
Function, connection-spec-channel-max: Exported functions
Function, connection-spec-frame-max: Exported functions
Function, connection-spec-heartbeat-interval: Exported functions
Function, connection-spec-host: Exported functions
Function, connection-spec-login: Exported functions
Function, connection-spec-p: Internal functions
Function, connection-spec-password: Exported functions
Function, connection-spec-port: Exported functions
Function, connection-spec-tls-ca: Internal functions
Function, connection-spec-tls-cert: Internal functions
Function, connection-spec-tls-key: Internal functions
Function, connection-spec-tls-verify-hostname: Internal functions
Function, connection-spec-tls-verify-peer: Internal functions
Function, connection-spec-use-ipv6-p: Exported functions
Function, connection-spec-use-tls-p: Exported functions
Function, connection-spec-vhost: Exported functions
Function, connection.close: Exported functions
Function, connection.consume: Exported functions
Function, connection.deregister-channel: Internal functions
Function, connection.get-channel: Internal functions
Function, connection.new: Exported functions
Function, connection.open: Exported functions
Function, connection.register-channel: Internal functions
Function, connection.send%: Internal functions
Function, connections-pool.add: Exported functions
Function, connections-pool.find-or-run: Exported functions
Function, connections-pool.get: Exported functions
Function, connections-pool.remove: Exported functions
Function, consume: Exported functions
Function, consumer-event-type: Internal functions
Function, copy-channel-id-allocator: Internal functions
Function, copy-connection-spec: Internal functions
Function, copy-fap-parser: Internal functions
Function, copy-int-allocator: Internal functions
Function, copy-output-frame-queue: Internal functions
Function, deregister-exchange: Internal functions
Function, dispatch-consumed-message: Internal functions
Function, dispatch-consumer-cancel: Internal functions
Function, enqueue-frame: Internal functions
Function, exchange.bind: Exported functions
Function, exchange.declare: Exported functions
Function, exchange.default: Exported functions
Function, exchange.delete: Exported functions
Function, exchange.direct: Exported functions
Function, exchange.exists-p: Exported functions
Function, exchange.fanout: Exported functions
Function, exchange.headers: Exported functions
Function, exchange.match: Exported functions
Function, exchange.topic: Exported functions
Function, exchange.unbind: Exported functions
Function, execute-consumer: Internal functions
Function, fap-parser-advance: Internal functions
Function, fap-parser-advance-end: Internal functions
Function, fap-parser-buffer: Internal functions
Function, fap-parser-buffer-index: Internal functions
Function, fap-parser-end-index: Internal functions
Function, fap-parser-frame: Internal functions
Function, fap-parser-p: Internal functions
Function, fap-parser-parser: Internal functions
Function, fap-parser-payload-parser: Internal functions
Function, find-consumer: Internal functions
Function, find-message-consumer: Internal functions
Function, get-connection-type: Internal functions
Function, get-customized-connection-parameters: Internal functions
Function, get-frame-bytes: Internal functions
Function, get-registered-exchange: Internal functions
Function, header-value: Internal functions
Function, install-main-readers: Internal functions
Function, int-allocator-allocate: Internal functions
Function, int-allocator-allocate%: Internal functions
Function, int-allocator-allocated-p: Internal functions
Function, int-allocator-bits: Internal functions
Function, int-allocator-isset%: Internal functions
Function, int-allocator-max: Internal functions
Function, int-allocator-min: Internal functions
Function, int-allocator-p: Internal functions
Function, int-allocator-release: Internal functions
Function, int-allocator-set%: Internal functions
Function, int-allocator-unset%: Internal functions
Function, make-async-promise: Internal functions
Function, make-channel-id-allocator: Internal functions
Function, make-confirm-message: Internal functions
Function, make-connection-spec%: Internal functions
Function, make-fap-parser: Internal functions
Function, make-fap-parser%: Internal functions
Function, make-int-allocator: Internal functions
Function, make-int-allocator%: Internal functions
Function, make-output-frame-queue: Internal functions
Function, make-promise: Internal functions
Function, make-sync-promise: Internal functions
Function, maybe-install-heartbeat-timer: Internal functions
Function, maybe-unescape-component: Internal functions
Function, message-app-id: Exported functions
Function, message-body-string: Exported functions
Function, message-cluster-id: Exported functions
Function, message-content-encoding: Exported functions
Function, message-content-type: Exported functions
Function, message-correlation-id: Exported functions
Function, message-expiration: Exported functions
Function, message-header-value: Exported functions
Function, message-headers: Exported functions
Function, message-message-id: Exported functions
Function, message-persistent-p: Exported functions
Function, message-priority: Exported functions
Function, message-reply-to: Exported functions
Function, message-timestamp: Exported functions
Function, message-type: Exported functions
Function, message-user-id: Exported functions
Function, message.ack: Exported functions
Function, message.nack: Exported functions
Function, new-channel-id-allocator: Internal functions
Function, next-channel-id: Internal functions
Function, notify-confirm-message-waiter: Internal functions
Function, notify-sync-promise-resolved: Internal functions
Function, open-socket-and-say-hello: Internal functions
Function, output-frame-queue-count: Internal functions
Function, output-frame-queue-current-frame-bytes: Internal functions
Function, output-frame-queue-current-frame-position: Internal functions
Function, output-frame-queue-p: Internal functions
Function, output-frame-queue-pop: Internal functions
Function, output-frame-queue-push: Internal functions
Function, output-frame-queue-queue: Internal functions
Function, output-frame-queue-state: Internal functions
Function, parse-boolean: Internal functions
Function, parse-user-info: Internal functions
Function, parse-with-channel-params: Internal functions
Function, parse-with-channel-params-list: Internal functions
Function, parse-with-connection-params: Internal functions
Function, parse-with-connection-params-list: Internal functions
Function, perform-handshake: Internal functions
Function, promise.force: Internal functions
Function, promise.force%: Internal functions
Function, publish: Exported functions
Function, qos: Exported functions
Function, queue.bind: Exported functions
Function, queue.consumer-count: Exported functions
Function, queue.declare: Exported functions
Function, queue.declare-temp: Exported functions
Function, queue.delete: Exported functions
Function, queue.exists-p: Exported functions
Function, queue.get: Exported functions
Function, queue.message-count: Exported functions
Function, queue.peek: Exported functions
Function, queue.purge: Exported functions
Function, queue.put: Exported functions
Function, queue.status: Internal functions
Function, queue.unbind: Exported functions
Function, read-frames: Internal functions
Function, register-exchange: Internal functions
Function, release-channel-id: Internal functions
Function, remove-consumer: Internal functions
Function, render-connection-parameters: Internal functions
Function, render-host: Internal functions
Function, render-port: Internal functions
Function, render-scheme: Internal functions
Function, render-userinfo: Internal functions
Function, render-vhost: Internal functions
Function, send-queued-frames: Internal functions
Function, setup-execute-in-connection-lambda: Internal functions
Function, shutdown-connection: Internal functions
Function, socket-readable: Internal functions
Function, socket-writeable: Internal functions
Function, socket.check: Internal functions
Function, subscribe: Exported functions
Function, subscribe-sync: Exported functions
Function, sync-promise-rejected-p: Internal functions
Function, sync-promise-resolved-or-rejected-p: Internal functions
Function, sync-promise-resolved-p: Internal functions
Function, tx.commit: Exported functions
Function, tx.rollback: Exported functions
Function, unsubscribe: Exported functions
Function, validate-host: Internal functions
Function, validate-server-auth-mechanisms: Internal functions
Function, validate-server-protocol-version: Internal functions
Function, wrap-async-on-cancel-with-channel: Internal functions
Function, wrap-async-subscribe-with-channel: Internal functions

G
Generic Function, (setf channel-expected-reply): Internal generic functions
Generic Function, (setf channel-on-error%): Internal generic functions
Generic Function, (setf channel-on-return%): Internal generic functions
Generic Function, (setf channel-open-p%): Internal generic functions
Generic Function, (setf channel-state): Internal generic functions
Generic Function, (setf channel-unconfirmed-set): Internal generic functions
Generic Function, (setf confirm-channel-counter): Internal generic functions
Generic Function, (setf connection-channel-max%): Internal generic functions
Generic Function, (setf connection-frame-max%): Internal generic functions
Generic Function, (setf connection-heartbeat%): Internal generic functions
Generic Function, (setf connection-last-client-activity): Internal generic functions
Generic Function, (setf connection-last-server-activity): Internal generic functions
Generic Function, (setf connection-on-blocked%): Internal generic functions
Generic Function, (setf connection-on-close%): Internal generic functions
Generic Function, (setf connection-on-error%): Internal generic functions
Generic Function, (setf connection-on-unblocked%): Internal generic functions
Generic Function, (setf connection-pool): Internal generic functions
Generic Function, (setf connection-pool-tag): Internal generic functions
Generic Function, (setf connection-socket): Internal generic functions
Generic Function, (setf exchange-on-return): Exported generic functions
Generic Function, (setf sync-promise-error): Internal generic functions
Generic Function, (setf sync-promise-forced-p): Internal generic functions
Generic Function, (setf sync-promise-values): Internal generic functions
Generic Function, async-promise-notify-lambda: Internal generic functions
Generic Function, channel-connection: Exported generic functions
Generic Function, channel-consumers: Internal generic functions
Generic Function, channel-exchanges: Internal generic functions
Generic Function, channel-expected-reply: Internal generic functions
Generic Function, channel-id: Exported generic functions
Generic Function, channel-mailbox: Internal generic functions
Generic Function, channel-method-assembler: Internal generic functions
Generic Function, channel-mode: Internal generic functions
Generic Function, channel-on-error%: Internal generic functions
Generic Function, channel-on-return%: Internal generic functions
Generic Function, channel-open-p: Exported generic functions
Generic Function, channel-open-p%: Internal generic functions
Generic Function, channel-state: Internal generic functions
Generic Function, channel-unconfirmed-set: Internal generic functions
Generic Function, channel.publish: Internal generic functions
Generic Function, channel.receive: Internal generic functions
Generic Function, channel.wait-confirms%: Internal generic functions
Generic Function, check-connection-parameters: Internal generic functions
Generic Function, close-connection-with-error: Internal generic functions
Generic Function, confirm-channel-condition-var: Internal generic functions
Generic Function, confirm-channel-counter: Internal generic functions
Generic Function, confirm-channel-lock: Internal generic functions
Generic Function, confirm-message-nowait: Internal generic functions
Generic Function, confirm-message-promise: Internal generic functions
Generic Function, connection-channel-id-allocator: Internal generic functions
Generic Function, connection-channel-max%: Internal generic functions
Generic Function, connection-channels: Internal generic functions
Generic Function, connection-control-mailbox: Internal generic functions
Generic Function, connection-event-base: Internal generic functions
Generic Function, connection-frame-max%: Internal generic functions
Generic Function, connection-heartbeat%: Internal generic functions
Generic Function, connection-init: Internal generic functions
Generic Function, connection-lambda: Internal generic functions
Generic Function, connection-last-client-activity: Internal generic functions
Generic Function, connection-last-server-activity: Internal generic functions
Generic Function, connection-loop: Internal generic functions
Generic Function, connection-on-blocked%: Internal generic functions
Generic Function, connection-on-close%: Internal generic functions
Generic Function, connection-on-error%: Internal generic functions
Generic Function, connection-on-unblocked%: Internal generic functions
Generic Function, connection-open-p%: Internal generic functions
Generic Function, connection-open-promise: Internal generic functions
Generic Function, connection-pool: Internal generic functions
Generic Function, connection-pool-tag: Internal generic functions
Generic Function, connection-server-properties%: Internal generic functions
Generic Function, connection-socket: Internal generic functions
Generic Function, connection-spec: Exported generic functions
Generic Function, connection-state-lock: Internal generic functions
Generic Function, connection-thread: Internal generic functions
Generic Function, connection.close%: Internal generic functions
Generic Function, connection.consume%: Internal generic functions
Generic Function, connection.init: Internal generic functions
Generic Function, connection.new%: Internal generic functions
Generic Function, connection.open%: Internal generic functions