Hey guys,
I'm trying to find a way to forward messages from ActiveMQ (component from
Eclipse Hono) to RabbitMQ via a Qpid Dispatch Router.
This is the current configuration:
[
["router", {
"id": "Hono.Example.Router",
"mode": "standalone",
"workerThreads": 3
}],
["authServicePlugin", {
"name": "Hono Auth",
"host": "hono-service-auth.hono",
"port": 5671,
"sslProfile": "internal"
}],
["sslProfile", {
"name": "external",
"certDb": "/run/secrets/trusted-certs.pem",
"certFile": "/run/secrets/qdrouter-cert.pem",
"keyFile": "/run/secrets/qdrouter-key.pem"
}],
["sslProfile", {
"name": "internal",
"certDb": "/run/secrets/trusted-certs.pem",
"certFile": "/run/secrets/qdrouter-cert.pem",
"keyFile": "/run/secrets/qdrouter-key.pem",
"uidFormat": "oun"
}],
["listener", {
"sslProfile": "external",
"requireSsl": true,
"host": "0.0.0.0",
"port": 5671,
"authenticatePeer": true,
"saslMechanisms": "PLAIN",
"saslPlugin": "Hono Auth"
}],
["listener", {
"host": "0.0.0.0",
"port": 5672,
"authenticatePeer": true,
"saslMechanisms": "PLAIN",
"saslPlugin": "Hono Auth"
}],
["listener", {
"sslProfile": "internal",
"requireSsl": true,
"host": "0.0.0.0",
"port": 5673,
"authenticatePeer": true,
"saslMechanisms": "EXTERNAL"
}],
["connector", {
"sslProfile": "external",
"name": "broker",
"host": "hono-artemis.hono",
"port": 5671,
"role": "route-container",
"saslUsername": "artemis",
"saslPassword": "artemis"
}],
["connector", {
"name": "mybroker",
"role": "route-container",
"host": "rabbitmq_amqp",
"port": "5672",
"saslMechanisms": "PLAIN",
"saslUsername": "atnoguser",
"saslPassword": "atnogpass"
}],
["linkRoute", {
"prefix": "event/",
"dir": "in",
"connection": "broker"
}],
["linkRoute", {
"prefix": "event/",
"dir": "out",
"connection": "broker"
}],
["address", {
"prefix": "telemetry"
}],
["autoLink", {
"addr": "telemetry",
"dir": "in",
"connection": "broker"
}],
["autoLink", {
"addr": "telemetry",
"dir": "out",
"connection": "mybroker"
}],
["autoLink", {
"addr": "telemetry",
"dir": "out",
"connection": "broker"
}],
["autoLink", {
"addr": "telemetry",
"dir": "in",
"connection": "mybroker"
}],
["policy", {
"maxConnections": 1000,
"enableVhostPolicy": true,
"defaultVhost": "hono"
}],
["vhost", {
"id": "hono",
"maxConnections": 500,
"maxConnectionsPerUser": 20,
"maxConnectionsPerHost": 10,
"allowUnknownUser": true,
"groups": {
"$default": {
"remoteHosts": "*",
"maxSessions": 10
}
}
}],
["vhost", {
"id": "hono-internal",
"maxConnections": 9,
"groups": {
"Hono": {
"users": "Eclipse IoT;Hono;hono-messaging, Eclipse
IoT;Hono;http-adapter, Eclipse IoT;Hono;mqtt-adapter, Eclipse
IoT;Hono;kura-adapter, Eclipse IoT;Hono;amqp-adapter, Eclipse
IoT;Hono;coap-adapter",
"remoteHosts": "*",
"maxSessions": 2,
"maxFrameSize": 16384,
"maxSessionWindow": 6553600,
"maxMessageSize": 131072,
"allowUserIdProxy": true,
"targets": "telemetry/*, event/*"
}
}
}],
["vhost", {
"id": "hono-kura-internal",
"maxConnections": 30,
"groups": {
"Hono": {
"users": "Eclipse IoT;Hono;kura-adapter",
"remoteHosts": "*",
"allowUserIdProxy": true,
"sources": "control/*",
"targets": "control/*"
}
}
}],
["vhost", {
"id": "hono-mqtt-internal",
"maxConnections": 30,
"groups": {
"Hono": {
"users": "Eclipse IoT;Hono;mqtt-adapter",
"remoteHosts": "*",
"allowUserIdProxy": true,
"sources": "control/*",
"targets": "control/*"
}
}
}],
["vhost", {
"id": "hono-amqp-internal",
"maxConnections": 30,
"groups": {
"Hono": {
"users": "Eclipse IoT;Hono;amqp-adapter",
"remoteHosts": "*",
"allowUserIdProxy": true,
"sources": "control/*",
"targets": "control/*"
}
}
}],
["vhost", {
"id": "hono-http-internal",
"maxConnections": 30,
"groups": {
"Hono": {
"users": "Eclipse IoT;Hono;http-adapter",
"remoteHosts": "*",
"allowUserIdProxy": true,
"sources": "control/*",
"targets": "control/*"
}
}
}],
["vhost", {
"id": "hono-coap-internal",
"maxConnections": 30,
"groups": {
"Hono": {
"users": "Eclipse IoT;Hono;coap-adapter",
"remoteHosts": "*",
"allowUserIdProxy": true,
"sources": "control/*",
"targets": "control/*"
}
}
}],
["log", {
"module": "DEFAULT",
"enable": "info+"
}]
]
I can connect to RabbitMQ but I can't forward the messages (telemetry
adress) from <broker> to <mybroker>. (Queue shows 0 messages)
What am I doing wrong?
Hope you guys can help me!
Best regards
--
Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
