Ajuda em MQ - filas

public class ConsumidorMQRecepcaoNFe_10threads_5procs implements Runnable {
	private Session session = null;
	static final Logger log = Logger.getLogger(ConsumidorMQRecepcaoNFe_10threads_5procs.class);
	
	public void run() {
		//System.out.println(new Date());
		onMessage();
	}
	
	public void onMessage() {
		log.info(" ################# RECEBEU A MENSAGEM ");
		Connection connection = null;
		MessageConsumer receiver = null;

		try {
			MQQueueConnectionFactory connectionFactory = new MQQueueConnectionFactory();

			connectionFactory.setHostName(LerArquivoPropertie.getPropriedade(ParametroDFe.DFE_CONFIGURACOES_PROPERTIES.getValue(), "nfe.dfe.mq.host.name"));
			connectionFactory.setPort(Integer.parseInt(LerArquivoPropertie.getPropriedade(ParametroDFe.DFE_CONFIGURACOES_PROPERTIES.getValue(), "nfe.dfe.mq.porta")));
			connectionFactory.setChannel(LerArquivoPropertie.getPropriedade(ParametroDFe.DFE_CONFIGURACOES_PROPERTIES.getValue(), "nfe.dfe.mq.channel"));
			connectionFactory.setQueueManager("");
			connectionFactory.setTransportType(Integer.parseInt(LerArquivoPropertie.getPropriedade(ParametroDFe.DFE_CONFIGURACOES_PROPERTIES.getValue(), "nfe.dfe.mq.transport.type")));
			connection = connectionFactory.createConnection();
			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			final MQQueue destination = new MQQueue(LerArquivoPropertie.getPropriedade(ParametroDFe.DFE_CONFIGURACOES_PROPERTIES.getValue(), "nfe.dfe.queue.nfe"));
			receiver = session.createConsumer(destination);
			
			connection.start();
			
			int qtdMaxProc = 5;
			
			// tamanho maximo do lote - 500kb
			int tamanhoLote = Integer.parseInt(LerArquivoPropertie.getPropriedade(ParametroDFe.DFE_CONFIGURACOES_PROPERTIES.getValue(), "nfe.dfe.tamanho.arquivo.lote"));
			
			double temposFila[] = new double[50];
			double temposTratarXml[] = new double[50];
			// double temposSession[] = new double[50];
			double temposText[] = new double[50]; 
			
			ManipulaXml map = new ManipulaXml();
			
			String numProtLog = null;
			
			for (int i = 0; ((i < qtdMaxProc) && conjuntoAN.length() < tamanhoLote); i++) {
				final TextMessage textMessage = (TextMessage)receiver.receiveNoWait();
				if(textMessage != null) {
					if(i == 0)
						numProtLog = textMessage.getJMSCorrelationID();
						
					String msg = textMessage.getText();
					map.limparXml();
					map.setXmlDFe(msg);
					tratarXml(msg, Long.parseLong(textMessage.getJMSCorrelationID()), map);
						
					} else {
						log.info(" ################# Atencao!  Não existe mensagem na fila para consumo neste momento!");
				
				}
			} // fim for
			// log.info(" ################# Log para protocolo inicial lote " + numProtLog +  " : Tempo for : " + calcularTempo(inicioFor, System.currentTimeMillis()));
			
			// calculo tempo fila
			double somaTotalFila = 0;
			for (int i = 0; i < temposFila.length; i++) {
				somaTotalFila += temposFila[i];  
			}
			
			// calculo tempo banco
			double somaTotalTratarXml = 0;
			for (int i = 0; i < temposTratarXml.length; i++) {
				somaTotalTratarXml += temposTratarXml[i];
			}
			
			// calculo tempo text
			double somaTotalText = 0;
			for (int i = 0; i < temposText.length; i++) {
				somaTotalText += temposText[i];
			}
			log.info(" ################# Log para protocolo inicial lote " + numProtLog +  " : Tempo Consumo fila " + somaTotalFila + " s. Tempo tratar xml " + somaTotalTratarXml  + " s. Tempo Text " + somaTotalText + "s. Tamanho da lista a ser enviada ao ambiente nacional " + listaControleDFeVO.size() + " e nota enviada é de: " + conjuntoAN.toString().length() + " em bytes");
			
		} catch (JMSException exception) {
			exception.printStackTrace();
			throw new RuntimeException();
		
		} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException();
			
		} finally {
			// fechar(consumer);
			fechar(receiver);
			fechar(session);
			fechar(connection);
		}
	}