This busmod is a bridge between Vert.x and an AMQP message broker (such as RabbitMQ). This code was originally developed on a branch of the main Vert.x project, but I extended it, added new features, and some tests.
The examples below are mostly conceptual; if you want to see working examples, look at src/test/javascript/amqp_test_client.js. They can be invoked as part of the integration test suite:
mvn -P integration-test -Damqp.uri=amqp://your-amqp-server-here verify
Programmatically, if you like:
vertx.deployWorkerVerticle(
"org.vertx.java.busmods.amqp.AmqpBridge",
{
"uri": "amqp://localhost",
"address": "amqp_bridge",
"defaultContentType": "application/json"
},
1,
function() {
// subscribe, if necessary, or send initial message
}
);
var handlerAddr = "my_addr";
eb.registerHandler(handlerAddr, function(msg) {
// handle message!
});
eb.send(
"amqp_bridge.create-consumer",
{
"exchange" : "raw_xbee_frames",
"routingKey" : "#",
"forward" : handlerAddr
},
function(reply) {
// check reply.status == "ok"
}
);
eb.send(
"amqp_bridge.send",
{
"routingKey" : "target_queue"
"properties" : {
"contentType" : "text/plain"
},
"body" : "my message"
},
function(reply) {
// check reply.status == "ok"
}
);
Based on this RabbitMQ article.
eb.send(
"amqp_bridge.invoke_rpc",
{
"routingKey" : "target_queue",
"body" : {
"my_name" : "Bob"
}
},
function(reply) {
// check reply.body == "Hi, Bob!"
}
);
var handlerAddr = "my_handler";
eb.registerHandler(handlerAddr, function(msg) {
// do something with msg
});
eb.send(
"amqp_bridge.invoke_rpc",
{
"routingKey" : "target_queue",
"replyTo" : handlerAddr,
"body" : {
"times_to_reply" : 3
}
},
function(reply) {
// check reply.status == "ok"
}
);
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent