}
private void startReceive(final Map<String, TextMessage> msgs) throws Exception
{
JBossConnectionFactory cf1 = (JBossConnectionFactory)ic[1].lookup("/ConnectionFactory");
Connection conn1 = cf1.createConnection();
Session sess1 = conn1.createSession(false, Session.CLIENT_ACKNOWLEDGE);
MessageConsumer cons1 = sess1.createConsumer(queue[1]);
cons1.setMessageListener(new MessageListener() {
public void onMessage(Message m)
{