[jira] [Commented] (AMQ-5877) The Queue got hanged with a scenario said in description with version 5.11.1 but this works with version 5.5.1

["Christopher L. Shannon (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/AMQ-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622168#comment-14622168 ] 

Christopher L. Shannon commented on AMQ-5877:
---------------------------------------------

I would recommend 2 things...first you should try this against the latest 5.12-SNAPSHOT as there have been a lot of fixes that have gone into it.  Second, your test case doesn't include the BrokerService being started and relies on an external broker.  You should include an embedded broker in your test case because it will be much easier to run your test plus a Broker can be configured many different ways so by including a Broker in your test you can include the exact configuration that is causing your issue.  Take a look at some of the unit tests in the ActiveMQ build under the activemq-unit-tests project if you need some examples on how to configure an embedded broker in a test case.

> The Queue got hanged with a scenario said in description with version 5.11.1 but this works with version 5.5.1
> --------------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-5877
>                 URL: https://issues.apache.org/jira/browse/AMQ-5877
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.11.1
>         Environment: Window 7 Enterprise Edition,  64 bit
> JDK 1.8.0_25, 64 bit 
> apache-activemq-5.11.1
>            Reporter: siva phani kumar
>            Priority: Blocker
>
> We are unable to read the message with message selector if we follow the below steps in ActiveMQ 5.11.1 
> * Start ActiveMQ
> * Send Two messages
> * Read one message with our selector,Using consumer.recieve() API
> * Send One more message, And hold the messageId
> * Read the message with the above message Id which we are holding as a selector("JMSMessageID='" + messageId + "'") immediately.
> * Now message we wont able to read, consumer thread will be waiting infinitely
> *Note :*  Its required activemq-all-5.11.1.jar,Junit jars need to be in classpath.
> Issue reproducible prgoram
> {code:java}
> import java.util.Properties;
> import javax.jms.Connection;
> import javax.jms.ConnectionFactory;
> import javax.jms.Message;
> import javax.jms.MessageConsumer;
> import javax.jms.MessageProducer;
> import javax.jms.Queue;
> import javax.jms.Session;
> import javax.naming.Context;
> import javax.naming.InitialContext;
> import org.junit.AfterClass;
> import org.junit.Assert;
> import org.junit.BeforeClass;
> import org.junit.Test;
> /**
>  * We are unable to read the message with message selector if we follow the
>  * below steps in ActiveMQ 5.11.1
>  * <ul>
>  * <li>Start ActiveMQ</li>
>  * <li>Send Two messages</li>
>  * <li>Read one message with our selector,Using consumer.recieve() API</li>
>  * <li>Send One more message, And hold the messageId</li>
>  * <li>Read the message with the above message Id which we are holding as a
>  * selector("JMSMessageID='" + messageId + "'") immediately.</li>
>  * <li>Now message we wont able to read, consumer thread will be waiting
>  * infinitely</li>
>  * </ul>
>  * <b>Note : </b> Its required activemq-all-5.11.1.jar,Junit jars need to be in classpath.
>  *
>  */
> public final class MessageSelectorJunit {
> 	private static Connection connection = null;
> 	private static final String CONTEXT_FACTORY = "org.apache.activemq.jndi.ActiveMQInitialContextFactory";
> 	private static final String URL = "tcp://localhost:61616";
> 	private static final String QUEUE_NAME = "TestQueue";
> 	@BeforeClass
> 	public static void oneTimeSetUp() throws Exception {
> 		Properties properties = new Properties();
> 		properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, CONTEXT_FACTORY);
> 		properties.setProperty(Context.PROVIDER_URL, URL);
> 		// Connection Creation
> 		Context context = new InitialContext(properties);
> 		ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("QueueConnectionFactory");
> 		connection = connectionFactory.createConnection();
> 		connection.start();
> 	}
> 	@Test
> 	public void testScenario() throws Exception {
> 		// Message1
> 		sendJMSMessage();
> 		sendJMSMessage();
> 		getJMSMessage(null);
> 		// Message2
> 		String messageId2 = sendJMSMessage();
> 		String messageSelector = "JMSMessageID='" + messageId2 + "'";
> 		Assert.assertNotNull("Expected message to be read with message selector : " + messageSelector,
> 				getJMSMessage(messageSelector));
> 	}
> 	private String sendJMSMessage() throws Exception {
> 		String messageId = null;
> 		Session session = null;
> 		MessageProducer producer = null;
> 		try {
> 			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
> 			producer = session.createProducer(session.createQueue(QUEUE_NAME));
> 			Message msg = session.createTextMessage("Test Message");
> 			producer.send(msg);
> 			messageId = msg.getJMSMessageID();
> 			System.out.println("Send MessageId : " + messageId);
> 		} finally {
> 			producer.close();
> 			session.close();
> 		}
> 		return messageId;
> 	}
> 	private String getJMSMessage(String messageSelector) throws Exception {
> 		String recievedId = null;
> 		MessageConsumer consumer = null;
> 		Session session = null;
> 		try {
> 			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
> 			Queue queue = session.createQueue(QUEUE_NAME);
> 			System.out.println("Started Recieving the message with the message selector : " + messageSelector);
> 			consumer = session.createConsumer(queue, messageSelector);
> 			connection.start();
> 			Message msg = consumer.receive(1000);
> 			if (msg != null) {
> 				recievedId = msg.getJMSMessageID();
> 				System.out.println("Message Recieved, Id : " + msg.getJMSMessageID());
> 			} else {
> 				System.out.println("Message not recieved.");
> 			}
> 		} finally {
> 			consumer.close();
> 			session.close();
> 		}
> 		return recievedId;
> 	}
> 	@AfterClass
> 	public static void oneTimeTearDown() throws Exception {
> 		if (connection != null) {
> 			connection.close();
> 		}
> 	}
> }
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)