The cl-rabbit Reference Manual

This is the cl-rabbit Reference Manual, generated automatically by Declt version 4.0 beta 2 "William Riker" on Sun Dec 08 17:18:50 2024 GMT+0.

Table of Contents


1 Introduction


2 Systems

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


2.1 cl-rabbit

Simple RabbitMQ interface for Common Lisp using CFFI

Author

Elias Martenson <>

License

MIT

Dependencies
  • cffi (system).
  • cffi-libffi (system).
  • alexandria (system).
  • babel (system).
  • cl-ppcre (system).
Source

cl-rabbit.asd.

Child Component

src (module).


3 Modules

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


3.1 cl-rabbit/src

Source

cl-rabbit.asd.

Parent Component

cl-rabbit (system).

Child Components

4 Files

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


4.1 Lisp


4.1.1 cl-rabbit/cl-rabbit.asd

Source

cl-rabbit.asd.

Parent Component

cl-rabbit (system).

ASDF Systems

cl-rabbit.


4.1.2 cl-rabbit/src/package.lisp

Source

cl-rabbit.asd.

Parent Component

src (module).

Packages

4.1.3 cl-rabbit/src/grovel.lisp

Dependency

package.lisp (file).

Source

cl-rabbit.asd.

Parent Component

src (module).


4.1.4 cl-rabbit/src/functions.lisp

Dependency

grovel.lisp (file).

Source

cl-rabbit.asd.

Parent Component

src (module).

Internals

4.1.5 cl-rabbit/src/misc.lisp

Dependency

functions.lisp (file).

Source

cl-rabbit.asd.

Parent Component

src (module).

Internals

4.1.6 cl-rabbit/src/amqp.lisp

Dependency

misc.lisp (file).

Source

cl-rabbit.asd.

Parent Component

src (module).

Public Interface
Internals

5 Packages

Packages are listed by definition order.


5.1 cl-rabbit.examples

Examples for cl-rabbit

Source

package.lisp.

Use List

5.2 cl-rabbit

CFFI-based interface to RabbitMQ

Source

package.lisp.

Use List

common-lisp.

Used By List

cl-rabbit.examples.

Public Interface
Internals

6 Definitions

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


6.1 Public Interface


6.1.1 Macros

Macro: with-channel ((connection channel) &body body)

Opens CHANNEL, evaluates BODY and ensures you don’t leave without closing the channel

Package

cl-rabbit.

Source

amqp.lisp.

Macro: with-connection ((conn) &body body)

Creates a connection using NEW-CONNECTION and evaluates BODY with the connection bound to CONN.

Package

cl-rabbit.

Source

amqp.lisp.


6.1.2 Ordinary functions

Function: basic-ack (conn channel delivery-tag &key multiple)

Acknowledges a message.
Does a basic.ack on a received message.

Parameters:
CONN - the connection object
CHANNEL - the channel identifier
MULTIPLE - if true, ack all messages up to this delivery tag, if false ack only this delivery tag

Package

cl-rabbit.

Source

amqp.lisp.

Function: basic-cancel (conn channel consumer-tag)
Package

cl-rabbit.

Source

amqp.lisp.

Function: basic-consume (conn channel queue &key consumer-tag no-local no-ack exclusive arguments)
Package

cl-rabbit.

Source

amqp.lisp.

Function: basic-nack (conn channel delivery-tag &key multiple requeue)

Do a basic.nack.
Actively reject a message, this has the same effect as amqp_basic_reject() however, amqp_basic_nack() can negatively acknowledge multiple messages with
one call much like amqp_basic_ack() can acknowledge mutliple messages with
one call.

Parameters:
CONN - the connection object
CHANNEL - the channel identifier
DELIVERY-TAG - the delivery tag of the message to reject
MULTIPLE - if true negatively acknowledge all unacknowledged messages on this channel REQUEUE - indicate to the broker whether it should requeue the message

Package

cl-rabbit.

Source

amqp.lisp.

Function: basic-publish (conn channel &key exchange routing-key mandatory immediate properties body encoding)

Publish a message on an exchange with a routing key.
Note that at the AMQ protocol level basic.publish is an async method:
this means error conditions that occur on the broker (such as
publishing to a non-existent exchange) will not be reflected in the
return value of this function.

Parameters:

CONN - the connection on which to send the message.

CHANNEL - the channel that should be used.

EXCHANGE - the exchange on the broker to publish to

ROUTING-KEY - the routing key to use when publishing the message

MANDATORY - indicate to the broker that the message MUST be routed to
a queue. If the broker cannot do this it should respond with a
basic.reject method

IMMEDIATE - indicate to the broker that the message MUST be delivered
to a consumer immediately. If the broker cannot do this it should
response with a basic.reject method.

BODY - can be either a vector of bytes, or a string. If it’s a string,
then it will be encoded using ENCODING before sending.

PROPERTIES - indicates an alist of message properties. The
following property keywords are accepted:
:CONTENT-TYPE :CONTENT-ENCODING :DELIVERY-MODE :PRIORITY :CORRELATION-ID
:REPLY-TO :EXPIRATION :MESSAGE-ID :TIMESTAMP :TYPE :USER-ID :APP-ID :CLUSTER-ID :HEADERS

Package

cl-rabbit.

Source

amqp.lisp.

Function: basic-qos (conn channel &key global prefetch-size prefetch-count)
Package

cl-rabbit.

Source

amqp.lisp.

Function: channel-close (conn channel &key code)

Closes a channel.
Parameters:
CONN - the connection object
CHANNEL - the channel that should be closed
CODE - the reason code, defaults to AMQP_REPLY_SUCCESS

Package

cl-rabbit.

Source

amqp.lisp.

Function: channel-flow (conn channel active)

Enable/disable flow from peer.

This method asks the peer to pause or restart the flow of content data sent by a consumer. This is a simple flow-control mechanism that a peer can use to avoid overflowing its queues or otherwise finding itself receiving more messages than it can process. Note that this method is not intended for window control. It does not affect contents returned by Basic.Get-Ok methods.

Parameters:
CONN - the connection object
CHANNEL - the channel that should be updated
ACTIVE - a boolean indicating if flow should be enabled or disabled

Package

cl-rabbit.

Source

amqp.lisp.

Function: channel-open (conn channel)
Package

cl-rabbit.

Source

amqp.lisp.

Function: confirm-select (conn channel)

Set CHANNEL to publisher confirm mode. a channel in transaction mode cannot be set to confirm mode. returns t if successful. signals RABBITMQ-SERVER-ERROR if channel is in transaction mode.

Package

cl-rabbit.

Source

amqp.lisp.

Function: consume-message (conn &key timeout)

Wait for and consume a message.
Waits for a basic.deliver method on any channel, upon receipt of basic.deliver it reads that message, and returns. If any other method is received before basic.deliver, this function will raise a RABBITMQ-LIBRARY-ERROR with its error code set
to :AMQP-UNEXPECTED-FRAME. The caller should then call amqp_simple_wait_frame() to read this frame and take appropriate action.

This function should be used after starting a consumer with the BASIC-CONSUME function.

This function returns an instance of ENVELOPE that contains the consumed message.

Parameters:

CONN - the connection object

TIMEOUT - the number of microseconds to wait for a message delivery. Passing in NIL will result in blocking behaviour.

Package

cl-rabbit.

Source

amqp.lisp.

Function: destroy-connection (conn)

Close a connection that was previously created using NEW-CONNECTION.

Package

cl-rabbit.

Source

amqp.lisp.

Function: exchange-bind (conn channel &key destination source routing-key arguments)
Package

cl-rabbit.

Source

amqp.lisp.

Function: exchange-declare (conn channel exchange type &key passive durable auto-delete internal arguments)
Package

cl-rabbit.

Source

amqp.lisp.

Function: exchange-delete (conn channel exchange &key if-unused)
Package

cl-rabbit.

Source

amqp.lisp.

Function: exchange-unbind (conn channel &key destination source routing-key)
Package

cl-rabbit.

Source

amqp.lisp.

Function: login-sasl-plain (conn vhost user password &key channel-max frame-max heartbeat properties)

Login to the broker using the SASL PLAIN method.

Parameters:

CONN - The connection object

VHOST - the virtual host to connect to on the broker. The default on most brokers is "/"

CHANNEL-MAX - the limit for the number of channels for the connection. 0 means no limit, and is a good default (AMQP_DEFAULT_MAX_CHANNELS) Note that the maximum number of channels the protocol supports is 65535 (2^16, with the 0-channel reserved)

FRAME-MAX - the maximum size of an AMQP frame on the wire to request of the broker for this connection. 4096 is the minimum size, 2^31-1 is the maximum, the default value is 131072 (128 kB).

HEARTBEAT - the number of seconds between heartbeat frame to request of the broker. A value of 0 disables heartbeats.

PROPERTIES - a table of properties to send to the broker

Package

cl-rabbit.

Source

amqp.lisp.

Function: new-connection ()

Create a new connection. The returned connection must be released using DESTROY-CONNECTION. As an alternative, WITH-CONNECTION can be used, which ensures that the connection is properly closed.

Package

cl-rabbit.

Source

amqp.lisp.

Function: queue-bind (conn channel &key queue exchange routing-key arguments)

Bind queue to an exchange.

This method binds a queue to an exchange. Until a queue is bound it will not receive any messages. In a classic messaging model, store-and-forward queues are bound to a direct exchange and subscription queues are bound to a topic exchange.

Package

cl-rabbit.

Source

amqp.lisp.

Function: queue-declare (conn channel &key queue passive durable exclusive auto-delete arguments)

Declare queue, create if needed.

This method creates or checks a queue. When creating a new queue the client can specify various properties that control the durability of the queue and its contents, and the level of sharing for the queue.

This function returns three values: The name of the queue, the number of messages waiting on the queue, the number of consumers for this queue.

