ActiveMQ impide que nuestro servidor de aplicaciones se detenga.

Bajo ciertas circunstancias, ActiveMQ evita que nuestro servidor de aplicaciones se detenga.
Estamos utilizando el siguiente escenario:
La versión 5.16.3 de ActiveMQ está integrada en nuestro Wildfly 25 a través de ActiveMQResourceAdapter. El servidor de aplicaciones está ubicado en un clúster de 2 servidores. El nodo activo es controlado a través de un “lease database locker”.

<persistenceAdapter>
  <jdbcPersistenceAdapter dataDirectory="${WILDFLY_INSTANCE_DATA_DIR}/activemq/jdbcPersistenceAdapter" dataSource="#activeMQDS" createTablesOnStartup="true" lockKeepAlivePeriod="4000">
    <locker>            
      <lease-database-locker lockAcquireSleepInterval="8000" leaseHolderId="${HOSTNAME}:${HOSTPORT}" maxAllowableDiffFromDBTime="2000"/>
    </locker>
    <statements>
      <statements tablePrefix="WILDFLY_" />
    </statements>
  </jdbcPersistenceAdapter>
 </persistenceAdapter>

Si se detiene el servidor de aplicaciones que actualmente no es el nodo activo, el hilo Java continúa. Un volcado de Java muestra que el proceso de detención está bloqueado por ActiveMQ.

 public void stop()
  {
    this.log.debug(new StringBuilder().append("Stop: ").append(getInfo()).toString());
    this.started.compareAndSet(true, false);
    synchronized (this.endpointWorkers) {
      while (this.endpointWorkers.size() > 0) {
        ActiveMQEndpointActivationKey key = (ActiveMQEndpointActivationKey)this.endpointWorkers.keySet().iterator().next();
        endpointDeactivation(key.getMessageEndpointFactory(), key.getActivationSpec());
      }
    }
    //BLOQUEADO AQUÍ
    synchronized (this) {
      if (this.broker != null) {
        if (this.brokerStartThread.isAlive()) {
          this.brokerStartThread.interrupt();
        }
        ServiceSupport.dispose(this.broker);
        this.broker = null;
      }
      if (this.reconnectingXaResource != null) {
        this.reconnectingXaResource.stop();
      }
    }

    this.bootstrapContext = null;
    this.reconnectingXaResource = null;
  }

La detención solo se lleva a cabo si se puede completar el inicio pendiente, lo cual bloquea o habilita el “synchronized”. Dado que el nodo del clúster no es el nodo activo de ActiveMQ, permanece activo hasta que el socio activo ceda su rol.