Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <28916420.post@talk.nabble.com>
Date: Thu, 17 Jun 2010 09:08:20 -0700 (PDT)
From: Kumar Pawan <pawankrmodi@gmail.com>
To: dev@activemq.apache.org
Subject: Sending a message but not able to receieve this mesage.
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


Sending a message but not able to receieve this mesage. when i change message
QueueName then its able receieve for few messsages again i have to change
the queue name to receieve next messages. But i am able to see every message
sent and receive in ActiveMQ admin. please help me why every time i have
change queue name.

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

public class MsgReceiver implements MessageListener {
private static int ackMode;
private static String messageQueueName;
private static String messageBrokerUrl;

private Session session;
private boolean transacted = false;
MessageConsumer consumer = null;
CreateDS createDS = new CreateDS();

static {
messageBrokerUrl = ReadProperty.getValues("messageBrokerUrl");
messageQueueName = "tmsmevent.messages";
ackMode = Session.AUTO_ACKNOWLEDGE;
}

private void setupMessageQueueConsumer() throws Exception {

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
messageBrokerUrl);
Connection connection = null;

try 
{
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(transacted, ackMode);
Destination adminQueue = session.createQueue(messageQueueName);
// Set up a consumer to consume messages off of the admin queue
consumer = session.createConsumer(adminQueue);
MsgReceiver msgReceiver = new MsgReceiver();
consumer.setMessageListener(msgReceiver);
} 
catch (Exception e) 
{
// Handle the exception appropriately
e.printStackTrace();
}
/*
* finally 
* { 
* try 
* { 
* if (consumer != null) 
* { 
* consumer.close(); 
* }
* 
* if (session != null) 
* { 
* session.close(); 
* }
* 
* if (connection != null) 
* { 
* connection.close(); 
* } 
* } 
* catch (Exception e)
* { 
* e.printStackTrace(); 
* } 
* }
*/
}

public void onMessage(Message message) {
try 
{

if (message instanceof TextMessage) 
{

TextMessage txtMsg = (TextMessage) message;
String messageText = txtMsg.getText();

System.out.println("Job Name: " + messageText);
}
} 
catch (Exception e) 
{
// Handle the exception appropriately
e.printStackTrace();
}
}
public static void main(String[] args) throws Exception {
new MsgReceiver().setupMessageQueueConsumer();
}
} 


-- 
View this message in context: http://old.nabble.com/Sending-a-message-but-not-able-to-receieve-this-mesage.-tp28916420p28916420.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.