Package

cl-rabbit.

Source

amqp.lisp.

Function: queue-delete (conn channel queue &key if-unused if-empty)
Package

cl-rabbit.

Source

amqp.lisp.

Function: queue-purge (conn channel queue)
Package

cl-rabbit.

Source

amqp.lisp.

Function: queue-unbind (conn channel &key queue exchange routing-key arguments)
Package

cl-rabbit.

Source

amqp.lisp.

Function: set-init-ssl-library (init)

Sets whether rabbitmq-c initialises the underlying SSL library.

For SSL libraries that require a one-time initialisation across
a whole program (e.g., OpenSSL) this sets whether or not rabbitmq-c will initialise the SSL library when the first call to amqp_open_socket() is made. You should call this function with do_init = 0 if the underlying SSL library is initialised somewhere else the program.

Failing to initialise or double initialisation of the SSL library will result in undefined behaviour

By default rabbitmq-c will initialise the underlying SSL library

NOTE: calling this function after the first socket has been opened with amqp_open_socket() will not have any effect.

INIT - If NIL rabbitmq-c will not initialise the SSL library, otherwise rabbitmq-c will initialise the SSL library

Package

cl-rabbit.

Source

amqp.lisp.

Function: simple-wait-frame (conn)

Returns frame object for supported frames (see notes section), t for confirmation (ok) frames or signals error for unsupported (not implemented frames), this function waits for frame on ANY CHANNEL on CONN.

Arguments:
CONN => Rabbitmq connection.

NOTES:
Currently implemented frames are basic acknowledgment, basic negative acknowledgment, return, deliver and select ok method frames, content header and content body frames.

Package

cl-rabbit.

Source

amqp.lisp.

Function: socket-open (socket host port)

Open a socket connection.
This function opens a socket connection returned from TCP-SOCKET-NEW or SSL-SOCKET-NEW.

Package

cl-rabbit.

Source

amqp.lisp.

Function: ssl-socket-new (conn)

Create a new TLS-encrypted socket.
Call CONNECTION-CLOSE to release socket resources.

Package

cl-rabbit.

Source

amqp.lisp.

Function: ssl-socket-set-cacert (socket cacert)

Set the CA certificate.
SOCKET is a socket object created by SSL-SOCKET-NEW. CACERT is the path to a certificate file in PEM format.

Package

cl-rabbit.

Source

amqp.lisp.

Function: ssl-socket-set-key (socket cert key)

Set the client key from a buffer.

SOCKET - An SSL/TLS socket object.
CERT - Path to the client certificate in PEM format. KEY - Path to the client key in PEM format.

Package

cl-rabbit.

Source

amqp.lisp.

Function: ssl-socket-set-key-buffer (socket cert key)

Set the client key from a buffer.

SOCKET - An SSL/TLS socket object.
CERT - Path to the client certificate in PEM format.
KEY - An array of type (UNSIGNED-BYTE 8) containing client key in PEM format.

Package

cl-rabbit.

Source

amqp.lisp.

Function: ssl-socket-set-verify (socket verify-p)

Enable or disable peer verification.

If peer verification is enabled then the common name in the server certificate must match the server name. Peer verification is enabled by default.

SOCKET - An SSL/TLS socket object.
VERIFY-P - verify Enable or disable peer verification.

Package

cl-rabbit.

Source

amqp.lisp.

Function: tcp-socket-new (conn)

Create a new TCP socket.
Call CONNECTION-CLOSE to release socket resources.

Package

cl-rabbit.

Source

amqp.lisp.

Function: tx-commit (conn channel)
Package

cl-rabbit.

Source

amqp.lisp.

Function: tx-rollback (conn channel)
Package

cl-rabbit.

Source

amqp.lisp.

Function: tx-select (conn channel)
Package

cl-rabbit.

Source

amqp.lisp.

Function: version ()
Package

cl-rabbit.

Source

amqp.lisp.


6.1.3 Generic functions

Generic Reader: content-body-frame/body (object)
Package

cl-rabbit.

Methods
Reader Method: content-body-frame/body ((content-body-frame content-body-frame))

Body payload raw content.

Source

amqp.lisp.

Target Slot

body.

Generic Reader: content-body-frame/channel (object)
Package

cl-rabbit.

Methods
Reader Method: content-body-frame/channel ((content-body-frame content-body-frame))

Rabbitmq channel.

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: content-header-frame/body-size (object)
Package

cl-rabbit.

Methods
Reader Method: content-header-frame/body-size ((content-header-frame content-header-frame))

Body payload size in bytes.

Source

amqp.lisp.

Target Slot

body-size.

Generic Reader: content-header-frame/channel (object)
Package

cl-rabbit.

Methods
Reader Method: content-header-frame/channel ((content-header-frame content-header-frame))

channel.

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: content-header-frame/class-id (object)
Package

cl-rabbit.

Methods
Reader Method: content-header-frame/class-id ((content-header-frame content-header-frame))

AMQP class id.

Source

amqp.lisp.

Target Slot

class-id.

Generic Reader: content-header-frame/properties (object)
Package

cl-rabbit.

Methods
Reader Method: content-header-frame/properties ((content-header-frame content-header-frame))

Payload properties.

Source

amqp.lisp.

Target Slot

properties.

Generic Reader: envelope/channel (object)
Package

cl-rabbit.

Methods
Reader Method: envelope/channel ((envelope envelope))

automatically generated reader method

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: envelope/consumer-tag (object)
Package

cl-rabbit.

Methods
Reader Method: envelope/consumer-tag ((envelope envelope))

automatically generated reader method

Source

amqp.lisp.

Target Slot

consumer-tag.

Generic Reader: envelope/delivery-tag (object)
Package

cl-rabbit.

Methods
Reader Method: envelope/delivery-tag ((envelope envelope))

automatically generated reader method

Source

amqp.lisp.

Target Slot

delivery-tag.

Generic Reader: envelope/exchange (object)
Package

cl-rabbit.

Methods
Reader Method: envelope/exchange ((envelope envelope))

automatically generated reader method

Source

amqp.lisp.

Target Slot

exchange.

Generic Reader: envelope/message (object)
Package

cl-rabbit.

Methods
Reader Method: envelope/message ((envelope envelope))

automatically generated reader method

Source

amqp.lisp.

Target Slot

message.

Generic Reader: envelope/routing-key (object)
Package

cl-rabbit.

Methods
Reader Method: envelope/routing-key ((envelope envelope))

automatically generated reader method

Source

amqp.lisp.

Target Slot

routing-key.

Generic Reader: message/body (object)
Package

cl-rabbit.

Methods
Reader Method: message/body ((message message))

automatically generated reader method

Source

amqp.lisp.

Target Slot

body.

Generic Reader: message/properties (object)
Package

cl-rabbit.

Methods
Reader Method: message/properties ((message message))

automatically generated reader method

Source

amqp.lisp.

Target Slot

properties.

