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);
}
}
};
}