org.springframework.xd.integration.hadoop.expression

Class MessagePartitionKeyPropertyAccessor

java.lang.Object

org.springframework.expression.spel.support.ReflectivePropertyAccessor

org.springframework.xd.integration.hadoop.expression.MessagePartitionKeyPropertyAccessor

All Implemented Interfaces:

org.springframework.expression.PropertyAccessor

public class MessagePartitionKeyPropertyAccessor
extends org.springframework.expression.spel.support.ReflectivePropertyAccessor

A PropertyAccessor reading values from a backing Message used by a partition key. In a way this is similar than MapAccessor for header but also adds 'payload' and 'headers' to be resolved. Having 'payload' or 'headers' keywords in headers is not possible to access via this accessor.

Author:

Janne Valkealahti

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor

Nested classes/interfaces inherited from class org.springframework.expression.spel.support.ReflectivePropertyAccessor

org.springframework.expression.spel.support.ReflectivePropertyAccessor.OptimalPropertyAccessor

Constructor Summary

Constructors

Constructor and Description
MessagePartitionKeyPropertyAccessor()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canRead(org.springframework.expression.EvaluationContext context, java.lang.Object target, java.lang.String name)
boolean	canWrite(org.springframework.expression.EvaluationContext context, java.lang.Object target, java.lang.String name)
org.springframework.expression.PropertyAccessor	createOptimalAccessor(org.springframework.expression.EvaluationContext evalContext, java.lang.Object target, java.lang.String name)
java.lang.Class<?>[]	getSpecificTargetClasses()
org.springframework.expression.TypedValue	read(org.springframework.expression.EvaluationContext context, java.lang.Object target, java.lang.String name)
void	write(org.springframework.expression.EvaluationContext context, java.lang.Object target, java.lang.String name, java.lang.Object newValue)

Methods inherited from class org.springframework.expression.spel.support.ReflectivePropertyAccessor

findField, findGetterForProperty, findSetterForProperty, getLastReadInvokerPair, getPropertyMethodSuffix, getPropertyMethodSuffixes

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagePartitionKeyPropertyAccessor

public MessagePartitionKeyPropertyAccessor()

Method Detail

getSpecificTargetClasses

public java.lang.Class<?>[] getSpecificTargetClasses()

Specified by:

getSpecificTargetClasses in interface org.springframework.expression.PropertyAccessor

Overrides:

getSpecificTargetClasses in class org.springframework.expression.spel.support.ReflectivePropertyAccessor

canRead

public boolean canRead(org.springframework.expression.EvaluationContext context,
              java.lang.Object target,
              java.lang.String name)
                throws org.springframework.expression.AccessException

Specified by:

canRead in interface org.springframework.expression.PropertyAccessor

Overrides:

canRead in class org.springframework.expression.spel.support.ReflectivePropertyAccessor

Throws:

org.springframework.expression.AccessException

read

public org.springframework.expression.TypedValue read(org.springframework.expression.EvaluationContext context,
                                             java.lang.Object target,
                                             java.lang.String name)
                                               throws org.springframework.expression.AccessException

Specified by:

read in interface org.springframework.expression.PropertyAccessor

Overrides:

read in class org.springframework.expression.spel.support.ReflectivePropertyAccessor

Throws:

org.springframework.expression.AccessException

canWrite

public boolean canWrite(org.springframework.expression.EvaluationContext context,
               java.lang.Object target,
               java.lang.String name)
                 throws org.springframework.expression.AccessException

Specified by:

canWrite in interface org.springframework.expression.PropertyAccessor

Overrides:

canWrite in class org.springframework.expression.spel.support.ReflectivePropertyAccessor

Throws:

org.springframework.expression.AccessException

write

public void write(org.springframework.expression.EvaluationContext context,
         java.lang.Object target,
         java.lang.String name,
         java.lang.Object newValue)
           throws org.springframework.expression.AccessException

Specified by:

write in interface org.springframework.expression.PropertyAccessor

Overrides:

write in class org.springframework.expression.spel.support.ReflectivePropertyAccessor

Throws:

org.springframework.expression.AccessException

createOptimalAccessor

public org.springframework.expression.PropertyAccessor createOptimalAccessor(org.springframework.expression.EvaluationContext evalContext,
                                                                    java.lang.Object target,
                                                                    java.lang.String name)

Overrides:

createOptimalAccessor in class org.springframework.expression.spel.support.ReflectivePropertyAccessor