Package org.apache.activemq.artemis.utils.collections

Class TypedProperties

java.lang.Object

org.apache.activemq.artemis.utils.collections.TypedProperties

Direct Known Subclasses:

TypedProperties

public class TypedProperties
extends Object

Property Value Conversion.

This implementation follows section 3.5.4 of the Java Message Service specification (Version 1.1 April 12, 2002).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TypedProperties.StringValue
static class	TypedProperties.TypedPropertiesDecoderPools
static class	TypedProperties.TypedPropertiesStringSimpleStringPools

Constructor Summary

Constructors

Constructor	Description
TypedProperties()
TypedProperties(Predicate<SimpleString> internalPropertyPredicate)
TypedProperties(Predicate<SimpleString> internalPropertyPredicate, Predicate<SimpleString> amqpPropertyPredicate)
TypedProperties(TypedProperties other)

Method Summary

Modifier and Type	Method	Description
void	clear()
boolean	clearAMQPProperties()
boolean	clearInternalProperties()
boolean	containsProperty(SimpleString key)
void	decode(io.netty.buffer.ByteBuf buffer)
void	decode(io.netty.buffer.ByteBuf buffer, TypedProperties.TypedPropertiesDecoderPools keyValuePools)
int	encode(io.netty.buffer.ByteBuf buffer)
void	forEach(BiConsumer<SimpleString,Object> action)	This method is read-only.
void	forEachKey(Consumer<SimpleString> action)	This method is read-only.
Boolean	getBooleanProperty(SimpleString key)
Byte	getByteProperty(SimpleString key)
Byte	getByteProperty(SimpleString key, Supplier<Byte> defaultValue)
byte[]	getBytesProperty(SimpleString key)
Character	getCharProperty(SimpleString key)
Double	getDoubleProperty(SimpleString key)
int	getEncodeSize()
Float	getFloatProperty(SimpleString key)
Integer	getIntProperty(SimpleString key)
Long	getLongProperty(SimpleString key)
Map<String,Object>	getMap()
Set<String>	getMapNames()
int	getMemoryOffset()
Object	getProperty(SimpleString key)
Set<SimpleString>	getPropertyNames()
Lock	getReadLock()
Short	getShortProperty(SimpleString key)
SimpleString	getSimpleStringProperty(SimpleString key)
Lock	getWriteLock()
boolean	isEmpty()
void	putBooleanProperty(SimpleString key, boolean value)
void	putByteProperty(SimpleString key, byte value)
void	putBytesProperty(SimpleString key, byte[] value)
void	putCharProperty(SimpleString key, char value)
void	putDoubleProperty(SimpleString key, double value)
void	putFloatProperty(SimpleString key, float value)
void	putIntProperty(SimpleString key, int value)
void	putLongProperty(SimpleString key, long value)
void	putNullValue(SimpleString key)
TypedProperties	putProperty(SimpleString key, Object value)
void	putShortProperty(SimpleString key, short value)
void	putSimpleStringProperty(SimpleString key, SimpleString value)
void	putTypedProperties(TypedProperties otherProps)
Object	removeProperty(SimpleString key)
static boolean	searchProperty(SimpleString key, io.netty.buffer.ByteBuf buffer, int startIndex)	Performs a search among the valid key properties contained in buffer, starting from from assuming it to be a valid encoded TypedProperties content.
static void	setObjectProperty(SimpleString key, Object value, TypedProperties properties)	Helper for MapMessage#setObjectProperty(String, Object)
int	size()	Return the number of properties
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

TypedProperties

public TypedProperties()

TypedProperties

public TypedProperties(Predicate<SimpleString> internalPropertyPredicate)

TypedProperties

public TypedProperties(Predicate<SimpleString> internalPropertyPredicate,
 Predicate<SimpleString> amqpPropertyPredicate)

TypedProperties

public TypedProperties(TypedProperties other)

Method Details

size

public int size()

Return the number of properties

getMemoryOffset

public int getMemoryOffset()

