Why does dequeue different from enqueue and from dispatch

[Michal Singer <Mi...@expand.com>]

Hi.
When i use spring to create a connection, i see in the jconsole that the
attributes on the Queue
DequeueCount
EnqueueCount
DispatchCount
are the same.

But when, i create a active mq connection with out spring, i get totally
differnet numbers.
For example:

DequeueCount = 0
EnqueueCount = 467
DispatchCount = 31

Does any one have any idea, what i am doing wrong?

Here is how i initalize the resources:
private synchronized void initMassagingConnections() /*throws
EVFailedProcessException*/
	{
		try
		{
			if (pcf == null && queueConnectionFactory == null)
			{
				pcf = new PooledConnectionFactory();
				queueConnectionFactory = new
ActiveMQConnectionFactory(QUEUE_CONNECION_FACTORY);
				queueConnectionFactory.setCopyMessageOnSend(false);
//				queueConnectionFactory.setProducerWindowSize(1024000);
				pcf.setConnectionFactory(queueConnectionFactory);
//				pcf.setMaxConnections(5);
//				pcf.setMaximumActive(5);
				
			}
			
			if(queueConnection == null)
			{
				queueConnection = (QueueConnection)pcf.createConnection();
				
				//queueConnection = queueConnectionFactory.createQueueConnection();
				queueConnection.start(); //Starts (or restarts) a connection's delivery
of incoming messages. A call to start on a connection that has already been
started is ignored.		
			}
			
			if(queueSessionSend == null)
			{
				/*
				 * If the session is transacted, the first parameter to
createQueueSession is true, 
				 * and the acknowledge mode parameter is ignored. If the session is not
transacted, 
				 * the first parameter to createQueueSession is false, and the
acknowledge mode parameter must be set.
				 */
				queueSessionSend = queueConnection.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
			}			
			if(queueSessionReceive == null)
			{
				queueSessionReceive = queueConnection.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
			}
			if(destinationSendClient == null)
			{
				destinationSendClient = queueSessionSend.createQueue(USER_QUEUE_NAME);
			}
			if(destinationSendAgent == null)
			{
				destinationSendAgent = queueSessionSend.createQueue(AGENT_QUEUE_NAME);
			}			
			if (queueSender == null)
			{
				queueSender = queueSessionSend.createSender(null);
			}
			if (destinationReceive == null)
			{
				destinationReceive =  queueSessionReceive.createQueue("result_queue");
			}
		}
		catch(JMSException e)
		{
			logger.error(e , e , EVError.JMS_CONNECTION_EXCEPTION);
			//e.printStackTrace();
		}	


public void operate(final LogicRequest logicRequest)
	{
//        QueueSender queueSender = null;
	
debugUtils.writeln("**************************************************************");
        try 
        {
        	final MessageConsumer messageConsumer; 	
        	final MessageConsumerObserver consumerObserver = new
MessageConsumerObserver();
//        	consumerObserver.setObserver((DefaultObserver)observer);
        	  	
//        	final TemporaryQueue destinationReceive =
queueSessionReceive.createTemporaryQueue();
        
         	messageConsumer =
queueSessionReceive.createConsumer(destinationReceive);
         	debugUtils.writeln("Producer: send request - " +
logicRequest.getLogicPath()+ ", temp queue for response: "+
destinationReceive.toString());
         	
         	
         	//System.out.println("CONSUMER ID: " +
messageConsumer.toString());
        	consumerObserver.setConsumer(messageConsumer , destinationReceive);
        		
        	messageConsumer.setMessageListener(new MessageListener()
        	{
        		public void onMessage(Message message)
        		{
        			try
        			{
        				message.acknowledge();
	        			Object logicResponse = ((ObjectMessage)message).getObject();
	         			
	        			if(logicResponse instanceof LogicResponse)
	        			{       				
	        				consumerObserver.update((LogicResponse)logicResponse);
	        			}
	        			else 
	        			{
	        				throw new JMSException("Fetched message from Temporary queue
which is not from type LogicResponse.");
	        			}
	        			
        			}
        			catch(Exception e)
        			{
        				logger.error(e, EVError.JMS_GET_MESSAGE);
        				//e.printStackTrace();
        			}  
        		}
        		
        	});
        	
        	
        	ObjectMessage objMsg =
queueSessionSend.createObjectMessage(logicRequest);
        	objMsg.setJMSReplyTo(destinationReceive);
        	
        	queueSender.send((Queue)destinationSendAgent, objMsg);
        	
        	
        	objMsg = null;
//        	queueSender.close();
         
        } 
        catch (JMSException e) 
        {
        	System.out.println(e.getLocalizedMessage());
        	System.out.println(e.toString());
           // e.printStackTrace();
        } 
        
	}
		 
-- 
View this message in context: http://www.nabble.com/Why-does-dequeue-different-from-enqueue-and-from-dispatch-tp16144292s2354p16144292.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.