Forward messages from ActiveMQ to RabbitMQ via Qpid Dispatch Router

[Icipher]

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: users-unsubscr...@qpid.apache.org
For additional commands, e-mail: users-h...@qpid.apache.org