putBooleanProperty

public void putBooleanProperty(SimpleString key,
 boolean value)

putByteProperty

public void putByteProperty(SimpleString key,
 byte value)

putBytesProperty

public void putBytesProperty(SimpleString key,
 byte[] value)

putShortProperty

public void putShortProperty(SimpleString key,
 short value)

putIntProperty

public void putIntProperty(SimpleString key,
 int value)

putLongProperty

public void putLongProperty(SimpleString key,
 long value)

putFloatProperty

public void putFloatProperty(SimpleString key,
 float value)

putDoubleProperty

public void putDoubleProperty(SimpleString key,
 double value)

putSimpleStringProperty

public void putSimpleStringProperty(SimpleString key,
 SimpleString value)

putNullValue

public void putNullValue(SimpleString key)

putCharProperty

public void putCharProperty(SimpleString key,
 char value)

putTypedProperties

public void putTypedProperties(TypedProperties otherProps)

putProperty

public TypedProperties putProperty(SimpleString key,
 Object value)

getProperty

public Object getProperty(SimpleString key)

getBooleanProperty

public Boolean getBooleanProperty(SimpleString key)
                           throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getByteProperty

public Byte getByteProperty(SimpleString key,
 Supplier<Byte> defaultValue)
                     throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getByteProperty

public Byte getByteProperty(SimpleString key)
                     throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getCharProperty

public Character getCharProperty(SimpleString key)
                          throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getBytesProperty

public byte[] getBytesProperty(SimpleString key)
                        throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getDoubleProperty

public Double getDoubleProperty(SimpleString key)
                         throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getIntProperty

public Integer getIntProperty(SimpleString key)
                       throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getLongProperty

public Long getLongProperty(SimpleString key)
                     throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getShortProperty

public Short getShortProperty(SimpleString key)
                       throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getFloatProperty

public Float getFloatProperty(SimpleString key)
                       throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getSimpleStringProperty

public SimpleString getSimpleStringProperty(SimpleString key)
                                     throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

removeProperty

public Object removeProperty(SimpleString key)

containsProperty

public boolean containsProperty(SimpleString key)

getPropertyNames

public Set<SimpleString> getPropertyNames()

clearInternalProperties

public boolean clearInternalProperties()

clearAMQPProperties

public boolean clearAMQPProperties()

forEachKey

public void forEachKey(Consumer<SimpleString> action)

This method is read-only. Do not modify the TypedProperties using the Consumer.

Parameters:

action - Consumer implementation that should not modify the TypedProperties

forEach

public void forEach(BiConsumer<SimpleString,Object> action)

This method is read-only. Do not modify the TypedProperties using the BiConsumer.

Parameters:

action - BiConsumer implementation that should not modify the TypedProperties

searchProperty

public static boolean searchProperty(SimpleString key,
 io.netty.buffer.ByteBuf buffer,
 int startIndex)

Performs a search among the valid key properties contained in buffer, starting from from assuming it to be a valid encoded TypedProperties content.

Throws:

IllegalStateException - if any not-valid property is found while searching the key property

decode

public void decode(io.netty.buffer.ByteBuf buffer,
 TypedProperties.TypedPropertiesDecoderPools keyValuePools)

decode

public void decode(io.netty.buffer.ByteBuf buffer)

encode

public int encode(io.netty.buffer.ByteBuf buffer)

getEncodeSize

public int getEncodeSize()

clear

public void clear()

toString

public String toString()

Overrides:

toString in class Object

isEmpty

public boolean isEmpty()

getMapNames

public Set<String> getMapNames()

getMap

public Map<String,Object> getMap()

getReadLock

public Lock getReadLock()

getWriteLock

public Lock getWriteLock()

setObjectProperty

public static void setObjectProperty(SimpleString key,
 Object value,
 TypedProperties properties)

Helper for MapMessage#setObjectProperty(String, Object)

Parameters:

key - The SimpleString key

value - The Object value

properties - The typed properties