Generic Reader: method-frame-basic-acknowledgment/channel (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-acknowledgment/channel ((method-frame-basic-acknowledgment method-frame-basic-acknowledgment))

automatically generated reader method

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: method-frame-basic-acknowledgment/delivery-tag (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-acknowledgment/delivery-tag ((method-frame-basic-acknowledgment method-frame-basic-acknowledgment))

Sequence number of the confirmed message.

Source

amqp.lisp.

Target Slot

delivery-tag.

Generic Reader: method-frame-basic-acknowledgment/id (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-acknowledgment/id ((method-frame-basic-acknowledgment method-frame-basic-acknowledgment))

Basic acknowledgment method ID.

Source

amqp.lisp.

Target Slot

id.

Generic Reader: method-frame-basic-acknowledgment/multiplep (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-acknowledgment/multiplep ((method-frame-basic-acknowledgment method-frame-basic-acknowledgment))

t when acknowledge messages up to and including the one with the sequence in delivery-tag.

Source

amqp.lisp.

Target Slot

multiplep.

Generic Reader: method-frame-basic-deliver/channel (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-deliver/channel ((method-frame-basic-deliver method-frame-basic-deliver))

automatically generated reader method

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: method-frame-basic-deliver/consumer-tag (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-deliver/consumer-tag ((method-frame-basic-deliver method-frame-basic-deliver))

Identifier for the consumer, valid within the current channel. The server-assigned and channel-specific delivery tag

Source

amqp.lisp.

Target Slot

consumer-tag.

Generic Reader: method-frame-basic-deliver/delivery-tag (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-deliver/delivery-tag ((method-frame-basic-deliver method-frame-basic-deliver))

Sequence number of confirmed message.

Source

amqp.lisp.

Target Slot

delivery-tag.

Generic Reader: method-frame-basic-deliver/exchange (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-deliver/exchange ((method-frame-basic-deliver method-frame-basic-deliver))

Exchange name.

Source

amqp.lisp.

Target Slot

exchange.

Generic Reader: method-frame-basic-deliver/id (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-deliver/id ((method-frame-basic-deliver method-frame-basic-deliver))

Basic deliver method ID.

Source

amqp.lisp.

Target Slot

id.

Generic Reader: method-frame-basic-deliver/redeliveredp (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-deliver/redeliveredp ((method-frame-basic-deliver method-frame-basic-deliver))

t when message is redelivered, after it was not successfully acknowledged by a consumer.

Source

amqp.lisp.

Target Slot

redeliveredp.

Generic Reader: method-frame-basic-deliver/routing-key (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-deliver/routing-key ((method-frame-basic-deliver method-frame-basic-deliver))

Message routing key.

Source

amqp.lisp.

Target Slot

routing-key.

Generic Reader: method-frame-basic-negative-acknowledgment/channel (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-negative-acknowledgment/channel ((method-frame-basic-negative-acknowledgment method-frame-basic-negative-acknowledgment))

automatically generated reader method

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: method-frame-basic-negative-acknowledgment/id (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-negative-acknowledgment/id ((method-frame-basic-negative-acknowledgment method-frame-basic-negative-acknowledgment))

Basic negative acknowledgment method ID.

Source

amqp.lisp.

Target Slot

id.

Generic Reader: method-frame-basic-negative-acknowledgment/multiplep (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-negative-acknowledgment/multiplep ((method-frame-basic-negative-acknowledgment method-frame-basic-negative-acknowledgment))

t when acknowledge messages up to and including the one with the sequence in delivery-tag.

Source

amqp.lisp.

Target Slot

multiplep.

Generic Reader: method-frame-basic-negative-acknowledgment/requeuep (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-negative-acknowledgment/requeuep ((method-frame-basic-negative-acknowledgment method-frame-basic-negative-acknowledgment))

t when instructing the broker to requeue message. this slot should be ignored when publisher receives negative acknowledgment from broker.

Source

amqp.lisp.

Target Slot

requeuep.

Generic Reader: method-frame-basic-return/channel (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-return/channel ((method-frame-basic-return method-frame-basic-return))

automatically generated reader method

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: method-frame-basic-return/exchange (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-return/exchange ((method-frame-basic-return method-frame-basic-return))

Exchange name.

Source

amqp.lisp.

Target Slot

exchange.

Generic Reader: method-frame-basic-return/id (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-return/id ((method-frame-basic-return method-frame-basic-return))

Basic return method ID.

Source

amqp.lisp.

Target Slot

id.

Generic Reader: method-frame-basic-return/reply-code (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-return/reply-code ((method-frame-basic-return method-frame-basic-return))

The AMQ reply code.

Source

amqp.lisp.

Target Slot

reply-code.

Generic Reader: method-frame-basic-return/reply-text (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-return/reply-text ((method-frame-basic-return method-frame-basic-return))

The localized reply text. this text can be logged as an aid to resolving issues.

Source

amqp.lisp.

Target Slot

reply-text.

Generic Reader: method-frame-basic-return/routing-key (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-return/routing-key ((method-frame-basic-return method-frame-basic-return))

Message routing key.

Source

amqp.lisp.

Target Slot

routing-key.

Generic Reader: method-frame-error/channel (condition)
Package

cl-rabbit.

Methods
Reader Method: method-frame-error/channel ((condition method-frame-error))
Source

amqp.lisp.

Target Slot

channel.

Generic Reader: method-frame-error/method-id (condition)
Package

cl-rabbit.

Methods
Reader Method: method-frame-error/method-id ((condition method-frame-error))
Source

amqp.lisp.

Target Slot

method-id.

Generic Reader: rabbitmq-library-error/error-code (condition)
Package

cl-rabbit.

Methods
Reader Method: rabbitmq-library-error/error-code ((condition rabbitmq-library-error))
Source

amqp.lisp.

Target Slot

error-code.

Generic Reader: rabbitmq-library-error/error-description (condition)
Package

cl-rabbit.

Methods
Reader Method: rabbitmq-library-error/error-description ((condition rabbitmq-library-error))
Source

amqp.lisp.

Target Slot

error-description.

Generic Reader: rabbitmq-server-error/message (condition)
Package

cl-rabbit.

Methods
Reader Method: rabbitmq-server-error/message ((condition rabbitmq-server-error))
Source

amqp.lisp.

Target Slot

message.

Generic Reader: rabbitmq-server-error/reply-code (condition)
Package

cl-rabbit.

Methods
Reader Method: rabbitmq-server-error/reply-code ((condition rabbitmq-server-error))
Source

amqp.lisp.

Target Slot

reply-code.


6.1.4 Standalone methods

Method: print-object ((obj content-header-frame) stream)
Source

amqp.lisp.

Method: print-object ((obj method-frame-basic-negative-acknowledgment) stream)
Source

amqp.lisp.

Method: print-object ((obj method-frame-basic-return) stream)
Source

amqp.lisp.

Method: print-object ((obj method-frame-basic-acknowledgment) stream)
Source

amqp.lisp.

Method: print-object ((obj method-frame-basic-deliver) stream)
Source

amqp.lisp.

Method: print-object ((obj content-body-frame) stream)
Source

amqp.lisp.

Method: print-object ((obj envelope) stream)
Source

amqp.lisp.

Method: print-object ((obj message) stream)
Source

amqp.lisp.


6.1.5 Conditions

Condition: method-frame-error

Error signaled when an unhandled method type recieved in a method frame.

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

rabbitmq-error.

Direct methods
Direct slots
Slot: channel
Initargs

:channel

Readers

method-frame-error/channel.

Writers

This slot is read-only.

Slot: method-id
Initargs

:method-id

Readers

method-frame-error/method-id.

Writers

This slot is read-only.

Condition: rabbitmq-error

General superclass for rabbitmq errors

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

error.

Direct subclasses
Condition: rabbitmq-library-error

Error that is raised when an AMQP call fails

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

rabbitmq-error.

Direct methods
Direct slots
Slot: error-code

The response type as returned by the AMQP call

Initargs

:error-code

Readers

rabbitmq-library-error/error-code.

Writers

This slot is read-only.

Slot: error-description
Initargs

:error-description

Readers

rabbitmq-library-error/error-description.

Writers

This slot is read-only.

Condition: rabbitmq-server-error

Error that is raised when the server reports an error condition

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

rabbitmq-error.

Direct methods
Direct slots
Slot: method
Package

common-lisp.

Initargs

:method

Readers

rabbitmq-server-error/method.

Writers

This slot is read-only.

Slot: reply-code
Initform

(quote 0)

Initargs

:reply-code

Readers

rabbitmq-server-error/reply-code.

Writers

This slot is read-only.

Slot: message
Initform

(quote "unknown error")

Initargs

:message

Readers

rabbitmq-server-error/message.

Writers

This slot is read-only.


6.1.6 Classes

Class: content-body-frame

Content body frame

Package

cl-rabbit.

Source

amqp.lisp.

Direct methods
Direct slots
Slot: channel

Rabbitmq channel.

Type

integer

Initargs

:channel

Readers

content-body-frame/channel.

Writers

This slot is read-only.

Slot: body

Body payload raw content.

Type

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

Initargs

:body

Readers

content-body-frame/body.

Writers

This slot is read-only.

Class: content-header-frame

Content header frame.

Package

cl-rabbit.

Source

amqp.lisp.

Direct methods
Direct slots
Slot: channel

channel.

Type

integer

Initargs

:channel

Readers

content-header-frame/channel.

Writers

This slot is read-only.

Slot: class-id

AMQP class id.

Type

integer

Initargs

:class-id

Readers

content-header-frame/class-id.

Writers

This slot is read-only.

Slot: body-size

Body payload size in bytes.

Type

integer

Initargs

:body-size

Readers

content-header-frame/body-size.

Writers

This slot is read-only.

Slot: properties

Payload properties.

Type

list

Initargs

:properties

Readers

content-header-frame/properties.

Writers

This slot is read-only.

Class: envelope
Package

cl-rabbit.

Source

amqp.lisp.

Direct methods
Direct slots
Slot: channel
Type

integer

Initargs

:channel

Readers

envelope/channel.

Writers

This slot is read-only.

Slot: consumer-tag
Type

string

Initargs

:consumer-tag

Readers

envelope/consumer-tag.

Writers

This slot is read-only.

Slot: delivery-tag
Type

integer

Initargs

:delivery-tag

Readers

envelope/delivery-tag.

Writers

This slot is read-only.

Slot: exchange
Type

string

Initargs

:exchange

Readers

envelope/exchange.

Writers

This slot is read-only.

Slot: routing-key
Type

string

Initargs

:routing-key

Readers

envelope/routing-key.

Writers

This slot is read-only.

Slot: message
Type

cl-rabbit:message

Initargs

:message

Readers

envelope/message.

Writers

This slot is read-only.

Class: message
Package

cl-rabbit.

Source

amqp.lisp.

Direct methods
Direct slots
Slot: body
Type

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

Initargs

:body

Readers

message/body.

Writers

This slot is read-only.

Slot: properties
Type

list

Initargs

:properties

Readers

message/properties.

Writers

This slot is read-only.

Class: method-frame-basic-acknowledgment

Basic acknowledgment method frame.

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

method-frame.

Direct methods
Direct slots
Slot: channel
Readers

method-frame-basic-acknowledgment/channel.

Writers

This slot is read-only.

Slot: id

Basic acknowledgment method ID.

Allocation

:class

Initform

3932240

Readers

method-frame-basic-acknowledgment/id.

Writers

This slot is read-only.

Slot: delivery-tag

Sequence number of the confirmed message.

Type

integer

Initargs

:delivery-tag

Readers

method-frame-basic-acknowledgment/delivery-tag.

Writers

This slot is read-only.

Slot: multiplep

t when acknowledge messages up to and including the one with the sequence in delivery-tag.

Initargs

:multiplep

Readers

method-frame-basic-acknowledgment/multiplep.

Writers

This slot is read-only.

Class: method-frame-basic-deliver

Basic deliver method frame.

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

method-frame.

Direct methods
Direct slots
Slot: channel
Readers

method-frame-basic-deliver/channel.

Writers

This slot is read-only.

Slot: id

Basic deliver method ID.

Allocation

:class

Initform

3932220

Readers

method-frame-basic-deliver/id.

Writers

This slot is read-only.

Slot: consumer-tag

Identifier for the consumer, valid within the current channel. The server-assigned and channel-specific delivery tag

Type

string

Initargs

:consumer-tag

Readers

method-frame-basic-deliver/consumer-tag.

Writers

This slot is read-only.

Slot: delivery-tag

Sequence number of confirmed message.

Type

integer

Initargs

:delivery-tag

Readers

method-frame-basic-deliver/delivery-tag.

Writers

This slot is read-only.

Slot: redeliveredp

t when message is redelivered, after it was not successfully acknowledged by a consumer.

Initargs

:redeliveredp

Readers

method-frame-basic-deliver/redeliveredp.

Writers

This slot is read-only.

Slot: exchange

Exchange name.

Type

string

Initargs

:exchange

Readers

method-frame-basic-deliver/exchange.

Writers

This slot is read-only.

Slot: routing-key

Message routing key.

Type

string

Initargs

:routing-key

Readers

method-frame-basic-deliver/routing-key.

Writers

This slot is read-only.

Class: method-frame-basic-negative-acknowledgment

Basic negative acknowledgment (nack) method frame.

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

method-frame.

Direct methods
Direct slots
Slot: channel
Readers

method-frame-basic-negative-acknowledgment/channel.

Writers

This slot is read-only.

Slot: id

Basic negative acknowledgment method ID.

Allocation

:class

Initform

3932280

Readers

method-frame-basic-negative-acknowledgment/id.

Writers

This slot is read-only.

Slot: delivery-tag

Sequence number of the negatively confirmed message.

Type

integer

Initargs

:delivery-tag

Readers

method-frame-basic-negative-acknowledgment/delivery-tag.

Writers

This slot is read-only.

Slot: multiplep

t when acknowledge messages up to and including the one with the sequence in delivery-tag.

Initargs

:multiplep

Readers

method-frame-basic-negative-acknowledgment/multiplep.

Writers

This slot is read-only.

Slot: requeuep

t when instructing the broker to requeue message. this slot should be ignored when publisher receives negative acknowledgment from broker.

Initargs

:requeuep

Readers

method-frame-basic-negative-acknowledgment/requeuep.

Writers

This slot is read-only.

Class: method-frame-basic-return

Basic return method frame.

Package

cl-rabbit.

Source

amqp.lisp.

Direct superclasses

method-frame.

Direct methods
Direct slots
Slot: channel
Readers

method-frame-basic-return/channel.

Writers

This slot is read-only.

Slot: id

Basic return method ID.

Allocation

:class

Initform

3932210

Readers

method-frame-basic-return/id.

Writers

This slot is read-only.

Slot: reply-code

The AMQ reply code.

Type

integer

Initargs

:reply-code

Readers

method-frame-basic-return/reply-code.

Writers

This slot is read-only.

Slot: reply-text

The localized reply text. this text can be logged as an aid to resolving issues.

Type

string

Initargs

:reply-text

Readers

method-frame-basic-return/reply-text.

Writers

This slot is read-only.

Slot: exchange

Exchange name.

Type

string

Initargs

:exchange

Readers

method-frame-basic-return/exchange.

Writers

This slot is read-only.

Slot: routing-key

Message routing key.

Type

string

Initargs

:routing-key

Readers

method-frame-basic-return/routing-key.

Writers

This slot is read-only.


6.2 Internals


6.2.1 Special variables

Special Variable: *field-kind-types*
Package

cl-rabbit.

Source

misc.lisp.

Special Variable: *props-mapping*
Package

cl-rabbit.

Source

amqp.lisp.


6.2.2 Macros

Macro: print-unreadable-safely ((&rest slots) object stream &body body)

A version of PRINT-UNREADABLE-OBJECT and WITH-SLOTS that is safe to use with unbound slots

Package

cl-rabbit.

Source

misc.lisp.

Macro: unwind-when-fail (form &body unwind-forms)
Package

cl-rabbit.

Source

misc.lisp.

Macro: with-amqp-table ((table values) &body body)
Package

cl-rabbit.

Source

misc.lisp.

Macro: with-bytes-string ((symbol string) &body body)
Package

cl-rabbit.

Source

misc.lisp.

Macro: with-bytes-strings ((&rest definitions) &body body)
Package

cl-rabbit.

Source

misc.lisp.

Macro: with-bytes-struct ((symbol value) &body body)
Package

cl-rabbit.

Source

misc.lisp.

Macro: with-foreign-buffer-from-byte-array ((sym buffer) &body body)
Package

cl-rabbit.

Source

misc.lisp.

Macro: with-foreign-timeval ((symbol time) &body body)
Package

cl-rabbit.

Source

misc.lisp.

Macro: with-state ((state conn) &body body)
Package

cl-rabbit.

Source

amqp.lisp.


6.2.3 Ordinary functions

Function: %check-client-version (name major minor patch)
Package

cl-rabbit.

Source

amqp.lisp.

Function: allocate-amqp-table (values)
Package

cl-rabbit.

Source

misc.lisp.

Function: amqp-basic-ack (state channel delivery-tag multiple)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-basic-cancel (state channel consumer-tag)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-basic-consume (state channel queue consumer-tag no-local no-ack exclusive arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-basic-get (state channel queue no-ack)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-basic-nack (state channel delivery-tag multiple requeue)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-basic-publish (state channel exchange routing-key mandatory immediate properties body)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-basic-qos (state channel prefetch_size prefetch_count global)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-basic-reject (state channel delivery-tag requeue)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-channel-close (state channel code)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-channel-flow (state channel active)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-channel-open (state channel)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-confirm-select (state channel)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-connection-close (state code)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-consume-message (state envelope timeout flags)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-cstring-bytes (cstr)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-data-in-buffer (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-destroy-connection (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-destroy-envelope (envelope)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-error-string2 (err)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-exchange-bind (state channel destination source routing-key arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-exchange-declare-0-5 (state channel exchange type passive durable arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-exchange-declare-0-6 (state channel exchange type passive durable auto-delete internal arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-exchange-delete (state channel exchange if-unused)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-exchange-unbind (state channel destination source routing-key arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-frames-enqueued (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-get-rpc-reply (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-get-sockfd (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-login-sasl-plain (state vhost channel-max frame-max heartbeat sasl-method user password)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-login-sasl-plain-with-properties (state vhost channel-max frame-max heartbeat properties sasl-method user password)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-maybe-release-buffers (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-maybe-release-buffers-on-channel (state channel)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-new-connection ()
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-queue-bind (state channel queue exchange routing-key arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-queue-declare (state channel queue passive durable exclusive auto-delete arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-queue-delete (state channel queue if-unused if-empty)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-queue-purge (state channel queue)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-queue-unbind (state channel queue exchange routing-key arguments)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-send-frame (state frame)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-send-method (state channel id decoded)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-set-initialize-ssl-library (init)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-simple-wait-frame (state decoded-frame)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-simple-wait-frame-noblock (state decoded-frame tv)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-socket-get-sockfd (self)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-socket-open (self host port)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-ssl-socket-new (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-ssl-socket-set-cacert (socket cacert)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-ssl-socket-set-key (socket cert key)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-ssl-socket-set-key-buffer (socket cert key)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-ssl-socket-set-verify (socket verify)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-table->lisp (table)
Package

cl-rabbit.

Source

misc.lisp.

Function: amqp-tcp-socket-new (state)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-tcp-socket-set-sockfd (self sockfd)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-tx-commit (state channel)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-tx-rollback (state channel)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-tx-select (state channel)
Package

cl-rabbit.

Source

functions.lisp.

Function: amqp-version ()
Package

cl-rabbit.

Source

functions.lisp.

Function: array-to-foreign-char-array (array)
Package

cl-rabbit.

Source

misc.lisp.

Function: bytes->array (bytes)
Package

cl-rabbit.

Source

misc.lisp.

Function: bytes->string (bytes)
Package

cl-rabbit.

Source

misc.lisp.

Function: bzero-ptr (ptr size)
Package

cl-rabbit.

Source

misc.lisp.

Function: call-with-amqp-table (fn values)
Package

cl-rabbit.

Source

misc.lisp.

Function: call-with-timeval (fn time)
Package

cl-rabbit.

Source

misc.lisp.

Function: check-client-version (major minor patch)
Package

cl-rabbit.

Source

amqp.lisp.

Function: confirm-channel-close (state channel)
Package

cl-rabbit.

Source

amqp.lisp.

Function: connection-close (conn &key code)

Closes the entire connection.
Implicitly closes all channels and informs the broker the connection
is being closed, after receiving acknowldgement from the broker it closes
the socket.

Parameters:
CONN - the connection object
CODE - the reason code for closing the connection. Defaults to AMQP_REPLY_SUCCESS.

Package

cl-rabbit.

Source

amqp.lisp.

Function: convert-to-bytes (array)
Package

cl-rabbit.

Source

misc.lisp.

Function: data-in-buffer (conn)
Package

cl-rabbit.

Source

amqp.lisp.

Function: fail-if-null (ptr)
Package

cl-rabbit.

Source

amqp.lisp.

Function: fill-in-properties-alist (properties)
Package

cl-rabbit.

Source

amqp.lisp.

Function: frames-enqueued (conn)
Package

cl-rabbit.

Source

amqp.lisp.

Function: get-sockfd (conn)
Package

cl-rabbit.

Source

amqp.lisp.

Function: load-properties-to-alist (props)
Package

cl-rabbit.

Source

amqp.lisp.

Function: make-content-body-frame (channel body)

Returns fresh object of CONTENT-BODY-FRAME.

Arguments:

CHANNEL => INTEGER, Rabbitmq channel. BODY => ARRAY of BYTES, contents.

Package

cl-rabbit.

Source

amqp.lisp.

Function: make-content-header-frame (channel class-id body-size properties)

Returns fresh object of CONTENT-HEADER-FRAME

Arguments:

CHANNEL => INTEGER, Rabbitmq channel. CLASS-ID => INTEGER, AMQP class id.
BODY-SIZE => INTEGER, Body payload size in bytes. PROPERTIES => ALIST, Payload properties.

Package

cl-rabbit.

Source

amqp.lisp.

Function: make-envelope-message (value)
Package

cl-rabbit.

Source

amqp.lisp.

Function: make-method-frame-basic-acknowledgment (channel delivery-tag multiplep)

Returns fresh object of METHOD-FRAME-BASIC-ACKNOWLEDGMENT.

Arguments:

CHANNEL => INTEGER, Rabbitmq channel.
DELIVERY-TAG => INTEGER, sequence number of confirmed message.
MULTIPLEP => BOOLEAN, t when acknowledge messages up to and including the one with the sequence in delivery-tag.

Package

cl-rabbit.

Source

amqp.lisp.

Function: make-method-frame-basic-deliver (channel consumer-tag delivery-tag redeliveredp exchange routing-key)

Returns fresh object of METHOD-FRAME-BASIC-DELIVER.

Arguments:

CHANNEL => INTEGER, Rabbitmq channel.
CONSUMER-TAG => STRING, identifier for the consumer, valid within the current channel. DELIVERY-TAG => INTEGER, sequence number of confirmed message.
REDELIVEREDP => BOOLEAN, t when message is redelivered after it was not successfully acknowledged by a consumer.
EXCHANGE => STRING, Exchange name.
ROUTING-KEY => STRING, Message routing key.

Package

cl-rabbit.

Source

amqp.lisp.

Function: make-method-frame-basic-negative-acknowledgment (channel delivery-tag multiplep requeuep)

Returns fresh object of METHOD-FRAME-BASIC-NEGATIVE-ACKNOWLEDGMENT

Arguments:

CHANNEL => INTEGER, Rabbitmq channel.
DELIVERY-TAG => INTEGER, sequence number of confirmed message.
MULTIPLEP => BOOLEAN, t when acknowledge messages up to and including the one with the sequence in delivery-tag. REQUEUEP => BOOLEAN, t when instructing the broker to requeue message. this slot should be
ignored when publisher receives negative acknowledgment from broker.

Package

cl-rabbit.

Source

amqp.lisp.

Function: make-method-frame-basic-return (channel reply-code reply-text exchange routing-key)

Returns fresh object of METHOD-FRAME-BASIC-RETURN.

Arguments:

CHANNEL => INTEGER, Rabbitmq channel.
REPLY-CODE => INTEGER, AMQ reply code.
REPLY-TEXT => STRING, localized reply text. this text can be logged as an aid to resolving issues. EXCHANGE => STRING, Rabbitmq exchange name.
ROUTING-KEY => STRING, Message routing key.

Package

cl-rabbit.

Source

amqp.lisp.

Function: maybe-release-buffers (state)
Package

cl-rabbit.

Source

amqp.lisp.

Function: raise-method-frame-error (channel method-id)

Signals an error of method

Package

cl-rabbit.

Source

amqp.lisp.

Function: raise-rabbitmq-library-error (code)
Package

cl-rabbit.

Source

amqp.lisp.

Function: raise-rabbitmq-server-error (state channel result)
Package

cl-rabbit.

Source

amqp.lisp.

Function: typed-value->lisp (value)
Package

cl-rabbit.

Source

misc.lisp.

Function: update-product-name-in-table (table)
Package

cl-rabbit.

Source

amqp.lisp.

Function: verify-rpc-framing-call (state channel result)
Package

cl-rabbit.

Source

amqp.lisp.

Function: verify-rpc-reply (state channel result)
Package

cl-rabbit.

Source

amqp.lisp.

Function: verify-status (status)
Package

cl-rabbit.

Source

amqp.lisp.


6.2.4 Generic functions

Generic Reader: connection/closed-p (object)
Package

cl-rabbit.

Methods
Reader Method: connection/closed-p ((connection connection))

automatically generated reader method

Source

amqp.lisp.

Target Slot

closed-p.

Generic Writer: (setf connection/closed-p) (object)
Package

cl-rabbit.

Methods
Writer Method: (setf connection/closed-p) ((connection connection))

automatically generated writer method

Source

amqp.lisp.

Target Slot

closed-p.

Generic Reader: connection/native-connection (object)
Package

cl-rabbit.

Methods
Reader Method: connection/native-connection ((connection connection))

automatically generated reader method

Source

amqp.lisp.

Target Slot

conn.

Generic Function: foreign-method->class (method-id method-struct channel)
Package

cl-rabbit.

Methods
Method: foreign-method->class (method-id method-struct channel)

Returns t when METHOD-ID equals CONFIRM-SELECT-OK-METHOD otherwise signals and error.

Arguments:

METHOD-ID => INTEGER, AMQP basic return method id.
METHOD-STRUCT => CFFI FOREIGN POINTER, decoded method frame.
CHANNEL => INTEGER, Rabbitmq channel.

Source

amqp.lisp.

Method: foreign-method->class ((method-id (eql 3932220)) method-struct channel)

Returns fresh object of METHOD-FRAME-BASIC-DELIVER filled with data from foreign METHOD-STRUCT.

Arguments:

METHOD-ID => CONSTANT, AMQP basic deliver method id.
METHOD-STRUCT => CFFI FOREIGN POINTER, decoded basic deliver method frame.
CHANNEL => INTEGER, Rabbitmq channel.

Source

amqp.lisp.

Method: foreign-method->class ((method-id (eql 3932210)) method-struct channel)

Returns fresh object of METHOD-FRAME-BASIC-RETURN filled with data from foreign METHOD-STRUCT.

Arguments:

METHOD-ID => CONSTANT, AMQP basic return method id.
METHOD-STRUCT => CFFI FOREIGN POINTER, decoded basic return method frame.
CHANNEL => INTEGER, Rabbitmq channel.

Source

amqp.lisp.

Method: foreign-method->class ((method-id (eql 3932280)) method-struct channel)

Returns fresh object of METHOD-FRAME-BASIC-NEGATIVE-ACKNOWLEDGMENT filled with data from foreign METHOD-STRUCT.

Arguments:

METHOD-ID => CONSTANT, AMQP basic acknowledgment method id.
METHOD-STRUCT => CFFI FOREIGN POINTER, decoded negative basic acknowledgment method frame.
CHANNEL => INTEGER, Rabbitmq channel.

Source

amqp.lisp.

Method: foreign-method->class ((method-id (eql 3932240)) method-struct channel)

Returns fresh object of METHOD-FRAME-BASIC-ACKNOWLEDGMENT filled with data from foreign METHOD-STRUCT.

Arguments:

METHOD-ID => CONSTANT, AMQP basic acknowledgment method id.
METHOD-STRUCT => CFFI FOREIGN POINTER, decoded basic acknowledgment method frame.
CHANNEL => INTEGER, Rabbitmq channel.

Source

amqp.lisp.

Generic Reader: method-frame-basic-negative-acknowledgment/delivery-tag (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame-basic-negative-acknowledgment/delivery-tag ((method-frame-basic-negative-acknowledgment method-frame-basic-negative-acknowledgment))

Sequence number of the negatively confirmed message.

Source

amqp.lisp.

Target Slot

delivery-tag.

Generic Reader: method-frame/channel (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame/channel ((method-frame method-frame))

Frame channel.

Source

amqp.lisp.

Target Slot

channel.

Generic Reader: method-frame/id (object)
Package

cl-rabbit.

Methods
Reader Method: method-frame/id ((method-frame method-frame))

Method id.

Source

amqp.lisp.

Target Slot

id.

Generic Reader: rabbitmq-server-error/method (condition)
Package

cl-rabbit.

Methods
Reader Method: rabbitmq-server-error/method ((condition rabbitmq-server-error))
Source

amqp.lisp.

Target Slot

method.


6.2.5 Classes

Class: connection

Class representing a connection to a RabbitMQ server.

Package

cl-rabbit.

Source

amqp.lisp.

Direct methods
Direct slots
Slot: conn
Type

cffi-sys:foreign-pointer

Initargs

:conn

Readers

connection/native-connection.

Writers

This slot is read-only.

Slot: closed-p
Readers

connection/closed-p.

Writers

(setf connection/closed-p).

Class: method-frame

Parent class for all method frames.

Package

cl-rabbit.

Source

amqp.lisp.

Direct subclasses
Direct methods
Direct slots
Slot: channel

Frame channel.

Type

integer

Initargs

:channel

Readers

method-frame/channel.

Writers

This slot is read-only.

Slot: id

Method id.

Type

integer

Readers

method-frame/id.

Writers

This slot is read-only.


Appendix A Indexes


A.1 Concepts


A.2 Functions

Jump to:   %   (  
A   B   C   D   E   F   G   L   M   N   P   Q   R   S   T   U   V   W  
Index Entry  Section

%
%check-client-version: Private ordinary functions

(
(setf connection/closed-p): Private generic functions
(setf connection/closed-p): Private generic functions

A
allocate-amqp-table: Private ordinary functions
amqp-basic-ack: Private ordinary functions
amqp-basic-cancel: Private ordinary functions
amqp-basic-consume: Private ordinary functions
amqp-basic-get: Private ordinary functions
amqp-basic-nack: Private ordinary functions
amqp-basic-publish: Private ordinary functions
amqp-basic-qos: Private ordinary functions
amqp-basic-reject: Private ordinary functions
amqp-channel-close: Private ordinary functions
amqp-channel-flow: Private ordinary functions
amqp-channel-open: Private ordinary functions
amqp-confirm-select: Private ordinary functions
amqp-connection-close: Private ordinary functions
amqp-consume-message: Private ordinary functions
amqp-cstring-bytes: Private ordinary functions
amqp-data-in-buffer: Private ordinary functions
amqp-destroy-connection: Private ordinary functions
amqp-destroy-envelope: Private ordinary functions
amqp-error-string2: Private ordinary functions
amqp-exchange-bind: Private ordinary functions
amqp-exchange-declare-0-5: Private ordinary functions
amqp-exchange-declare-0-6: Private ordinary functions
amqp-exchange-delete: Private ordinary functions
amqp-exchange-unbind: Private ordinary functions
amqp-frames-enqueued: Private ordinary functions
amqp-get-rpc-reply: Private ordinary functions
amqp-get-sockfd: Private ordinary functions
amqp-login-sasl-plain: Private ordinary functions
amqp-login-sasl-plain-with-properties: Private ordinary functions
amqp-maybe-release-buffers: Private ordinary functions
amqp-maybe-release-buffers-on-channel: Private ordinary functions
amqp-new-connection: Private ordinary functions
amqp-queue-bind: Private ordinary functions
amqp-queue-declare: Private ordinary functions
amqp-queue-delete: Private ordinary functions
amqp-queue-purge: Private ordinary functions
amqp-queue-unbind: Private ordinary functions
amqp-send-frame: Private ordinary functions
amqp-send-method: Private ordinary functions
amqp-set-initialize-ssl-library: Private ordinary functions
amqp-simple-wait-frame: Private ordinary functions
amqp-simple-wait-frame-noblock: Private ordinary functions
amqp-socket-get-sockfd: Private ordinary functions
amqp-socket-open: Private ordinary functions
amqp-ssl-socket-new: Private ordinary functions
amqp-ssl-socket-set-cacert: Private ordinary functions
amqp-ssl-socket-set-key: Private ordinary functions
amqp-ssl-socket-set-key-buffer: Private ordinary functions
amqp-ssl-socket-set-verify: Private ordinary functions
amqp-table->lisp: Private ordinary functions
amqp-tcp-socket-new: Private ordinary functions
amqp-tcp-socket-set-sockfd: Private ordinary functions
amqp-tx-commit: Private ordinary functions
amqp-tx-rollback: Private ordinary functions
amqp-tx-select: Private ordinary functions
amqp-version: Private ordinary functions
array-to-foreign-char-array: Private ordinary functions

B
basic-ack: Public ordinary functions
basic-cancel: Public ordinary functions
basic-consume: Public ordinary functions
basic-nack: Public ordinary functions
basic-publish: Public ordinary functions
basic-qos: Public ordinary functions
bytes->array: Private ordinary functions
bytes->string: Private ordinary functions
bzero-ptr: Private ordinary functions

C
call-with-amqp-table: Private ordinary functions
call-with-timeval: Private ordinary functions
channel-close: Public ordinary functions
channel-flow: Public ordinary functions
channel-open: Public ordinary functions
check-client-version: Private ordinary functions
confirm-channel-close: Private ordinary functions
confirm-select: Public ordinary functions
connection-close: Private ordinary functions
connection/closed-p: Private generic functions
connection/closed-p: Private generic functions
connection/native-connection: Private generic functions
connection/native-connection: Private generic functions
consume-message: Public ordinary functions
content-body-frame/body: Public generic functions
content-body-frame/body: Public generic functions
content-body-frame/channel: Public generic functions
content-body-frame/channel: Public generic functions
content-header-frame/body-size: Public generic functions
content-header-frame/body-size: Public generic functions
content-header-frame/channel: Public generic functions
content-header-frame/channel: Public generic functions
content-header-frame/class-id: Public generic functions
content-header-frame/class-id: Public generic functions
content-header-frame/properties: Public generic functions
content-header-frame/properties: Public generic functions
convert-to-bytes: Private ordinary functions

D
data-in-buffer: Private ordinary functions
destroy-connection: Public ordinary functions

E
envelope/channel: Public generic functions
envelope/channel: Public generic functions
envelope/consumer-tag: Public generic functions
envelope/consumer-tag: Public generic functions
envelope/delivery-tag: Public generic functions
envelope/delivery-tag: Public generic functions
envelope/exchange: Public generic functions
envelope/exchange: Public generic functions
envelope/message: Public generic functions
envelope/message: Public generic functions
envelope/routing-key: Public generic functions
envelope/routing-key: Public generic functions
exchange-bind: Public ordinary functions
exchange-declare: Public ordinary functions
exchange-delete: Public ordinary functions
exchange-unbind: Public ordinary functions

F
fail-if-null: Private ordinary functions
fill-in-properties-alist: Private ordinary functions
foreign-method->class: Private generic functions
foreign-method->class: Private generic functions
foreign-method->class: Private generic functions
foreign-method->class: Private generic functions
foreign-method->class: Private generic functions
foreign-method->class: Private generic functions
frames-enqueued: Private ordinary functions
Function, %check-client-version: Private ordinary functions
Function, allocate-amqp-table: Private ordinary functions
Function, amqp-basic-ack: Private ordinary functions
Function, amqp-basic-cancel: Private ordinary functions
Function, amqp-basic-consume: Private ordinary functions
Function, amqp-basic-get: Private ordinary functions
Function, amqp-basic-nack: Private ordinary functions
Function, amqp-basic-publish: Private ordinary functions
Function, amqp-basic-qos: Private ordinary functions
Function, amqp-basic-reject: Private ordinary functions
Function, amqp-channel-close: Private ordinary functions
Function, amqp-channel-flow: Private ordinary functions
Function, amqp-channel-open: Private ordinary functions
Function, amqp-confirm-select: Private ordinary functions
Function, amqp-connection-close: Private ordinary functions
Function, amqp-consume-message: Private ordinary functions
Function, amqp-cstring-bytes: Private ordinary functions
Function, amqp-data-in-buffer: Private ordinary functions
Function, amqp-destroy-connection: Private ordinary functions
Function, amqp-destroy-envelope: Private ordinary functions
Function, amqp-error-string2: Private ordinary functions
Function, amqp-exchange-bind: Private ordinary functions
Function, amqp-exchange-declare-0-5: Private ordinary functions
Function, amqp-exchange-declare-0-6: Private ordinary functions
Function, amqp-exchange-delete: Private ordinary functions
Function, amqp-exchange-unbind: Private ordinary functions
Function, amqp-frames-enqueued: Private ordinary functions
Function, amqp-get-rpc-reply: Private ordinary functions
Function, amqp-get-sockfd: Private ordinary functions
Function, amqp-login-sasl-plain: Private ordinary functions
Function, amqp-login-sasl-plain-with-properties: Private ordinary functions
Function, amqp-maybe-release-buffers: Private ordinary functions
Function, amqp-maybe-release-buffers-on-channel: Private ordinary functions
Function, amqp-new-connection: Private ordinary functions
Function, amqp-queue-bind: Private ordinary functions
Function, amqp-queue-declare: Private ordinary functions
Function, amqp-queue-delete: Private ordinary functions
Function, amqp-queue-purge: Private ordinary functions
Function, amqp-queue-unbind: Private ordinary functions
Function, amqp-send-frame: Private ordinary functions
Function, amqp-send-method: Private ordinary functions
Function, amqp-set-initialize-ssl-library: Private ordinary functions
Function, amqp-simple-wait-frame: Private ordinary functions
Function, amqp-simple-wait-frame-noblock: Private ordinary functions
Function, amqp-socket-get-sockfd: Private ordinary functions
Function, amqp-socket-open: Private ordinary functions
Function, amqp-ssl-socket-new: Private ordinary functions
Function, amqp-ssl-socket-set-cacert: Private ordinary functions
Function, amqp-ssl-socket-set-key: Private ordinary functions
Function, amqp-ssl-socket-set-key-buffer: Private ordinary functions
Function, amqp-ssl-socket-set-verify: Private ordinary functions
Function, amqp-table->lisp: Private ordinary functions
Function, amqp-tcp-socket-new: Private ordinary functions
Function, amqp-tcp-socket-set-sockfd: Private ordinary functions
Function, amqp-tx-commit: Private ordinary functions
Function, amqp-tx-rollback: Private ordinary functions
Function, amqp-tx-select: Private ordinary functions
Function, amqp-version: Private ordinary functions
Function, array-to-foreign-char-array: Private ordinary functions
Function, basic-ack: Public ordinary functions
Function, basic-cancel: Public ordinary functions
Function, basic-consume: Public ordinary functions
Function, basic-nack: Public ordinary functions
Function, basic-publish: Public ordinary functions
Function, basic-qos: Public ordinary functions
Function, bytes->array: Private ordinary functions
Function, bytes->string: Private ordinary functions
Function, bzero-ptr: Private ordinary functions
Function, call-with-amqp-table: Private ordinary functions
Function, call-with-timeval: Private ordinary functions
Function, channel-close: Public ordinary functions
Function, channel-flow: Public ordinary functions
Function, channel-open: Public ordinary functions
Function, check-client-version: Private ordinary functions
Function, confirm-channel-close: Private ordinary functions
Function, confirm-select: Public ordinary functions
Function, connection-close: Private ordinary functions
Function, consume-message: Public ordinary functions
Function, convert-to-bytes: Private ordinary functions
Function, data-in-buffer: Private ordinary functions
Function, destroy-connection: Public ordinary functions
Function, exchange-bind: Public ordinary functions
Function, exchange-declare: Public ordinary functions
Function, exchange-delete: Public ordinary functions
Function, exchange-unbind: Public ordinary functions
Function, fail-if-null: Private ordinary functions
Function, fill-in-properties-alist: Private ordinary functions
Function, frames-enqueued: Private ordinary functions
Function, get-sockfd: Private ordinary functions
Function, load-properties-to-alist: Private ordinary functions
Function, login-sasl-plain: Public ordinary functions
Function, make-content-body-frame: Private ordinary functions
Function, make-content-header-frame: Private ordinary functions
Function, make-envelope-message: Private ordinary functions
Function, make-method-frame-basic-acknowledgment: Private ordinary functions
Function, make-method-frame-basic-deliver: Private ordinary functions
Function, make-method-frame-basic-negative-acknowledgment: Private ordinary functions
Function, make-method-frame-basic-return: Private ordinary functions
Function, maybe-release-buffers: Private ordinary functions
Function, new-connection: Public ordinary functions
Function, queue-bind: Public ordinary functions
Function, queue-declare: Public ordinary functions
Function, queue-delete: Public ordinary functions
Function, queue-purge: Public ordinary functions
Function, queue-unbind: Public ordinary functions
Function, raise-method-frame-error: Private ordinary functions
Function, raise-rabbitmq-library-error: Private ordinary functions
Function, raise-rabbitmq-server-error: Private ordinary functions
Function, set-init-ssl-library: Public ordinary functions
Function, simple-wait-frame: Public ordinary functions
Function, socket-open: Public ordinary functions
Function, ssl-socket-new: Public ordinary functions
Function, ssl-socket-set-cacert: Public ordinary functions
Function, ssl-socket-set-key: Public ordinary functions
Function, ssl-socket-set-key-buffer: Public ordinary functions
Function, ssl-socket-set-verify: Public ordinary functions
Function, tcp-socket-new: Public ordinary functions
Function, tx-commit: Public ordinary functions
Function, tx-rollback: Public ordinary functions
Function, tx-select: Public ordinary functions
Function, typed-value->lisp: Private ordinary functions
Function, update-product-name-in-table: Private ordinary functions
Function, verify-rpc-framing-call: Private ordinary functions
Function, verify-rpc-reply: Private ordinary functions
Function, verify-status: Private ordinary functions
Function, version: Public ordinary functions

G
Generic Function, (setf connection/closed-p): Private generic functions
Generic Function, connection/closed-p: Private generic functions
Generic Function, connection/native-connection: Private generic functions
Generic Function, content-body-frame/body: Public generic functions
Generic Function, content-body-frame/channel: Public generic functions
Generic Function, content-header-frame/body-size: Public generic functions
Generic Function, content-header-frame/channel: Public generic functions
Generic Function, content-header-frame/class-id: Public generic functions
Generic Function, content-header-frame/properties: Public generic functions
Generic Function, envelope/channel: Public generic functions
Generic Function, envelope/consumer-tag: Public generic functions
Generic Function, envelope/delivery-tag: Public generic functions
Generic Function, envelope/exchange: Public generic functions
Generic Function, envelope/message: Public generic functions
Generic Function, envelope/routing-key: Public generic functions
Generic Function, foreign-method->class: Private generic functions
Generic Function, message/body: Public generic functions
Generic Function, message/properties: Public generic functions
Generic Function, method-frame-basic-acknowledgment/channel: Public generic functions
Generic Function, method-frame-basic-acknowledgment/delivery-tag: Public generic functions
Generic Function, method-frame-basic-acknowledgment/id: Public generic functions
Generic Function, method-frame-basic-acknowledgment/multiplep: Public generic functions
Generic Function, method-frame-basic-deliver/channel: Public generic functions
Generic Function, method-frame-basic-deliver/consumer-tag: Public generic functions
Generic Function, method-frame-basic-deliver/delivery-tag: Public generic functions
Generic Function, method-frame-basic-deliver/exchange: Public generic functions
Generic Function, method-frame-basic-deliver/id: Public generic functions
Generic Function, method-frame-basic-deliver/redeliveredp: Public generic functions
Generic Function, method-frame-basic-deliver/routing-key: Public generic functions
Generic Function, method-frame-basic-negative-acknowledgment/channel: Public generic functions
Generic Function, method-frame-basic-negative-acknowledgment/delivery-tag: Private generic functions
Generic Function, method-frame-basic-negative-acknowledgment/id: Public generic functions
Generic Function, method-frame-basic-negative-acknowledgment/multiplep: Public generic functions
Generic Function, method-frame-basic-negative-acknowledgment/requeuep: Public generic functions
Generic Function, method-frame-basic-return/channel: Public generic functions
Generic Function, method-frame-basic-return/exchange: Public generic functions
Generic Function, method-frame-basic-return/id: Public generic functions
Generic Function, method-frame-basic-return/reply-code: Public generic functions
Generic Function, method-frame-basic-return/reply-text: Public generic functions
Generic Function, method-frame-basic-return/routing-key: Public generic functions
Generic Function, method-frame-error/channel: Public generic functions
Generic Function, method-frame-error/method-id: Public generic functions
Generic Function, method-frame/channel: Private generic functions
Generic Function, method-frame/id: Private generic functions
Generic Function, rabbitmq-library-error/error-code: Public generic functions
Generic Function, rabbitmq-library-error/error-description: Public generic functions
Generic Function, rabbitmq-server-error/message: Public generic functions
Generic Function, rabbitmq-server-error/method: Private generic functions
Generic Function, rabbitmq-server-error/reply-code: Public generic functions
get-sockfd: Private ordinary functions

L
load-properties-to-alist: Private ordinary functions
login-sasl-plain: Public ordinary functions

M
Macro, print-unreadable-safely: Private macros
Macro, unwind-when-fail: Private macros
Macro, with-amqp-table: Private macros
Macro, with-bytes-string: Private macros
Macro, with-bytes-strings: Private macros
Macro, with-bytes-struct: Private macros
Macro, with-channel: Public macros
Macro, with-connection: Public macros
Macro, with-foreign-buffer-from-byte-array: Private macros
Macro, with-foreign-timeval: Private macros
Macro, with-state: Private macros
make-content-body-frame: Private ordinary functions
make-content-header-frame: Private ordinary functions
make-envelope-message: Private ordinary functions
make-method-frame-basic-acknowledgment: Private ordinary functions
make-method-frame-basic-deliver: Private ordinary functions
make-method-frame-basic-negative-acknowledgment: Private ordinary functions
make-method-frame-basic-return: Private ordinary functions
maybe-release-buffers: Private ordinary functions
message/body: Public generic functions
message/body: Public generic functions
message/properties: Public generic functions
message/properties: Public generic functions
Method, (setf connection/closed-p): Private generic functions
Method, connection/closed-p: Private generic functions
Method, connection/native-connection: Private generic functions
Method, content-body-frame/body: Public generic functions
Method, content-body-frame/channel: Public generic functions
Method, content-header-frame/body-size: Public generic functions
Method, content-header-frame/channel: Public generic functions
Method, content-header-frame/class-id: Public generic functions
Method, content-header-frame/properties: Public generic functions
Method, envelope/channel: Public generic functions
Method, envelope/consumer-tag: Public generic functions
Method, envelope/delivery-tag: Public generic functions
Method, envelope/exchange: Public generic functions
Method, envelope/message: Public generic functions
Method, envelope/routing-key: Public generic functions
Method, foreign-method->class: Private generic functions
Method, foreign-method->class: Private generic functions
Method, foreign-method->class: Private generic functions
Method, foreign-method->class: Private generic functions
Method, foreign-method->class: Private generic functions
Method, message/body: Public generic functions
Method, message/properties: Public generic functions
Method, method-frame-basic-acknowledgment/channel: Public generic functions
Method, method-frame-basic-acknowledgment/delivery-tag: Public generic functions
Method, method-frame-basic-acknowledgment/id: Public generic functions
Method, method-frame-basic-acknowledgment/multiplep: Public generic functions
Method, method-frame-basic-deliver/channel: Public generic functions
Method, method-frame-basic-deliver/consumer-tag: Public generic functions
Method, method-frame-basic-deliver/delivery-tag: Public generic functions
Method, method-frame-basic-deliver/exchange: Public generic functions
Method, method-frame-basic-deliver/id: Public generic functions
Method, method-frame-basic-deliver/redeliveredp: Public generic functions
Method, method-frame-basic-deliver/routing-key: Public generic functions
Method, method-frame-basic-negative-acknowledgment/channel: Public generic functions
Method, method-frame-basic-negative-acknowledgment/delivery-tag: Private generic functions
Method, method-frame-basic-negative-acknowledgment/id: Public generic functions
Method, method-frame-basic-negative-acknowledgment/multiplep: Public generic functions
Method, method-frame-basic-negative-acknowledgment/requeuep: Public generic functions
Method, method-frame-basic-return/channel: Public generic functions
Method, method-frame-basic-return/exchange: Public generic functions
Method, method-frame-basic-return/id: Public generic functions
Method, method-frame-basic-return/reply-code: Public generic functions
Method, method-frame-basic-return/reply-text: Public generic functions
Method, method-frame-basic-return/routing-key: Public generic functions
Method, method-frame-error/channel: Public generic functions
Method, method-frame-error/method-id: Public generic functions
Method, method-frame/channel: Private generic functions
Method, method-frame/id: Private generic functions
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, rabbitmq-library-error/error-code: Public generic functions
Method, rabbitmq-library-error/error-description: Public generic functions
Method, rabbitmq-server-error/message: Public generic functions
Method, rabbitmq-server-error/method: Private generic functions
Method, rabbitmq-server-error/reply-code: Public generic functions
method-frame-basic-acknowledgment/channel: Public generic functions
method-frame-basic-acknowledgment/channel: Public generic functions
method-frame-basic-acknowledgment/delivery-tag: Public generic functions
method-frame-basic-acknowledgment/delivery-tag: Public generic functions
method-frame-basic-acknowledgment/id: Public generic functions
method-frame-basic-acknowledgment/id: Public generic functions
method-frame-basic-acknowledgment/multiplep: Public generic functions
method-frame-basic-acknowledgment/multiplep: Public generic functions
method-frame-basic-deliver/channel: Public generic functions
method-frame-basic-deliver/channel: Public generic functions
method-frame-basic-deliver/consumer-tag: Public generic functions
method-frame-basic-deliver/consumer-tag: Public generic functions
method-frame-basic-deliver/delivery-tag: Public generic functions
method-frame-basic-deliver/delivery-tag: Public generic functions
method-frame-basic-deliver/exchange: Public generic functions
method-frame-basic-deliver/exchange: Public generic functions
method-frame-basic-deliver/id: Public generic functions
method-frame-basic-deliver/id: Public generic functions
method-frame-basic-deliver/redeliveredp: Public generic functions
method-frame-basic-deliver/redeliveredp: Public generic functions
method-frame-basic-deliver/routing-key: Public generic functions
method-frame-basic-deliver/routing-key: Public generic functions
method-frame-basic-negative-acknowledgment/channel: Public generic functions
method-frame-basic-negative-acknowledgment/channel: Public generic functions
method-frame-basic-negative-acknowledgment/delivery-tag: Private generic functions
method-frame-basic-negative-acknowledgment/delivery-tag: Private generic functions
method-frame-basic-negative-acknowledgment/id: Public generic functions
method-frame-basic-negative-acknowledgment/id: Public generic functions
method-frame-basic-negative-acknowledgment/multiplep: Public generic functions
method-frame-basic-negative-acknowledgment/multiplep: Public generic functions
method-frame-basic-negative-acknowledgment/requeuep: Public generic functions
method-frame-basic-negative-acknowledgment/requeuep: Public generic functions
method-frame-basic-return/channel: Public generic functions
method-frame-basic-return/channel: Public generic functions
method-frame-basic-return/exchange: Public generic functions
method-frame-basic-return/exchange: Public generic functions
method-frame-basic-return/id: Public generic functions
method-frame-basic-return/id: Public generic functions
method-frame-basic-return/reply-code: Public generic functions
method-frame-basic-return/reply-code: Public generic functions
method-frame-basic-return/reply-text: Public generic functions
method-frame-basic-return/reply-text: Public generic functions
method-frame-basic-return/routing-key: Public generic functions
method-frame-basic-return/routing-key: Public generic functions
method-frame-error/channel: Public generic functions
method-frame-error/channel: Public generic functions
method-frame-error/method-id: Public generic functions
method-frame-error/method-id: Public generic functions
method-frame/channel: Private generic functions
method-frame/channel: Private generic functions
method-frame/id: Private generic functions
method-frame/id: Private generic functions

N
new-connection: Public ordinary functions

P
print-object: Public standalone methods
print-object: Public standalone methods
print-object: Public standalone methods
print-object: Public standalone methods
print-object: Public standalone methods
print-object: Public standalone methods
print-object: Public standalone methods
print-object: Public standalone methods
print-unreadable-safely: Private macros

Q
queue-bind: Public ordinary functions
queue-declare: Public ordinary functions
queue-delete: Public ordinary functions
queue-purge: Public ordinary functions
queue-unbind: Public ordinary functions

R
rabbitmq-library-error/error-code: Public generic functions
rabbitmq-library-error/error-code: Public generic functions
rabbitmq-library-error/error-description: Public generic functions
rabbitmq-library-error/error-description: Public generic functions
rabbitmq-server-error/message: Public generic functions
rabbitmq-server-error/message: Public generic functions
rabbitmq-server-error/method: Private generic functions
rabbitmq-server-error/method: Private generic functions
rabbitmq-server-error/reply-code: Public generic functions
rabbitmq-server-error/reply-code: Public generic functions
raise-method-frame-error: Private ordinary functions
raise-rabbitmq-library-error: Private ordinary functions
raise-rabbitmq-server-error: Private ordinary functions

S
set-init-ssl-library: Public ordinary functions
simple-wait-frame: Public ordinary functions
socket-open: Public ordinary functions
ssl-socket-new: Public ordinary functions
ssl-socket-set-cacert: Public ordinary functions
ssl-socket-set-key: Public ordinary functions
ssl-socket-set-key-buffer: Public ordinary functions
ssl-socket-set-verify: Public ordinary functions

T
tcp-socket-new: Public ordinary functions
tx-commit: Public ordinary functions
tx-rollback: Public ordinary functions
tx-select: Public ordinary functions
typed-value->lisp: Private ordinary functions

U
unwind-when-fail: Private macros
update-product-name-in-table: Private ordinary functions

V
verify-rpc-framing-call: Private ordinary functions
verify-rpc-reply: Private ordinary functions
verify-status: Private ordinary functions
version: Public ordinary functions

W
with-amqp-table: Private macros
with-bytes-string: Private macros
with-bytes-strings: Private macros
with-bytes-struct: Private macros
with-channel: Public macros
with-connection: Public macros
with-foreign-buffer-from-byte-array: Private macros
with-foreign-timeval: Private macros
with-state: Private macros


A.3 Variables

Jump to:   *  
B   C   D   E   I   M   P   R   S  
Index Entry  Section

*
*field-kind-types*: Private special variables
*props-mapping*: Private special variables

B
body: Public classes
body: Public classes
body-size: Public classes

C
channel: Public conditions
channel: Public classes
channel: Public classes
channel: Public classes
channel: Public classes
channel: Public classes
channel: Public classes
channel: Public classes
channel: Private classes
class-id: Public classes
closed-p: Private classes
conn: Private classes
consumer-tag: Public classes
consumer-tag: Public classes

D
delivery-tag: Public classes
delivery-tag: Public classes
delivery-tag: Public classes
delivery-tag: Public classes

E
error-code: Public conditions
error-description: Public conditions
exchange: Public classes
exchange: Public classes
exchange: Public classes

I
id: Public classes
id: Public classes
id: Public classes
id: Public classes
id: Private classes

M
message: Public conditions
message: Public classes
method: Public conditions
method-id: Public conditions
multiplep: Public classes
multiplep: Public classes

P
properties: Public classes
properties: Public classes

R
redeliveredp: Public classes
reply-code: Public conditions
reply-code: Public classes
reply-text: Public classes
requeuep: Public classes
routing-key: Public classes
routing-key: Public classes
routing-key: Public classes

S
Slot, body: Public classes
Slot, body: Public classes
Slot, body-size: Public classes
Slot, channel: Public conditions
Slot, channel: Public classes
Slot, channel: Public classes
Slot, channel: Public classes
Slot, channel: Public classes
Slot, channel: Public classes
Slot, channel: Public classes
Slot, channel: Public classes
Slot, channel: Private classes
Slot, class-id: Public classes
Slot, closed-p: Private classes
Slot, conn: Private classes
Slot, consumer-tag: Public classes
Slot, consumer-tag: Public classes
Slot, delivery-tag: Public classes
Slot, delivery-tag: Public classes
Slot, delivery-tag: Public classes
Slot, delivery-tag: Public classes
Slot, error-code: Public conditions
Slot, error-description: Public conditions
Slot, exchange: Public classes
Slot, exchange: Public classes
Slot, exchange: Public classes
Slot, id: Public classes
Slot, id: Public classes
Slot, id: Public classes
Slot, id: Public classes
Slot, id: Private classes
Slot, message: Public conditions
Slot, message: Public classes
Slot, method: Public conditions
Slot, method-id: Public conditions
Slot, multiplep: Public classes
Slot, multiplep: Public classes
Slot, properties: Public classes
Slot, properties: Public classes
Slot, redeliveredp: Public classes
Slot, reply-code: Public conditions
Slot, reply-code: Public classes
Slot, reply-text: Public classes
Slot, requeuep: Public classes
Slot, routing-key: Public classes
Slot, routing-key: Public classes
Slot, routing-key: Public classes
Special Variable, *field-kind-types*: Private special variables
Special Variable, *props-mapping*: Private special variables


A.4 Data types

Jump to:   A   C   E   F   G   M   P   R   S  
Index Entry  Section

A
amqp.lisp: The cl-rabbit/src/amqp․lisp file

C
cl-rabbit: The cl-rabbit system
cl-rabbit: The cl-rabbit package
cl-rabbit.asd: The cl-rabbit/cl-rabbit․asd file
cl-rabbit.examples: The cl-rabbit․examples package
Class, connection: Private classes
Class, content-body-frame: Public classes
Class, content-header-frame: Public classes
Class, envelope: Public classes
Class, message: Public classes
Class, method-frame: Private classes
Class, method-frame-basic-acknowledgment: Public classes
Class, method-frame-basic-deliver: Public classes
Class, method-frame-basic-negative-acknowledgment: Public classes
Class, method-frame-basic-return: Public classes
Condition, method-frame-error: Public conditions
Condition, rabbitmq-error: Public conditions
Condition, rabbitmq-library-error: Public conditions
Condition, rabbitmq-server-error: Public conditions
connection: Private classes
content-body-frame: Public classes
content-header-frame: Public classes

E
envelope: Public classes

F
File, amqp.lisp: The cl-rabbit/src/amqp․lisp file
File, cl-rabbit.asd: The cl-rabbit/cl-rabbit․asd file
File, functions.lisp: The cl-rabbit/src/functions․lisp file
File, grovel.lisp: The cl-rabbit/src/grovel․lisp file
File, misc.lisp: The cl-rabbit/src/misc․lisp file
File, package.lisp: The cl-rabbit/src/package․lisp file
functions.lisp: The cl-rabbit/src/functions․lisp file

G
grovel.lisp: The cl-rabbit/src/grovel․lisp file

M
message: Public classes
method-frame: Private classes
method-frame-basic-acknowledgment: Public classes
method-frame-basic-deliver: Public classes
method-frame-basic-negative-acknowledgment: Public classes
method-frame-basic-return: Public classes
method-frame-error: Public conditions
misc.lisp: The cl-rabbit/src/misc․lisp file
Module, src: The cl-rabbit/src module

P
Package, cl-rabbit: The cl-rabbit package
Package, cl-rabbit.examples: The cl-rabbit․examples package
package.lisp: The cl-rabbit/src/package․lisp file

R
rabbitmq-error: Public conditions
rabbitmq-library-error: Public conditions
rabbitmq-server-error: Public conditions

S
src: The cl-rabbit/src module
System, cl-rabbit: The cl-rabbit system