ActiveMQ + Jencks Performance

[andriy_heikal <an...@telkom.net>]

Hello all,

I'm implementing ActiveMQ in Spring environment and using Jencks for
consumer as a listener. Performance for   6000 messages sent in one time is
47msg/sec... but when testing ActiveMQ with simple java class I get about 3k
msg/sec. Whats the problem? can anybody help me? anyway my testing platform
is notebook with dual core 1.7GHz and 1.5GB memory. Please refer to my code
below.

My Producer code :
public class ProducerAndListener {
	
	    public static String  Producer(String input) throws JMSException {
	        
	    	boolean jmsSuccess = false;
	    	boolean isJMSException = false;
	    	javax.jms.Connection connection = null; 
	        javax.jms.Session session = null; 
	        while(!jmsSuccess)
	        {
	        	try {
						org.apache.activemq.ActiveMQConnectionFactory connectionFactory = new
org.apache.activemq.ActiveMQConnectionFactory(
"tcp://localhost:61616?jms.prefetchPolicy.all=100" ); 
						connectionFactory.setUseAsyncSend(true); // This is the magic words
"+connectionFactory.getBrokerURL());
						//connectionFactory.setBrokerURL("tcp://192.168.1.137:61616");
		                connection = connectionFactory.createConnection(); 
		                
		                session = connection.createSession( false,
javax.jms.Session.AUTO_ACKNOWLEDGE ); 
		                javax.jms.Destination destination = session.createQueue(
"sminderQueue" ); 
		                javax.jms.MessageProducer producer =
session.createProducer( destination ); 
		                producer.setDeliveryMode(
javax.jms.DeliveryMode.PERSISTENT ); 
		                connection.start(); 

		                javax.jms.TextMessage message =
session.createTextMessage(); 
	

		                        message.setText(input); 
		                        producer.send( message ); 

		               jmsSuccess = true;
		        }
		        catch ( javax.jms.JMSException je)
		        {
		        	if (!isJMSException)
		        		isJMSException = true;
		        	System.out.println("[ERROR][1] the jms error: "+je.toString());
		        }
		        catch ( Exception eOuter ) { 
		        	if (!isJMSException)
		        		System.out.println("[ERROR][3] the other error:
"+eOuter.toString()); 
		        } 
	        }

	                try { 
	                        if ( session != null ) session.close(); 
	                        if ( connection != null ) connection.close(); 
	                } 
	                catch ( Exception eInner ) { 
	                        eInner.printStackTrace(); 

	        }
	    	
	    	
	        return ("Sukses");
	    }

}

My Consumer code :
public class MessageConsumer implements MessageListener
{
	public MessageConsumer()
	{
	}
	
	public synchronized void onMessage(Message message)
	{
		String contentSMS = "";

		
		TextMessage textMessage = (TextMessage)message;

		

		System.out.println("####the content: "+textMessage);
	}

}


Spring Bean Conf :
<bean id="messageConsumer"
class="com.trendcom.app.sminder.webapp.jms.MessageConsumer"
autowire="byName"/>
    
    <bean id="transactionManager"
class="org.jencks.factory.TransactionManagerFactoryBean" singleton="true"/>
    
    <bean id="jencks" class="org.jencks.JCAContainer">
  		<property name="transactionManager" ref="transactionManager"/>
  		<property name="threadPoolSize" value="25"/>

  		<!-- the JCA Resource Adapter -->
  		<property name="resourceAdapter">
    		<bean id="activeMQResourceAdapter"
class="org.apache.activemq.ra.ActiveMQResourceAdapter">
      			<property name="serverUrl" value="tcp://localhost:61616"/>
    		</bean>
  		</property>
	</bean>
	
	<bean id="inboundConnectorA" class="org.jencks.JCAConnector">

  		<property name="jcaContainer" ref="jencks" />

  		<!-- subscription details -->
  		<property name="activationSpec">
    		<bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
      			<property name="destination" value="sminderQueue"/>
      			<property name="destinationType" value="javax.jms.Queue"/>
      			<property name="maxSessions" value="100"/>
                <property name="maxMessagesPerSessions" value="100"/>
    		</bean>
  		</property>

  		<property name="ref" value="messageConsumer"/>
	</bean>

Many thanks...

-- 
View this message in context: http://www.nabble.com/ActiveMQ-%2B-Jencks-Performance-tp14249994s2354p14249994.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ + Jencks Performance

[Mario Siegenthaler <ms...@inventsoft.ch>]

I'd say it's a problem related to connection pooling (or the lack
thereof). To do a simple test try replacing your
ActiveMQConnectionFactory with the PooledActiveMQConnectionFactory
(not sure about the name, but something along this line)

Mario

On 12/10/07, andriy_heikal <an...@telkom.net> wrote:
> I'm implementing ActiveMQ in Spring environment and using Jencks for
> consumer as a listener. Performance for   6000 messages sent in one time is
> 47msg/sec... but when testing ActiveMQ with simple java class I get about 3k
> msg/sec. Whats the problem? can anybody help me? anyway my testing platform
> is notebook with dual core 1.7GHz and 1.5GB memory. Please refer to my code
> below.