2016-06-23 2 views
4

나는 Gatling을 사용하여 ActiveMq 서버에 메시지를 게시했습니다. 내가 얻을 "java.lang.SecurityException : 잘못된 사용자 이름 : null 또는 비어 있습니다" tho 나는 유효한 사용자 이름과 비밀 번호를 사용합니다. 여기에 내 테스트 코드가 있으며 예외가 발생했습니다. 이 문제를 해결하는 방법에 대한 모든 정보는 도움이 될 것입니다.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 

답변

1

좋아, 나는 두 가지를 추가이 작업을 가지고 :

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

나는 동일을 반영하기 위해 위의 코드를 편집했다. 해피 갤링!

관련 문제