[
https://issues.apache.org/jira/browse/AMQ-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christopher L. Shannon resolved AMQ-5877.
-----------------------------------------
Resolution: Fixed
Fix Version/s: 5.12.0
This test fails in 5.11.1 and 5.11.2 but passes in 5.12.0. 5.12.0 is currently
under vote and should be released in a day or two.
I'm closing this out because this has been fixed already by one of the other
200 issues that apply to 5.12.0.
If necessary, I suppose we could use git-bisect to try and figure out which
commit or commits fixed this issue and put it into the 5.11.x branch in case
there is a 5.11.3 release.
> 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
> Fix For: 5.12.0
>
> Attachments: AMQ5877Test.java
>
>
> 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)
