[jira] [Created] (AMQ-6205) When two object messages are submitted to the queue, only the second message is ever read by the receiver

["David Johnson (JIRA)" <ji...@apache.org>]

David Johnson created AMQ-6205:
----------------------------------

             Summary: When two object messages are submitted to the queue, only the second message is ever read by the receiver
                 Key: AMQ-6205
                 URL: https://issues.apache.org/jira/browse/AMQ-6205
             Project: ActiveMQ
          Issue Type: Bug
          Components: Transport
    Affects Versions: 5.13.2
         Environment: AMQ version is 5.13.2.
Java 1.8.0_74
transportConnector uri="vm://localhost"
OS is Windows 10
            Reporter: David Johnson


This is cross-posted at http://stackoverflow.com/questions/35896002/activemq-jms-losing-messages-what-am-i-missing

What am I missing?  I am hoping this is a PICNIC error (Problem In Chair, Not In Computer), but if so I am not seeing how.

Given a simple test case, two Object messages are transmitted, one with data and the other being an end-of-data marker. Only the end-of-data marker is being received. This can be confirmed by looking at the message ID in the log.

The queue is created at the beginning of the job, and destroyed after the job completes.

If I run a larger number of transactions, I see about a 50% receive rate.

The logs clearly show that the receiver was started before the first message was put on the queue, both messages are being put on the queue, but only the second message is actually being received.

Both the sender and receiver are on the same JVM. Each has its own Session and Connection.


Transmit code:

    private void doSomeStuffInTransaction (final Object model) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                try {
                    doSomeStuff ( model );

                    ObjectMessage message = session.createObjectMessage(
                            (model.getRoot() == null)
                            ? null
                            : model.getRoot().getContents().getId());
                    messageProducer.send(message);
                    logger.debug("Sent: {}", message.toString());
                }catch (Exception e) {
                      //use this to rollback exception in case of exception
                    status.setRollbackOnly();
                    throw new RuntimeException(e.getmessage(), e);
                }   

            }});
    }   
Receiver code:

public Object read() throws Exception,
        UnexpectedInputException, ParseException,
        NonTransientResourceException {

    Object result = null;

    logger.debug("Attempting to receive message on connection: ", connection.toString());

    ObjectMessage msg = (ObjectMessage) messageConsumer.receive();
    logger.debug("Received: {}", msg.toString());
    result = msg.getObject();

    return result;
}
Log snip:

DEBUG com.mylib.SelectedDataJmsReader - Attempting to receive message on connection: 
... snip ...
DEBUG com.mylib.SelectedDataJmsWriter - Sent: ActiveMQObjectMessage {commandId = 0, responseRequired = false, messageId = ID:zip-51438-1457536143607-4:1:5:1:1, originalDestination = null, originalTransactionId = null, producerId = null, destination = queue://Workorders via SQL.383, transactionId = null, expiration = 0, timestamp = 1457536412608, arrival = 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@3c21d3e0, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}
INFO  com.mylib.SelectedDataJmsWriter - Committed 1 hierarchies to redo log and JMS queue
INFO  com.mylib.SourceSelectionReaderImpl - Returning empty treemodel and end-of-stream placeholder.
DEBUG com.mylib.SelectedDataJmsWriter - Sent: ActiveMQObjectMessage {commandId = 0, responseRequired = false, messageId = ID:zip-51438-1457536143607-4:1:5:1:2, originalDestination = null, originalTransactionId = null, producerId = null, destination = queue://Workorders via SQL.383, transactionId = null, expiration = 0, timestamp = 1457536412696, arrival = 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}
INFO  com.mylib.SelectedDataJmsWriter - Committed 1 hierarchies to redo log and JMS queue
DEBUG com.mylib.SelectedDataJmsReader - Received: ActiveMQObjectMessage {commandId = 19, responseRequired = true, messageId = ID:zip-51438-1457536143607-4:1:5:1:2, originalDestination = null, originalTransactionId = null, producerId = ID:zip-51438-1457536143607-4:1:5:1, destination = queue://Workorders via SQL.383, transactionId = null, expiration = 0, timestamp = 1457536412696, arrival = 0, brokerInTime = 1457536412696, brokerOutTime = 1457536412697, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 1024, properties = null, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false}
INFO  com.mylib.SelectedDataJmsReader - executed read, found end-of-stream marker, returning null



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