Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/CopernicaMarketingSoftware/AMQP-CPP
/ functions
Functions
1,099 in github.com/CopernicaMarketingSoftware/AMQP-CPP
⨍
Functions
1,099
◇
Types & classes
253
↓ 65 callers
Method
get
* Retrieve a pointer to the object * * @return Pointer to the object or nullptr if no object is managed */
include/amqpcpp/stack_ptr.h:111
↓ 64 callers
Method
process
* Process the received frame * @param connection * @return bool */
src/receivedframe.cpp:135
↓ 62 callers
Method
channel
* The channel this message was sent on */
src/extframe.h:97
↓ 60 callers
Method
set
* Set all meta data * @param data */
include/amqpcpp/metadata.h:170
↓ 58 callers
Method
add
* Add a channel to the connection, and return the channel ID that it * is allowed to use, or 0 when no more ID's are available * @param channel
src/connectionimpl.cpp:59
↓ 34 callers
Method
valid
* Is this a valid function or not? * @return bool */
src/linux_tcp/function.h:133
↓ 28 callers
Method
size
* Get the size this field will take when * encoded in the AMQP wire-frame format */
src/table.cpp:142
↓ 22 callers
Method
reportSuccess
include/amqpcpp/channelimpl.h:681
↓ 20 callers
Method
clear
* Clear the buffer */
src/linux_tcp/tcpoutbuffer.h:202
↓ 20 callers
Method
onIdle
* Method to be called when we need to monitor a different filedescriptor * @param state * @param fd * @param events */
include/amqpcpp/linux_tcp/tcpconnection.h:193
↓ 16 callers
Method
append
* Append data * @param buffer incoming data * @param size size of the data * @return bool true if the message
include/amqpcpp/message.h:95
↓ 16 callers
Method
nextUint16
* Read the next uint16_t from the buffer * @return uint16_t value read */
src/inbuffer.cpp:48
↓ 15 callers
Method
set
* Set a field * * @param index field index * @param value field value * @return Array */
include/amqpcpp/array.h:96
↓ 12 callers
Method
data
* Get access to the raw data * @param pos position in the buffer * @param size number of continuous bytes * @retur
include/amqpcpp/bytebuffer.h:115
↓ 11 callers
Method
nextInt16
* Read the next int16_t from the buffer * @return int16_t value read */
src/inbuffer.cpp:63
↓ 10 callers
Method
add
* Add a pointer to the next deferred result * @param deferred */
include/amqpcpp/deferred.h:176
↓ 10 callers
Method
size
* Total size * @return uint32_t */
include/amqpcpp/metadata.h:346
↓ 9 callers
Method
append
* The method that adds the actual data * @param data * @param size */
src/passthroughbuffer.h:76
↓ 9 callers
Method
nextUint8
* Read the next uint8 from the buffer * @param char* buffer buffer to read from * @return uint8_t value read */
src/inbuffer.cpp:21
↓ 8 callers
Method
contains
* Is a certain field set in the table * @param name * @return bool */
include/amqpcpp/table.h:160
↓ 8 callers
Method
copy
* Copy bytes to a buffer * * No safety checks are necessary: this method will only be called * for bytes that actually exist *
src/reducedbuffer.h:92
↓ 8 callers
Method
data
* data ptr (guaranteed null-terminated) * @return const char * */
src/linux_tcp/sslerrorprinter.cpp:89
↓ 7 callers
Method
nextUint32
* Read the next uint32_t from the buffer * @return uint32_t value read */
src/inbuffer.cpp:78
↓ 7 callers
Method
nextUint64
* Read the next uint64_t from the buffer * @return uint64_t value read */
src/inbuffer.cpp:108
↓ 7 callers
Method
onError
* Install an error callback * @param callback */
src/tagger.cpp:212
↓ 7 callers
Method
push_back
* Add a field to the array * @param value */
src/array.cpp:94
↓ 6 callers
Method
add
* Add data to the buffer * @param buffer * @param size */
src/linux_tcp/tcpoutbuffer.h:140
↓ 6 callers
Method
install
* Install a consumer * @param consumertag The consumer tag * @param consumer The consumer object */
include/amqpcpp/channelimpl.h:742
↓ 6 callers
Method
nextInt32
* Read the next int32_t from the buffer * @return uint32_t value read */
src/inbuffer.cpp:93
↓ 6 callers
Method
onError
* Method called when the AMQP connection ends up in an error state * @param connection The connection that entered the error state * @param
src/linux_tcp/tcpconnection.cpp:204
↓ 6 callers
Function
valid
* Is the openssl library loaded? * @return bool */
src/linux_tcp/openssl.cpp:46
↓ 5 callers
Function
ERR_clear_error
* Clear the SSL error queue * @return void */
src/linux_tcp/openssl.cpp:348
↓ 5 callers
Function
SSL_get_error
* Obtain result code for TLS/SSL I/O operation * @param ssl SSL object * @param ret the returned diagnostic value of SSL calls * @ret
src/linux_tcp/openssl.cpp:271
↓ 5 callers
Method
bodySize
* Size of the body * @return uint64_t */
src/basicheaderframe.h:113
↓ 5 callers
Method
clone
* Create a new instance on the heap of this object, identical to the object passed * @return Field* */
include/amqpcpp/table.h:99
↓ 5 callers
Method
close
* Close the connection * This will close all channels * @return bool */
src/connectionimpl.cpp:246
↓ 5 callers
Method
id
* Get the channel we're working on * @return uint16_t */
include/amqpcpp/channel.h:601
↓ 5 callers
Method
lock
* Get reference to self to prevent that object falls out of scope * @return std::shared_ptr */
include/amqpcpp/deferredget.h:63
↓ 5 callers
Method
payloadSize
* The size of the payload * @return uint32_t */
src/extframe.h:136
↓ 5 callers
Method
process
* Process the frame * @param connection The connection over which it was received * @return bool Was it succesfully proc
include/amqpcpp/frame.h:91
↓ 5 callers
Method
reportError
* Method that is called to report an error * @param message */
src/tagger.cpp:119
↓ 5 callers
Method
send
* Send method for a frame * @param id * @param frame */
src/tagger.cpp:67
↓ 5 callers
Method
size
* length of the string * @return size_t */
src/linux_tcp/sslerrorprinter.cpp:95
↓ 4 callers
Method
close
* Close the connection * This will close all channels * @return bool */
include/amqpcpp/connection.h:232
↓ 4 callers
Method
contains
* Check if a filedescriptor is covered by the watcher * @param fd * @return bool */
include/amqpcpp/libev.h:135
↓ 4 callers
Method
data
* Get access to the raw data * @param pos position in the buffer * @param size number of continuous bytes * @retur
src/reducedbuffer.h:76
↓ 4 callers
Method
nextData
* Get a pointer to the next binary buffer of a certain size * @param size * @return char* */
src/inbuffer.cpp:169
↓ 4 callers
Method
onData
* Method that is called by the connection when data needs to be sent over the network * @param connection The connection that created this ou
src/linux_tcp/tcpconnection.cpp:193
↓ 4 callers
Method
totalSize
* return the total size of the frame * @return uint32_t */
src/extframe.h:126
↓ 4 callers
Method
typeID
* Get the type ID that is used to identify this type of * field in a field table */
include/amqpcpp/table.h:225
↓ 4 callers
Method
usable
* Is the channel usable / not yet closed? * @return bool */
include/amqpcpp/channel.h:142
↓ 4 callers
Method
valid
* Check if the object is valid * @return bool */
include/amqpcpp/monitor.h:119
↓ 3 callers
Method
byte
* Get access to a single byte * @param pos position in the buffer * @return char value of the byte in the buffer */
src/reducedbuffer.h:65
↓ 3 callers
Method
confirm
* Retrieve the deferred confirm that handles publisher confirms * @return The deferred confirm object */
include/amqpcpp/channelimpl.h:791
↓ 3 callers
Method
deliveryTag
* Return the server-assigned and channel specific delivery tag * @return uint64_t */
src/basicackframe.h:100
↓ 3 callers
Method
in
* Expose the filedescriptors * @return int */
src/linux_tcp/pipe.h:73
↓ 3 callers
Method
onReceived
* Method to be called when data was received * @param state * @param buffer * @return size_t */
include/amqpcpp/linux_tcp/tcpconnection.h:181
↓ 3 callers
Method
receiver
* Retrieve the current object that is receiving a message * @return The handler responsible for the current message */
include/amqpcpp/channelimpl.h:779
↓ 3 callers
Method
reset
* Reset the pointer */
include/amqpcpp/stack_ptr.h:65
↓ 3 callers
Method
sendto
* Send the buffer to a socket * @param socket the socket to send data to * @return ssize_t number of bytes sent (or the
src/linux_tcp/tcpoutbuffer.h:242
↓ 3 callers
Method
size
* Get the size this field will take when * encoded in the AMQP wire-frame format * @return size_t */
src/array.cpp:104
↓ 3 callers
Method
size
* Total size of the buffer * @return size_t */
src/linux_tcp/tcpoutbuffer.h:129
↓ 3 callers
Method
synchronous
* Is this a synchronous frame? * * After a synchronous frame no more frames may be * sent until the accompanying -ok frame arrives
src/methodframe.h:68
↓ 3 callers
Method
unchain
* Remove this object from the chain of deferreds */
include/amqpcpp/deferred.h:185
↓ 3 callers
Method
value
* Get the byte value * @return value */
include/amqpcpp/booleanset.h:164
↓ 2 callers
Function
SSL_shutdown
* Shut down a TLS/SSL shut down * @param ssl SSL object to terminate * @return int returns diagnostic values */
src/linux_tcp/openssl.cpp:214
↓ 2 callers
Function
SSL_write
* Write data to an ssl socket * @param ssl ssl structure * @param buf buffer to write * @param num size of buffer * @return in
src/linux_tcp/openssl.cpp:111
↓ 2 callers
Method
body
* Access to the full message data * @return buffer */
include/amqpcpp/envelope.h:98
↓ 2 callers
Method
close
* Close the connection. * Warning: this potentially directly calls several handlers (onError, onLost, onDetached) * @return bool */
src/linux_tcp/tcpconnection.cpp:125
↓ 2 callers
Method
construct
include/amqpcpp/stack_ptr.h:83
↓ 2 callers
Method
events
* Change the events for which the filedescriptor is monitored * @param events */
include/amqpcpp/libboostasio.h:351
↓ 2 callers
Method
expected
* Expected number of bytes for the next parse() call. * * This method returns the number of bytes that the next call to parse() at least
include/amqpcpp/connection.h:194
↓ 2 callers
Method
fail
* Fail all open channels, helper method * @param monitor object to check if object still exists * @param message error message * @ret
src/connectionimpl.cpp:189
↓ 2 callers
Method
heartbeat
* Send a ping/heartbeat to the channel to keep it alive * @return bool */
include/amqpcpp/connection.h:101
↓ 2 callers
Method
maxPayload
* The max payload size for body frames * @return uint32_t */
src/channelimpl.cpp:817
↓ 2 callers
Method
monitor
* Method that is called by AMQP-CPP to register a filedescriptor for readability or writability * @param connection The TCP connection object
include/amqpcpp/libuv.h:182
↓ 2 callers
Method
multiple
* Return whether to acknowledge multiple messages * @return bool */
src/basicackframe.h:109
↓ 2 callers
Method
nextInt64
* Read the next uint64_t from the buffer * @return uint64_t value read */
src/inbuffer.cpp:123
↓ 2 callers
Method
onAck
* Called when the deliverytag(s) are acked * @param deliveryTag * @param multiple */
src/tagger.cpp:78
↓ 2 callers
Method
onDetached
* Method that is called when the TCP connection is detached * @param connection The TCP connection */
examples/libev.cpp:66
↓ 2 callers
Method
onNack
* Called when the deliverytag(s) are nacked * @param deliveryTag * @param multiple */
src/tagger.cpp:99
↓ 2 callers
Method
option
include/amqpcpp/address.h:440
↓ 2 callers
Method
partOfHandshake
* Is this a frame that is part of the connection setup? * @return bool */
src/connectionopenframe.h:108
↓ 2 callers
Method
payload
* Return the payload of the body * @return const char * */
src/bodyframe.h:94
↓ 2 callers
Method
reallocate
* Reallocate date * @param size */
src/linux_tcp/tcpinbuffer.h:79
↓ 2 callers
Method
receivefrom
* Receive data from a socket * @param socket socket to read from * @param expected number of bytes that the library exp
src/linux_tcp/tcpinbuffer.h:91
↓ 2 callers
Method
remove
* Remove a channel * @param channel */
src/connectionimpl.cpp:85
↓ 2 callers
Method
remove
* Remove a monitor * @param monitor */
include/amqpcpp/watchable.h:57
↓ 2 callers
Method
replyCode
* Return the reply code * @return int16_t */
src/basicreturnframe.h:146
↓ 2 callers
Method
reportAck
* Report an ack, calls the callback. */
include/amqpcpp/deferredpublish.h:47
↓ 2 callers
Method
reportClosed
* Report to the handler that the channel is closed * * Returns whether the channel object is still valid * * @return bool
include/amqpcpp/channelimpl.h:648
↓ 2 callers
Method
reportNack
* Report an nack, calls the callback if set. */
include/amqpcpp/deferredpublish.h:56
↓ 2 callers
Method
shrink
* Shrink the buffer (in practice this is always called with the full buffer size) * @param size */
src/linux_tcp/tcpinbuffer.h:141
↓ 2 callers
Method
size
* Number of addresses * @return size_t */
include/amqpcpp/addresses.h:99
↓ 2 callers
Method
size
* Size of the envelope, this is the size of the meta+data plus the number of bytes * required to store the size of the body + the actual body.
include/amqpcpp/envelope.h:118
↓ 2 callers
Method
waiting
* Is the connection waiting for an answer from an instruction? * @return bool */
src/connectionimpl.cpp:349
↓ 1 callers
Function
ERR_print_errors_cb
* Print errors via a callback * @param cb * @param u */
src/linux_tcp/openssl.cpp:362
↓ 1 callers
Function
SSL_CTX_free
* Free an allocated ssl context * @param ctx */
src/linux_tcp/openssl.cpp:154
↓ 1 callers
Function
SSL_CTX_new
* Create new SSL context * @param method SSL_METHOD can be of the following types: TLS_method(), TLS_server_method(), TLS_client_method() * @re
src/linux_tcp/openssl.cpp:79
↓ 1 callers
Function
SSL_CTX_set_default_verify_paths
* Specify that the default location from which CA certificates are loaded * should be used. * @param ctx */
src/linux_tcp/openssl.cpp:335
next →
1–100 of 1,099, ranked by callers