Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
062d92f
trivial housekepping
paolopas Dec 8, 2025
6be5e1b
libboostasio fixed strand header and test example
paolopas Dec 8, 2025
0291bd2
end of virtual inheritance abuse
paolopas Dec 8, 2025
5b32219
replaced deadline_timer with steady_timer
paolopas Dec 8, 2025
3c0c4d6
libboostasio freed from null_buffers
paolopas Dec 8, 2025
f7c4726
libboostasio handlers generation more rational
paolopas Dec 8, 2025
37e31ba
trivial housekepping
paolopas Dec 11, 2025
40ed673
libboostasio new handler factory (make_handler)
paolopas Dec 12, 2025
5090d0f
libboostasio bottom note added
paolopas Dec 12, 2025
5d03768
liboostasio immediate socket release (fix #479)
paolopas Dec 12, 2025
2f10c1f
liboostasio fixed timer_handler condition
paolopas Dec 12, 2025
b332ed9
libboostasio extended heartbeat support (fix #464)
paolopas Dec 12, 2025
bd08410
libboostasio heartbeat finishing
paolopas Dec 12, 2025
31105f7
some typos in the README.md
paolopas Dec 13, 2025
1349cdd
libboostasio reliable fixing of #424,
paolopas Dec 13, 2025
2ecd890
libboostasio asserted
paolopas Dec 13, 2025
b6a37c5
libboostasio must not hold the execution context
paolopas Dec 13, 2025
38c650c
libboostasio disclaimer notice added
paolopas Dec 18, 2025
b461f49
liboostasio new release method (protected)
paolopas Dec 18, 2025
6e152ec
libbostasio optimized watcher creation,
paolopas Dec 18, 2025
ddc1662
libboostasio watcher now holds a plain pointer
paolopas Dec 18, 2025
6143b87
libboostasio test example rewritten
paolopas Dec 18, 2025
4b4d592
simplified libboostasio test
paolopas Dec 19, 2025
1870a70
libboostasio says goodbye to shared_ptrs,
paolopas Dec 23, 2025
1c11cd9
libboostasio simplifies handlers
paolopas Dec 23, 2025
b1355f1
libboostasio watcher gives up parent for strand
paolopas Dec 23, 2025
060348c
libboostasio improved rw handler responsivity
paolopas Dec 27, 2025
2de0e52
revert of last commit,
paolopas Dec 28, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,7 @@ to RabbitMQ has to be set up.

An example compilation command for an application using the TCP module:
```bash
g++ -g -Wall -lamqcpp -lpthread -ldl my-amqp-cpp.c -o my-amqp-cpp
g++ -std=c++17 -g -Wall -lamqcpp -lpthread -ldl my-amqp-cpp.c -o my-amqp-cpp
```

HOW TO USE AMQP-CPP
Expand Down Expand Up @@ -710,7 +710,7 @@ it has a couple of open issues.

| TCP Handler Impl | Header File Location | Sample File Location |
| ----------------------- | ---------------------- | ------------------------- |
| Boost asio (io_service) | include/libboostasio.h | examples/libboostasio.cpp |
| Boost asio | include/libboostasio.h | examples/libboostasio.cpp |
| libev | include/libev.h | examples/libev.cpp |
| libevent | include/libevent.h | examples/libevent.cpp |
| libuv | include/libuv.h | examples/libuv.cpp |
Expand Down Expand Up @@ -770,7 +770,7 @@ class MyTcpHandler : public AMQP::TcpHandler
````

If you enable heartbeats, it is your own responsibility to ensure that the
```connection->heartbeat()``` method is called at least once during this period,
`connection->heartbeat()` method is called at least once during this period,
or that you call one of the other channel or connection methods to send data
over the connection. Heartbeats are sent by the server too, RabbitMQ also ensures
that _some data_ is sent over the connection from the server to the client
Expand Down Expand Up @@ -925,7 +925,7 @@ channel2.declareExchange("my-exchange");

Now, if an error occurs with declaring the queue, it will not have consequences
for the other call. But this comes at a small price: setting up the extra channel
requires and extra instruction to be sent to the RabbitMQ server, so some extra
requires an extra instruction to be sent to the RabbitMQ server, so some extra
bytes are sent over the network, and some additional resources in both the client
application and the RabbitMQ server are used (although this is all very limited).

Expand Down Expand Up @@ -1097,7 +1097,7 @@ bool publish(const std::string &exchange, const std::string &routingKey, const c
Published messages are normally not confirmed by the server, and the RabbitMQ
will not send a report back to inform you whether the message was successfully
published or not. But with the flags you can instruct RabbitMQ to send back
the message if it was undeliverable. In you use these flags you must also install
the message if it was undeliverable. If you use these flags you must also install
callbacks that will process these bounced messages.

You can also use transactions to ensure that your messages get delivered.
Expand Down Expand Up @@ -1146,7 +1146,7 @@ the server starts counting the received messages (starting from 1) and sends
acknowledgments for every message it processed (it can also acknowledge
multiple message at once).

If server is unable to process a message, it will send send negative
If server is unable to process a message, it will send negative
acknowledgments. Both positive and negative acknowledgments handling are
passed to callbacks that you can install on the object that
is returned by the `confirmSelect()` method:
Expand Down Expand Up @@ -1190,7 +1190,7 @@ operations are individually acknowledged:
// create a channel
AMQP::TcpChannel mychannel(connection);

// wrap the channel into a reliable-object so that publish-opertions are
// wrap the channel into a reliable-object so that publish-operations are
// individually confirmed (after wrapping the channel, it is recommended
// to no longer make direct calls to the channel)
AMQP::Reliable reliable(mychannel);
Expand Down Expand Up @@ -1289,7 +1289,7 @@ for (size_t i = 0; i < 100000; ++i)
}
````

For more information, see http://www.rabbitmq.com/confirms.html.
For more information, see http://www.rabbitmq.com/docs/confirms.

CONSUMING MESSAGES
==================
Expand Down
Loading