shims/qpid-jms/src/main/java/org/apache/qpid/interop_test/jms_hdrs_props_test/Sender.java [136:167]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                _messageProducer.send(msg, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE);
                _msgsSent++;
            }
        }
        _connection.close();
    }
    
    protected Message createMessage(String jmsMessageType, String key, String testValue, int i) throws Exception {
        Message message = null;
        switch (jmsMessageType) {
        case "JMS_MESSAGE_TYPE":
            message = createJMSMessage(key, testValue);
            break;
        case "JMS_BYTESMESSAGE_TYPE":
            message = createJMSBytesMessage(key, testValue);
            break;
        case "JMS_MAPMESSAGE_TYPE":
            message = createJMSMapMessage(key, testValue, i);
            break;
        case "JMS_OBJECTMESSAGE_TYPE":
            message = createJMSObjectMessage(key, testValue);
            break;
        case "JMS_STREAMMESSAGE_TYPE":
            message = createJMSStreamMessage(key, testValue);
            break;
        case "JMS_TEXTMESSAGE_TYPE":
            message = createTextMessage(testValue);
            break;
        default:
            throw new Exception("Internal exception: Unexpected JMS message type \"" + jmsMessageType + "\"");
        }
        return message;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



shims/qpid-jms/src/main/java/org/apache/qpid/interop_test/jms_messages_test/Sender.java [123:154]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                _messageProducer.send(msg, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE);
                _msgsSent++;
            }
        }
        _connection.close();
    }
    
    protected Message createMessage(String jmsMessageType, String key, String testValue, int i) throws Exception {
        Message message = null;
        switch (jmsMessageType) {
        case "JMS_MESSAGE_TYPE":
            message = createJMSMessage(key, testValue);
            break;
        case "JMS_BYTESMESSAGE_TYPE":
            message = createJMSBytesMessage(key, testValue);
            break;
        case "JMS_MAPMESSAGE_TYPE":
            message = createJMSMapMessage(key, testValue, i);
            break;
        case "JMS_OBJECTMESSAGE_TYPE":
            message = createJMSObjectMessage(key, testValue);
            break;
        case "JMS_STREAMMESSAGE_TYPE":
            message = createJMSStreamMessage(key, testValue);
            break;
        case "JMS_TEXTMESSAGE_TYPE":
            message = createTextMessage(testValue);
            break;
        default:
            throw new Exception("Internal exception: Unexpected JMS message type \"" + jmsMessageType + "\"");
        }
        return message;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -