Gerenciando filas do MQ

amateusPJ:

Boa tarde galera,

Preciso gerenciar as mensagens na minha fila do MQ do WebSphere. Contar mensagens na fila, removê-las, encontrar uma mensagen especifica e etc. Alguém sabe como fazê-lo? Procurei na internet mas achei um único exemplo (que não funciona) :???:  para WebSphere e alguns outros exemplos para JBoss (que não é meu caso) :sad: .

Agradeço muito!

tbm estou precisando mto saber como eu sei qtas mensagens possui em uma fila!!!.. se alguém puder ajudar!!!
vaelu!!!

Se não me engano, na instalação do MQ vem um console de gerenciamento junto… ou você precisa fazer via código?

[]´s

asaudate:

Se não me engano, na instalação do MQ vem um console de gerenciamento junto… ou você precisa fazer via código?

[]´s

preciso fazer via código!!!.. já consegui pegar esse fila… só preciso saber qtas msg existem nessa fila para colocar em uma condição (tipo ‘while’ ou ‘for’) para prosseguir com a minha regra de negócio!!!.. tenho que executar uma tarefa para todas as msg que estiverem na fila!!!

Tópico bem antigo mas vai que alguém ainda precise da resposta...

/**
 * Classe para percorrer uma fila
 * @author carlos.pomari
 */
public class PercorrendoFila {
	public static void main(String[] args) throws Exception {
		// serviço de nomes - JNDI
		InitialContext ic = new InitialContext();
		
		// fábrica de conexões JMS
		ConnectionFactory factory = (ConnectionFactory) 
			ic.lookup("jms/K19Factory");
		
		// fila
		Queue queue = (Queue) ic.lookup("jms/pedidos");
		
		// conexão JMS
		Connection connection = factory.createConnection();
		
		// sessão JMS
		Session session = connection.createSession(false, 
				Session.AUTO_ACKNOWLEDGE);
		
		// queue browser
		QueueBrowser queueBrowser = session.createBrowser(queue);
		
		Enumeration<TextMessage> messages = queueBrowser.getEnumeration();
		int count = 1;
		while (messages.hasMoreElements()) {
			TextMessage message = messages.nextElement();
			System.out.println(count + " : " + message.getText());
			count++;
		}
		
		// fechando
		queueBrowser.close();
		session.close();
		connection.close();
		
		System.out.println("FIM");
		System.exit(0);
	}
}