in activemq-web-console/src/main/java/org/apache/activemq/web/controller/SendMessage.java [179:242]
protected void appendHeaders(Message message, HttpServletRequest request) throws JMSException {
message.setJMSCorrelationID(jmsCorrelationID);
if (jmsReplyTo != null && jmsReplyTo.trim().length() > 0) {
message.setJMSReplyTo(ActiveMQDestination.createDestination(jmsReplyTo, ActiveMQDestination.QUEUE_TYPE));
}
message.setJMSType(jmsType);
// now lets add all of the parameters
Map map = request.getParameterMap();
if (map != null) {
for (Iterator iter = map.entrySet().iterator(); iter.hasNext();) {
Map.Entry entry = (Map.Entry) iter.next();
String name = (String) entry.getKey();
if (name.equals("secret")) {
continue;
}
Object value = entry.getValue();
if (isValidPropertyName(name)) {
if (value instanceof String[]) {
String[] array = (String[]) value;
if (array.length > 0) {
value = array[0];
} else {
value = null;
}
}
if ((name.equals("AMQ_SCHEDULED_DELAY") || name.equals("AMQ_SCHEDULED_PERIOD"))) {
if (value != null) {
String str = value.toString().trim();
if (str.length() > 0) {
message.setLongProperty(name, Long.parseLong(str));
}
}
} else if (name.equals("AMQ_SCHEDULED_REPEAT")) {
if (value != null) {
String str = value.toString().trim();
if (str.length() > 0) {
message.setIntProperty(name, Integer.parseInt(str));
}
}
} else if (name.equals("AMQ_SCHEDULED_CRON")) {
if (value != null) {
String str = value.toString().trim();
if (str.length() > 0) {
message.setStringProperty(name, str);
}
}
} else {
if (value instanceof String) {
String text = value.toString().trim();
if (text.length() == 0) {
value = null;
} else {
value = text;
}
}
if (value != null) {
message.setObjectProperty(name, value);
}
}
}
}
}
}