Как настроить обмен сообщениями activemq - thorntail или swarm с использованием значений по умолчанию для проекта yaml

Как настроить обмен сообщениями activemq - thorntail или swarm с использованием значений по умолчанию для проекта yaml

В настоящее время я получаю следующее исключение

Возможности, необходимые для ресурса '/ subsystem = messaging-activemq / connection-factory = RemoteConnectionFactory', недоступны: org.wildfly.messaging.activemq.connector.external.http-connector; Возможные точки регистрации для этой возможности:

 messaging-activemq:
    connection-factories:
      InVmConnectionFactory:
        entries:
          - 'java:/ConnectionFactory'
        connectors:
          - 'in-vm'
      RemoteConnectionFactory:
        ha: true
        entries:
          - 'java:jboss/exported/jms/RemoteConnectionFactory'
        connectors:
          - 'http-connector'
    pooled-connection-factories:
      activemq-ra:
        entries:
          - 'java:/JmsXA'
          - 'java:jboss/DefaultJMSConnectionFactory'
        transaction: xa
    in-vm-connectors:
      in-vm:
        server-id: 0
    http-connectors:
      http-connector-throughput:
        params:
          batch-delay: 50

        socket-binding: http
        endpoint: http-acceptor-throughput
    servers:
      default:
        jms-queues:
          ExpiryQueue:
            entries:
              - 'java:/jms/queue/ExpiryQueue'
          DLQ:
            entries:
              - 'java:/jms/queue/DLQ'
          CsiDLQ:
            entries:
              - 'java:/jms/queue/CsiDLQ'
          CCDLQ:
            entries:
              - 'java:/jms/queue/CCDLQ'
          CCRequestQueue:
            entries:
              - 'java:/jms/queue/CCRequestQueue'
        address-settings:
          default:
            message-counter-history-day-limit: 10
            page-size-bytes: 2097152
            max-size-bytes: 10485760
            expiry-address: jms.queue.ExpiryQueue
            dead-letter-address: jms.queue.DLQ
            redistribution-delay: 1000
          CCRequestQueue:
            message-counter-history-day-limit: 10
            page-size-bytes: 2097152
            max-size-bytes: 10485760
            expiry-address: jms.queue.ExpiryQueue
            dead-letter-address: CCDLQ
            redistribution-delay: 1000
        security-settings:
          default:
            roles:
              guest:
                send: true
                delete-durable-queue: true
                create-non-durable-queue: true
                consume: true
        http-acceptors:
          http-acceptor-mq:
            http-listener: default
        http-connectors:
          http-connector-mq:
            socket-binding: http
            endpoint: http-acceptor
        cluster-password: ${jboss.messaging.cluster.password:CHANGEME}
        discovery-groups:
          activemq-discovery:
            jgroups-cluster: activemq-cluster
        broadcast-groups:
          activemq-broadcast:
            jgroups-cluster: activemq-cluster
            connectors:
              - 'http-connector'
        cluster-connections:
          activemq-cluster:
            cluster-connection-address: jms
            connector-name: http-connector
            discovery-group: activemq-discovery

Полное исключение при запуске.

2020-04-08 14:55:27,032 ERROR [org.jboss.as.controller] (Controller Boot Thread) WFLYCTL0362: Capabilities required by resource '/subsystem=messaging-activemq/connection-factory=RemoteConnectionFactory' are not available:
    org.wildfly.messaging.activemq.connector.external.http-connector; Possible registration points for this capability: 
        /subsystem=messaging-activemq/connector=*
        /subsystem=messaging-activemq/in-vm-connector=*
        /subsystem=messaging-activemq/remote-connector=*
        /subsystem=messaging-activemq/http-connector=*
        /subsystem=messaging-activemq/server=*/connector=*
        /subsystem=messaging-activemq/server=*/in-vm-connector=*
        /subsystem=messaging-activemq/server=*/remote-connector=*
        /subsystem=messaging-activemq/server=*/http-connector=*
        /subsystem=messaging-activemq/server=*/http-acceptor=*
2020-04-08 14:55:27,036 FATAL [org.jboss.as.server] (Controller Boot Thread) WFLYSRV0056: Server boot has failed in an unrecoverable manner; exiting. See previous messages for details.

person Fholisani Mashegana    schedule 08.04.2020    source источник
comment
Кажется, что в RemoteConnectionFactory вы ссылаетесь на http-connector, но когда вы определяете соединители HTTP, вы используете имя http-connector-throughput. Может, это несоответствие?   -  person Ladicek    schedule 08.04.2020


Ответы (1)


Это то, что сработало для меня ... после комментария выше от @Ladicek

  messaging-activemq:
    in-vm-connectors:
      in-vm:
        server-id: 0
    http-connectors:
      http-connector:
        params:
          batch-delay: 50
        socket-binding: http
        endpoint: http-acceptor-throughput
    servers:
      default:
        jms-queues:
          ExpiryQueue:
            entries:
              - 'java:/jms/queue/ExpiryQueue'
          DLQ:
            entries:
              - 'java:/jms/queue/DLQ'
          CSIRequestQueue:
            entries:
              - 'java:/jms/queue/CSIRequestQueue'
          CsiDLQ:
            entries:
              - 'java:/jms/queue/CsiDLQ'
          CCDLQ:
            entries:
              - 'java:/jms/queue/CCDLQ'
          CCRequestQueue:
            entries:
              - 'java:/jms/queue/CCRequestQueue'
        address-settings:
          default:
            message-counter-history-day-limit: 10
            page-size-bytes: 2097152
            max-size-bytes: 10485760
            expiry-address: jms.queue.ExpiryQueue
            dead-letter-address: jms.queue.DLQ
            redistribution-delay: 1000
          CCRequestQueue:
            message-counter-history-day-limit: 10
            page-size-bytes: 2097152
            max-size-bytes: 10485760
            expiry-address: jms.queue.ExpiryQueue
            dead-letter-address: CCDLQ
            redistribution-delay: 1000
        security-settings:
          default:
            roles:
              guest:
                send: true
                delete-durable-queue: true
                create-non-durable-queue: true
                consume: true
        http-acceptors:
          http-acceptor-mq:
            http-listener: default
        http-connectors:
          http-connector-mq:
            socket-binding: http
            endpoint: http-acceptor
        cluster-password: ${jboss.messaging.cluster.password:CHANGEME}
        discovery-groups:
          activemq-discovery:
            jgroups-cluster: activemq-cluster
        broadcast-groups:
          activemq-broadcast:
            jgroups-cluster: activemq-cluster
            connectors:
              - 'http-connector'
        cluster-connections:
          activemq-cluster:
            cluster-connection-address: jms
            connector-name: http-connector
            discovery-group: activemq-discover
person Fholisani Mashegana    schedule 10.04.2020