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
Method
fill
* Write encoded payload to the given buffer. * @param buffer OutBuffer to write to */
include/amqpcpp/numericfield.h:176
Method
fill
* Write encoded payload to the given buffer. * @param buffer OutBuffer to write to */
include/amqpcpp/voidfield.h:68
Method
fill
* Write encoded payload to the given buffer. * @param buffer */
include/amqpcpp/stringfield.h:257
Method
fill
* Write encoded payload to the given buffer. */
include/amqpcpp/decimalfield.h:61
Method
fill
* Fill the buffer * @param buffer */
include/amqpcpp/booleanset.h:155
Method
fill
* Fill an output buffer * This method is not used by this library, but could be useful if you want to store * the meta-data + message con
include/amqpcpp/envelope.h:130
Method
finalState
* Construct the final state * @param monitor Object that monitors whether connection still exists * @return TcpState* */
src/linux_tcp/tcpconnected.h:86
Method
flush
* Signal the channel that a synchronous operation was completed. After * this operation, waiting frames can be sent out. */
src/channelimpl.cpp:828
Method
flush
* Flush the object */
src/passthroughbuffer.h:61
Method
frameMax
* Proposed maximum frame size * @return _uint32_t */
src/connectiontuneframe.h:113
Method
frameMax
* Proposed maximum frame size * @return _uint32_t */
src/connectiontuneokframe.h:106
Method
get
* Get one of the booleans * @param index from 0 to 7, where 0 is rightmost bit * @return bool */
include/amqpcpp/booleanset.h:119
Method
get_dispatch_wrapper
* Builds a io handler callback that executes the io callback in a strand. * @param io_handler The handler callback to dispatch * @
include/amqpcpp/libboostasio.h:125
Method
get_read_handler
* Binds and returns a read handler for the io operation. * @param connection The connection being watched. * @param fd
include/amqpcpp/libboostasio.h:147
Method
get_timer_handler
* Binds and returns a lamba function handler for the io operation. * @param connection The connection being watched. * @param ti
include/amqpcpp/libboostasio.h:183
Method
get_write_handler
* Binds and returns a read handler for the io operation. * @param connection The connection being watched. * @param fd
include/amqpcpp/libboostasio.h:165
Method
global
* returns the value of global * @return boolean */
src/basicqosframe.h:106
Method
hasAppID
include/amqpcpp/metadata.h:204
Method
hasClusterID
include/amqpcpp/metadata.h:203
Method
hasContentEncoding
include/amqpcpp/metadata.h:201
Method
hasContentType
include/amqpcpp/metadata.h:202
Method
hasCorrelationID
include/amqpcpp/metadata.h:197
Method
hasDeliveryMode
include/amqpcpp/metadata.h:199
Method
hasExpiration
* Check if a certain field is set * @return bool */
include/amqpcpp/metadata.h:195
Method
hasHeaders
include/amqpcpp/metadata.h:200
Method
hasMessageID
include/amqpcpp/metadata.h:208
Method
hasPriority
include/amqpcpp/metadata.h:198
Method
hasReplyTo
include/amqpcpp/metadata.h:196
Method
hasTimestamp
include/amqpcpp/metadata.h:207
Method
hasTypeName
include/amqpcpp/metadata.h:206
Method
hasUserID
include/amqpcpp/metadata.h:205
Method
headerSize
* Size of the header * @return uint32_t */
src/extframe.h:106
Method
heartbeat
* Send a ping / heartbeat frame to keep the connection alive * @return bool */
src/connectionimpl.cpp:440
Method
heartbeat
* Desired heartbeat delay * @return uint16_t */
src/connectiontuneframe.h:122
Method
heartbeat
* Desired heartbeat delay * @return uint16_t */
src/connectiontuneokframe.h:115
Method
heartbeat
* Send a heartbeat * @return bool */
include/amqpcpp/linux_tcp/tcpconnection.h:348
Method
id
* Get the channel we're working on * @return uint16_t */
include/amqpcpp/channelimpl.h:585
Method
ifEmpty
* returns the value of ifEmpty * @returns bool */
src/queuedeleteframe.h:131
Method
ifUnused
* returns whether to delete if unused * @return bool */
src/exchangedeleteframe.h:120
Method
ifUnused
* returns value of ifUnused * @returns bool */
src/queuedeleteframe.h:122
Method
immediate
* Return the request immediate delivery indication * @return boolean */
src/basicpublishframe.h:148
Method
initialize
* Initialize the object to send out a message * @param exchange the exchange to which the message was published * @param routingkey
src/deferredextreceiver.cpp:26
Method
initialized
* Is (or was) the connection initialized * @return bool */
include/amqpcpp/connectionimpl.h:235
Method
initialized
* Is the connection initialized, meaning: it has passed the login handshake? * It may be closing or closed * @return bool */
include/amqpcpp/linux_tcp/tcpconnection.h:288
Method
internal
* Is this an internal exchange? * @return bool */
src/exchangedeclareframe.h:180
Method
isArray
include/amqpcpp/field.h:111
Method
isArray
* We are an array field * * @return true, because we are an array */
include/amqpcpp/array.h:188
Method
isBoolean
include/amqpcpp/field.h:113
Method
isBoolean
* We are a boolean field * * @return true, because we are a boolean */
include/amqpcpp/booleanset.h:183
Method
isDecimal
include/amqpcpp/field.h:110
Method
isDecimal
* We are a decimal field * * @return true, because we are a decimal field */
include/amqpcpp/decimalfield.h:223
Method
isInteger
* Check the field type * * @return Is the field a specific type? */
include/amqpcpp/field.h:109
Method
isInteger
* We are an integer field * * @return true, because we are an integer */
include/amqpcpp/numericfield.h:156
Method
isReadable
* Check if the socket is readable * @return bool */
src/linux_tcp/sslconnected.h:224
Method
isString
include/amqpcpp/field.h:114
Method
isString
* We are a string * * @return true, because we are a string */
include/amqpcpp/stringfield.h:284
Method
isTable
* We are a table * * @return true, because we are a table */
include/amqpcpp/table.h:235
Method
isTable
include/amqpcpp/field.h:112
Method
isVoid
include/amqpcpp/field.h:115
Method
isVoid
* We are an void field * * @return true, because we are an void */
include/amqpcpp/voidfield.h:94
Method
isWritable
* Check if the socket is writable * @return bool */
src/linux_tcp/sslconnected.h:237
Method
keys
* Retrieve all keys in the table * * @return Vector with all keys in the table */
src/table.cpp:102
Method
locale
* The selected locale * @return string */
src/connectionstartokframe.h:138
Method
lock
* Get reference to self to prevent that object falls out of scope * @return std::shared_ptr */
include/amqpcpp/deferredconsumer.h:75
Method
lock
* Get reference to self to prevent that object falls out of scope * @return std::shared_ptr */
include/amqpcpp/deferredrecall.h:73
Function
main
tests/table/table.cpp:5
Function
main
* Main program * @return int */
examples/libuv.cpp:59
Function
main
* Main program * @return int */
examples/libev.cpp:159
Function
main
* Main program * @return int */
examples/libboostasio.cpp:26
Function
main
* Main program * @return int */
examples/libevent.cpp:21
Method
majorVersion
* Major AMQP version number * @return uint8_t */
src/connectionstartframe.h:144
Method
mandatory
* Return the mandatory routing indication * @return boolean */
src/basicpublishframe.h:139
Method
maxFrame
* The max frame size * @return uint32_t */
include/amqpcpp/connectionimpl.h:309
Method
maxFrame
* The max frame size. Useful if you set up a buffer to parse incoming data: it does not have to exceed this size. * @return uint32_t */
include/amqpcpp/linux_tcp/tcpconnection.h:314
Method
maxLength
* Get the maximum allowed string length for this field * @return size_t */
include/amqpcpp/stringfield.h:248
Method
maxPayload
* The max payload size for body frames * @return uint32_t */
include/amqpcpp/connectionimpl.h:318
Method
maxframe
* Install max-frame size * @param heartbeat suggested heartbeat */
src/linux_tcp/sslconnected.h:437
Method
maxframe
* Install max-frame size * @param heartbeat suggested heartbeat */
src/linux_tcp/tcpconnected.h:245
Method
messageCount
* Number of messages * @return int32_t */
src/queuedeclareokframe.h:108
Method
messageCount
* Return the number of messages in the queue * @return uint32_t */
src/basicgetokframe.h:146
Method
methodID
* Return the method ID * @return uint16_t */
src/basicconsumeframe.h:130
Method
methodID
* return the method id * @return uint16_t */
src/transactionselectframe.h:46
Method
methodID
* returns the method id * @return uint16_t */
src/exchangedeclareokframe.h:54
Method
methodID
* return the method id * @return uint16_t */
src/confirmselectokframe.h:59
Method
methodID
* Method id * @return uint16_t */
src/connectionsecureokframe.h:69
Method
methodID
* Return the method ID * @return uint16_t */
src/basicrecoverasyncframe.h:80
Method
methodID
* returns the method id * @return uint16_t */
src/exchangedeleteokframe.h:55
Method
methodID
* Return the method ID * @return uint16_t */
src/basicrejectframe.h:91
Method
methodID
* Return the method ID * @return uint16_t */
src/basicrecoverframe.h:80
Method
methodID
* Method id * @return uint16_t */
src/connectionopenokframe.h:70
Method
methodID
* returns the method id * @return uint16_t */
src/queueunbindokframe.h:57
Method
methodID
* Return the method ID * @return uint16_t */
src/basicqosframe.h:88
Method
methodID
* return the method id * @return uint16_t */
src/transactionselectokframe.h:58
Method
methodID
* The method ID * @return method id */
src/queuepurgeframe.h:100
Method
methodID
* Return the method id * @return uint16_t */
src/basicqosokframe.h:51
Method
methodID
* Method id * @return uint16_t */
src/connectionunblockframe.h:58
Method
methodID
* Method id * @return uint16_t */
src/channelopenframe.h:62
Method
methodID
* Return the method ID * @return uint16_t */
src/basicdeliverframe.h:152
Method
methodID
* Returns the method id * @return uint16_t */
src/queuebindframe.h:129
Method
methodID
* returns the method id * @return uint16_t */
src/queuebindokframe.h:53
← previous
next →
501–600 of 1,099, ranked by callers