001/*
002 * Licensed to the Apache Software Foundation (ASF) under one or more
003 * contributor license agreements. See the NOTICE file distributed with
004 * this work for additional information regarding copyright ownership.
005 * The ASF licenses this file to You under the Apache license, Version 2.0
006 * (the "License"); you may not use this file except in compliance with
007 * the License. You may obtain a copy of the License at
008 *
009 *      http://www.apache.org/licenses/LICENSE-2.0
010 *
011 * Unless required by applicable law or agreed to in writing, software
012 * distributed under the License is distributed on an "AS IS" BASIS,
013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
014 * See the license for the specific language governing permissions and
015 * limitations under the license.
016 */
017package org.apache.log4j.or.jms;
018
019import org.apache.log4j.or.ObjectRenderer;
020import org.apache.logging.log4j.Logger;
021import org.apache.logging.log4j.status.StatusLogger;
022
023import javax.jms.Message;
024import javax.jms.JMSException;
025import javax.jms.DeliveryMode;
026
027/**
028 * Log4j 1.x JMS Message Renderer
029 */
030public class MessageRenderer implements ObjectRenderer {
031    private static final Logger LOGGER = StatusLogger.getLogger();
032
033    /**
034     Render a {@link javax.jms.Message}.
035     */
036    @Override
037    public
038    String  doRender(Object obj) {
039        if (obj instanceof Message) {
040            StringBuilder sb = new StringBuilder();
041            Message message = (Message) obj;
042            try {
043                sb.append("DeliveryMode=");
044                switch(message.getJMSDeliveryMode()) {
045                    case DeliveryMode.NON_PERSISTENT :
046                        sb.append("NON_PERSISTENT");
047                        break;
048                    case DeliveryMode.PERSISTENT :
049                        sb.append("PERSISTENT");
050                        break;
051                    default: sb.append("UNKNOWN");
052                }
053                sb.append(", CorrelationID=");
054                sb.append(message.getJMSCorrelationID());
055
056                sb.append(", Destination=");
057                sb.append(message.getJMSDestination());
058
059                sb.append(", Expiration=");
060                sb.append(message.getJMSExpiration());
061
062                sb.append(", MessageID=");
063                sb.append(message.getJMSMessageID());
064
065                sb.append(", Priority=");
066                sb.append(message.getJMSPriority());
067
068                sb.append(", Redelivered=");
069                sb.append(message.getJMSRedelivered());
070
071                sb.append(", ReplyTo=");
072                sb.append(message.getJMSReplyTo());
073
074                sb.append(", Timestamp=");
075                sb.append(message.getJMSTimestamp());
076
077                sb.append(", Type=");
078                sb.append(message.getJMSType());
079
080            } catch(JMSException e) {
081                LOGGER.error("Could not parse Message.", e);
082            }
083            return sb.toString();
084        }
085        return obj.toString();
086    }
087}