Hi Yong Hao Gao ,

Thank you for reply. But , I don't have any idea about to limit the TestQueue and how it works..?Could you please help me out

package com.vmchannel.listener;

import javax.ejb.ActivationConfigProperty;

import javax.ejb.MessageDriven;

import javax.inject.Inject;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.ObjectMessage;

import org.jboss.ejb3.annotation.ResourceAdapter;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import com.common.exception.ApplicationException;

import com.common.utils.ApplicationConstants;

import com.common.utils.JsonUtils;

import com.communication.destination.Queues;

import com.communication.message.ComponentMessage;

import com.communication.message.IdentificationDetail;

import com.communication.message.content.VoiceMessage;

import com.vmchannel.model.IVMChannelModel;

/**

* Message-Driven Bean implementation class for: VoiceMessageListener

*/

@MessageDriven(activationConfig = {

        @ActivationConfigProperty(propertyName="messageSelector", propertyValue="MESSAGE_TYPE='VoiceMessage'"),

        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),

        @ActivationConfigProperty(propertyName = "destination", propertyValue = Queues.VOICEMESSAGE_QUEUE), })

@ResourceAdapter("hornetq-ra.rar")

public class VMChannelListener implements MessageListener {

  private @Inject IVMChannelModel vmChannelModel;

  /**

  * Logger for this class

  */

  private Logger logger = LoggerFactory.getLogger(VMChannelListener.class);

    /**

     * Default constructor.

     */

    public VMChannelListener() {

        // TODO Auto-generated constructor stub

    }

  /**

     * @see MessageListener#onMessage(Message)

     */

    @SuppressWarnings("unchecked")

  public void onMessage(Message message) {

    logger.info("VoiceMailListener onMessage(Message message) - START");

    try {

    ObjectMessage  objectMessage = (ObjectMessage) message;

    ComponentMessage<VoiceMessage>  componentMessage =(ComponentMessage<VoiceMessage>) objectMessage.getObject();

    logger.info("VoiceMessage Recieved : \n {} ",JsonUtils.toJson(componentMessage));

    if (!(componentMessage==null)) {

  VoiceMessage voiceMessage = componentMessage

  .getMessageContent();

  IdentificationDetail identificationDetail = componentMessage

  .getIdentificationDetails();

  if (!(voiceMessage == null) && !(identificationDetail == null)) {

  vmChannelModel.processVoiceMessage(identificationDetail,

  voiceMessage);

  } else {

  // VoiceMessage | IdentificationDetail Object is required to process

  throw new ApplicationException(

  ApplicationConstants.ES_VM_01);

  }

  }

    else{

    //ComponentMessage is null

    throw new ApplicationException(

  ApplicationConstants.ES_VM_01);

    }

  } catch (Exception e) {

  logger.error("VoiceMailListener onMessage(Message message)",e);

  }

    }

}

Hi Yong Hao Gao ,

Please assume that there are multiple instance more than 2 like 4 jboss server instances and 2 hornetq servers.