Forum Discussion

mahesh_avinash1's avatar
mahesh_avinash1
Occasional Contributor
9 years ago

JMS queue messages are not consuming using groovy script

Below is my code to consume the message from Queue1, but I'm unable to consume the message. My requirement is to  consumer queue always consume the message once script is run.

 

def Queue1_jmsEndpoint = new JMSEndpoint("jms://activeMQsession::-::queue_Queue1");//properties.Queue1
def Queue1_hermes = HermesUtils.getHermes( context.testCase.testSuite.project, Queue1_jmsEndpoint.sessionName)
def Queue1_jmsConnectionHolder = new JMSConnectionHolder( Queue1_jmsEndpoint, Queue1_hermes, false, null ,null ,null);
Session Queue1_queueSession = Queue1_jmsConnectionHolder.getSession();
Queue Queue1_queueReceive = Queue1_jmsConnectionHolder.getQueue(Queue1_jmsConnectionHolder.getJmsEndpoint().getReceive() );

MessageConsumer consumer = Queue1_queueSession.createConsumer(Queue1_queueReceive);
Message message = null;
while((message = consumer.receiveNoWait()) != null){
//do nothing
}
 
Queue1_jmsConnectionHolder.closeAll()

 

  • MarcusJ's avatar
    MarcusJ
    Moderator
    9 years ago

    Hello,

     

    Is there any messages on the queue to be consumed? Is activeMQsession the correct name of the session you created in HermesJMS?  Attach the hermes-config.xml file if possible.

     

     

    Regards,

    Marcus

    SmartBear Suport