ActiveMQ - la Suppression des files d'attente par programmation

Collègues StackOverflowers, il est un moyen pour moi de supprimer une file d'attente ou un sujet dans ActiveMQ par programmation? Je suis à l'aide de ActiveMQ standard de persistance, et mon application exige que, au démarrage, toutes les nouvelles files d'attente dynamique de re-créé (sauf si il y a des messages stockés dans la file d'attente, dans ce cas, la file d'attente doit rester à exister).

Je suis également à la création de toutes les files d'attente par programmation dans le cadre des sessions. Est-il équivalent à celui de la procédure, que de les supprimer une file d'attente? En interrogeant et en parcourant les files d'attente existantes serait également utile, mais je n'ai pas trouvé un moyen de le faire encore.

  • Avez-vous été courir ActiveMQ intégré ou autonome?
InformationsquelleAutor Eduardo Z. | 2010-06-14
  1. 6

    Vous pouvez également Supprimer Des Destinations qui sont inactifs pendant une certaine période de temps. Disponible depuis Active MQ 5.4

    Sinon, si vous exécutez ActiveMQ intégré, vous pouvez utiliser l'API pour supprimer des destinations: La région.removeDestination

    InformationsquelleAutor Andrejs
  2. 4

    Pour supprimer une destination de ActiveMQ par programme, vous aurez besoin de le faire via JMX à l'aide de la removeTopic et removeQueue méthodes sur le courtier MBean (org.apache.activemq:BrokerName=localhost,Type=Broker). J'ai posté un exemple de code pour le démontrer, y compris l'utilisation de la removeTopic méthode, plus sur l'Essentiel:

    http://gist.github.com/439668

    Espère que ça aide.

    Bruce

    InformationsquelleAutor bsnyder
  3. 2

    Si vous utilisez printemps JmsTemplate, vous pouvez le faire de cette façon:

    Connection cn = getJmsTemplate().getConnectionFactory().createConnection();
ActiveMQDestination destination = ActiveMQDestination.createDestination(queueName, ActiveMQDestination.QUEUE_TYPE);             

if(cn instanceof PooledConnection){
    ((PooledConnection)cn).getConnection().destroyDestination(destination );
}
    InformationsquelleAutor Yu Jiaao
  4. 0

    Alors il n'y a pas beaucoup d'exemples concrets, il y a peu de documentation à ce sujet ici :
    http://activemq.apache.org/how-do-i-purge-a-queue.html

    • Grâce nos, je vais jeter un oeil à la BrokerViewMBean interface plus tard et voir ce que je peux faire avec elle. Je vais vous laisser savoir si cela fonctionne.
    InformationsquelleAutor nos