private FilterableMessage wrap()

in client/src/main/java/org/apache/qpid/client/filter/JMSSelectorFilter.java [93:210]


    private FilterableMessage wrap(final AbstractJMSMessage message)
    {
        return new FilterableMessage()
        {
            public boolean isPersistent()
            {
                try
                {
                    return message.getJMSDeliveryMode() == DeliveryMode.PERSISTENT;
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public boolean isRedelivered()
            {
                try
                {
                    return message.getJMSRedelivered();
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public Object getHeader(String name)
            {
                try
                {
                    return message.getObjectProperty(name);
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public String getReplyTo()
            {
                return message.getReplyToString();
            }

            public String getType()
            {
                try
                {
                    return message.getJMSType();
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public byte getPriority()
            {
                try
                {
                    return (byte) message.getJMSPriority();
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public String getMessageId()
            {
                try
                {
                    return message.getJMSMessageID();
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public long getTimestamp()
            {
                try
                {
                    return message.getJMSTimestamp();
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public String getCorrelationId()
            {
                try
                {
                    return message.getJMSCorrelationID();
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }

            public long getExpiration()
            {
                try
                {
                    return message.getJMSExpiration();
                }
                catch (JMSException e)
                {
                    throw new SelectorParsingException(e);
                }
            }
        };
    }