使用Gatling將消息發佈到ActiveMQ

我一直在使用Gatling將消息發佈到ActiveMq服務器。我得到「java.lang.SecurityException：無效的用戶名：空或空」我使用有效的用戶名和密碼。這是我的測試代碼和拋出的異常。任何關於如何解決這個問題的建議都會有所幫助。使用Gatling將消息發佈到ActiveMQ

import io.gatling.core.Predef.Simulation 
import io.gatling.core.Predef._ 
import io.gatling.jms.Predef._ 
import io.gatling.core.config.Credentials 
import org.apache.activemq.ActiveMQConnectionFactory 
import org.apache.activemq.jndi.ActiveMQInitialContextFactory 
import javax.jms._ 
    class WebProducer extends Simulation{ 
     val jmsUsername:String="userName" 
     val jmsPwd:String="Password" 
     val jmsConfig = jms 
     .connectionFactoryName("ConnectionFactory") 
     .url("ssl://message01-dev.platform.net:61617") 
     .credentials(jmsUsername,jmsPwd) 
     .disableAnonymousConnect 
     .contextFactory(classOf[org.apache.activemq.jndi.ActiveMQInitialContextFactory].getName) 
     .listenerCount(1) 
     .usePersistentDeliveryMode 
     .receiveTimeout(6000) 

     val scn = scenario("JMS DSL test").repeat(1) { 
     exec(jms("req reply testing"). 
      reqreply 
      .queue("YourJMSQueueName") 
      .replyQueue("YourJMSQueueName") 
      .textMessage("payload To be posted") 
      .property("company_id", "1234598776665") 
      .property("event_type","EntityCreate") 
      .property("event_target_entity_type","Account")  
     ) 
     } 
     setUp(scn.inject(atOnceUsers(1))) 
     .protocols(jmsConfig)   
    }

以下是異常被拋出：

java.lang.SecurityException: Invalid username: null or empty

來源

2016-06-23 Alferd Nobel

好吧，我得到了這個工作增加了兩兩件事：

- .disableAnonymousConnect after .credentials(jmsUsername,jmsPwd) 
- .replyQueue(jmsQueueName) after .queue(jmsQueueName)

我編輯了上面的代碼，以反映相同。快樂的加特林！

來源

2016-07-19 23:50:30

使用Gatling將消息發佈到ActiveMQ

回答

相關問題