A B C D G H I J M O P R S T Y

A

AbstractIntegrationYarnContainer - Class in org.springframework.yarn.integration.container
Base implementation of YarnContainer extending AbstractYarnContainer to handle IntegrationAppmasterServiceClient.
AbstractIntegrationYarnContainer() - Constructor for class org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer
 
afterPropertiesSet() - Method in class org.springframework.yarn.integration.convert.ConverterRegistrar
 
afterPropertiesSet() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
 
AppmasterMindScOperations - Interface in org.springframework.yarn.integration.ip.mind
 

B

BaseObject - Class in org.springframework.yarn.integration.ip.mind.binding
Base object of messages meant for pojo mapping.
BaseObject() - Constructor for class org.springframework.yarn.integration.ip.mind.binding.BaseObject
Constructs an empty object
BaseObject(String) - Constructor for class org.springframework.yarn.integration.ip.mind.binding.BaseObject
Constructs object with a given type
BaseResponseObject - Class in org.springframework.yarn.integration.ip.mind.binding
Base object for messages which should have a common fields for responses.
BaseResponseObject() - Constructor for class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
 
BaseResponseObject(String) - Constructor for class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
 
BaseResponseObject(String, String, String) - Constructor for class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
 

C

checkClosure(int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
 
ConversionServiceCreator - Class in org.springframework.yarn.integration.convert
Post processor which automatically creates an instance of conversion service if it doesn't exists.
ConversionServiceCreator() - Constructor for class org.springframework.yarn.integration.convert.ConversionServiceCreator
 
convert(MindRpcMessageHolder) - Method in class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
 
convert(BaseObject) - Method in class org.springframework.yarn.integration.convert.MindObjectToHolderConverter
 
ConverterRegistrar - Class in org.springframework.yarn.integration.convert
Utility class that keeps track of a set of Converters in order to register them with the "integrationConversionService" upon initialization.
ConverterRegistrar(Set<Converter<?, ?>>) - Constructor for class org.springframework.yarn.integration.convert.ConverterRegistrar
 

D

DefaultMindAppmasterServiceClient - Class in org.springframework.yarn.integration.ip.mind
Default implementation of MindAppmasterServiceClient which handles the message serialization using type information in mind message headers.
DefaultMindAppmasterServiceClient() - Constructor for class org.springframework.yarn.integration.ip.mind.DefaultMindAppmasterServiceClient
 
DefaultPortExposingTcpSocketSupport - Class in org.springframework.yarn.integration.support
Implementation of TcpSocketSupport which extends its base functionality by catching socket information, like listen address and port.
DefaultPortExposingTcpSocketSupport() - Constructor for class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport
 
deserialize(InputStream) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
 
destroy() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
 
doMindRequest(BaseObject) - Method in interface org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations
 
doMindRequest(BaseObject) - Method in class org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient
 
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceClientParser
 
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceParser
 
doStart() - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
 
doStop() - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
 

G

get(RpcMessage<?>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClient
 
getBaseResponseObject(RpcMessage<?>) - Method in class org.springframework.yarn.integration.ip.mind.DefaultMindAppmasterServiceClient
 
getBaseResponseObject(RpcMessage<?>) - Method in class org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient
This method is called from MindAppmasterServiceClient.doMindRequest(BaseObject) to convert the response content back to mind BaseResponseObject.
getBeanClass(Element) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceClientParser
 
getBeanClass(Element) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceParser
 
getContent() - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Gets the content of this holder.
getConversionService(BeanFactory) - Static method in class org.springframework.yarn.integration.support.IntegrationContextUtils
Return the ConversionService bean whose name is "integrationConversionService" if available.
getConversionService() - Method in class org.springframework.yarn.integration.support.IntegrationObjectSupport
Gets the spring conversion service.
getHeaders() - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Gets headers of this holder.
getHost() - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
 
getIntegrationServiceClient() - Method in class org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer
Gets the integration service client.
getObject() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
 
getObject() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
 
getObject() - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Return the singleton ObjectMapper.
getObjectType() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
 
getPayload(RpcMessage<?>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClient
This method is called from IntegrationAppmasterServiceClient.get(RpcMessage) to resolve the actual payload sent to Sprint Int Tcp channel.
getPayload(RpcMessage<?>) - Method in class org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient
 
getPort() - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
 
getRequiredTaskScheduler(BeanFactory) - Static method in class org.springframework.yarn.integration.support.IntegrationContextUtils
Return the TaskScheduler bean whose name is "taskScheduler".
getResmsg() - Method in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
 
getResstate() - Method in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
 
getServerSocketAddress() - Method in class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport
 
getServerSocketAddress() - Method in interface org.springframework.yarn.integration.support.PortExposingTcpSocketSupport
Gets the binded server socket address.
getServerSocketPort() - Method in class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport
 
getServerSocketPort() - Method in interface org.springframework.yarn.integration.support.PortExposingTcpSocketSupport
Gets the binded server socket port.
getTaskScheduler(BeanFactory) - Static method in class org.springframework.yarn.integration.support.IntegrationContextUtils
Return the TaskScheduler bean whose name is "taskScheduler" if available.
getType() - Method in class org.springframework.yarn.integration.ip.mind.binding.BaseObject
Get type of this object.

H

handleMessageInternal(RpcMessage<T>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
Implementor need to write this method to process incoming messages.
handleMessageInternal(RpcMessage<MindRpcMessageHolder>) - Method in class org.springframework.yarn.integration.ip.mind.MindAppmasterService
 
handleMindMessageInternal(MindRpcMessageHolder) - Method in class org.springframework.yarn.integration.ip.mind.MindAppmasterService
Internal message handling for MindRpcMessageHolder.
hasPort() - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
 

I

init() - Method in class org.springframework.yarn.integration.config.IntegrationNamespaceHandler
 
IntegrationAmServiceClientParser - Class in org.springframework.yarn.integration.config
Simple namespace parser for <yarn-int:amservice-client>.
IntegrationAmServiceClientParser() - Constructor for class org.springframework.yarn.integration.config.IntegrationAmServiceClientParser
 
IntegrationAmServiceParser - Class in org.springframework.yarn.integration.config
Simple namespace parser for <yarn-int:amservice>.
IntegrationAmServiceParser() - Constructor for class org.springframework.yarn.integration.config.IntegrationAmServiceParser
 
IntegrationAppmasterService<T> - Class in org.springframework.yarn.integration
Base implementation of AppmasterService using Spring Integration Ip channels as a communication link.
IntegrationAppmasterService() - Constructor for class org.springframework.yarn.integration.IntegrationAppmasterService
 
IntegrationAppmasterServiceClient<T> - Class in org.springframework.yarn.integration
Implementation of Appmaster service client working on top of Spring Int tcp channels.
IntegrationAppmasterServiceClient() - Constructor for class org.springframework.yarn.integration.IntegrationAppmasterServiceClient
 
IntegrationAppmasterServiceClientFactoryBean - Class in org.springframework.yarn.integration
Factory which creates appmaster service clients.
IntegrationAppmasterServiceClientFactoryBean() - Constructor for class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
 
IntegrationAppmasterServiceFactoryBean - Class in org.springframework.yarn.integration
Bean factory for building AppmasterService instances supported by this module.
IntegrationAppmasterServiceFactoryBean() - Constructor for class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
 
IntegrationContextUtils - Class in org.springframework.yarn.integration.support
Utility methods for accessing common integration components from the BeanFactory.
IntegrationContextUtils() - Constructor for class org.springframework.yarn.integration.support.IntegrationContextUtils
 
IntegrationConverterParser - Class in org.springframework.yarn.integration.config
Simple namespace parser for <yarn-int:converter>.
IntegrationConverterParser() - Constructor for class org.springframework.yarn.integration.config.IntegrationConverterParser
 
IntegrationNamespaceHandler - Class in org.springframework.yarn.integration.config
Handler for <yarn-int> namespace.
IntegrationNamespaceHandler() - Constructor for class org.springframework.yarn.integration.config.IntegrationNamespaceHandler
 
IntegrationObjectSupport - Class in org.springframework.yarn.integration.support
Extension of LifecycleObjectSupport adding common ConversionService for all implementors of this class.
IntegrationObjectSupport() - Constructor for class org.springframework.yarn.integration.support.IntegrationObjectSupport
 
isSingleton() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
 
isSingleton() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
 
isSingleton() - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
 

J

Jackson2ObjectMapperFactoryBean - Class in org.springframework.yarn.integration.support
A FactoryBean for creating a Jackson ObjectMapper with setters to enable or disable Jackson features from within XML configuration.
Jackson2ObjectMapperFactoryBean() - Constructor for class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
 

M

maxMessageSize - Variable in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
 
MindAppmasterService - Class in org.springframework.yarn.integration.ip.mind
Implementation of AppmasterService which handles communication via Spring Int tcp channels using mind protocol.
MindAppmasterService() - Constructor for class org.springframework.yarn.integration.ip.mind.MindAppmasterService
 
MindAppmasterServiceClient - Class in org.springframework.yarn.integration.ip.mind
Implementation of Appmaster service client extending IntegrationAppmasterServiceClient.
MindAppmasterServiceClient() - Constructor for class org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient
 
MindDataConversionException - Exception in org.springframework.yarn.integration.convert
Simple exception indicating errors during the conversion.
MindDataConversionException(String, Throwable) - Constructor for exception org.springframework.yarn.integration.convert.MindDataConversionException
Construct a new mind data conversion exception.
MindDataConversionException(String) - Constructor for exception org.springframework.yarn.integration.convert.MindDataConversionException
Construct a new mind data conversion exception.
MindHolderToObjectConverter - Class in org.springframework.yarn.integration.convert
Spring Converter which knows how to convert MindRpcMessageHolder to BaseObject.
MindHolderToObjectConverter(ObjectMapper) - Constructor for class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
Instantiates a new mind holder to object converter.
MindHolderToObjectConverter(ObjectMapper, String) - Constructor for class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
Instantiates a new mind holder to object converter.
MindHolderToObjectConverter(ObjectMapper, String[]) - Constructor for class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
Instantiates a new mind holder to object converter.
MindObjectToHolderConverter - Class in org.springframework.yarn.integration.convert
Spring Converter which knows how to convert BaseObject to MindRpcMessageHolder.
MindObjectToHolderConverter(ObjectMapper) - Constructor for class org.springframework.yarn.integration.convert.MindObjectToHolderConverter
Constructs converter with a jackson object mapper.
MindRpcMessageHolder - Class in org.springframework.yarn.integration.ip.mind
Mind request and response contains a set of headers and a content.
MindRpcMessageHolder(Map<String, String>, String) - Constructor for class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Constructs holder instance with a map of headers and a content.
MindRpcMessageHolder(Map<String, String>, byte[]) - Constructor for class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Constructs holder instance with a map of headers and a content.
MindRpcSerializer - Class in org.springframework.yarn.integration.ip.mind
Spring Serializer and Deserializer interfaces for mind protocol.
MindRpcSerializer() - Constructor for class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
 

O

org.springframework.yarn.integration - package org.springframework.yarn.integration
 
org.springframework.yarn.integration.config - package org.springframework.yarn.integration.config
 
org.springframework.yarn.integration.container - package org.springframework.yarn.integration.container
 
org.springframework.yarn.integration.convert - package org.springframework.yarn.integration.convert
 
org.springframework.yarn.integration.ip.mind - package org.springframework.yarn.integration.ip.mind
 
org.springframework.yarn.integration.ip.mind.binding - package org.springframework.yarn.integration.ip.mind.binding
 
org.springframework.yarn.integration.support - package org.springframework.yarn.integration.support
 

P

parseInternal(Element, ParserContext) - Method in class org.springframework.yarn.integration.config.IntegrationConverterParser
 
PortExposingTcpSocketSupport - Interface in org.springframework.yarn.integration.support
Extension of TcpSocketSupport interface adding methods to get more information about the socket ports.
postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.yarn.integration.convert.ConversionServiceCreator
 
postProcessServerSocket(ServerSocket) - Method in class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport
 
postProcessSocket(Socket) - Method in class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport
 

R

readBytes(InputStream, int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
Helper method to read bytes from a stream.
readHeader(InputStream) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
Reads the first line as a protocol header and parses sizes of underlying headers and content.
readHeaders(InputStream, int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
Reads a message headers from inputstream with a given length.
resmsg - Variable in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
Message of a response.
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceClientParser
 
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceParser
 
resstate - Variable in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
State of a response.

S

serialize(MindRpcMessageHolder, OutputStream) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
 
setAnnotationIntrospector(AnnotationIntrospector) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Set the AnnotationIntrospector for both serialization and deserialization.
setAutoDetectFields(boolean) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Shortcut for MapperFeature.AUTO_DETECT_FIELDS option.
setAutoDetectGettersSetters(boolean) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Shortcut for MapperFeature.AUTO_DETECT_SETTERS/ MapperFeature.AUTO_DETECT_GETTERS option.
setBasePackage(String[]) - Method in class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
Sets the base packages.
setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.integration.convert.ConverterRegistrar
 
setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
 
setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
 
setChannel(SubscribableChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
Sets the message channel for service dispatching.
setContent(byte[]) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Sets the content of this holder.
setContent(String) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Sets the content of this holder.
setConversionService(ConversionService) - Method in class org.springframework.yarn.integration.support.IntegrationObjectSupport
Sets the ConversionService.
setDateFormat(DateFormat) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Define the format for date/time with the given DateFormat.
setDeserializersByType(Map<Class<?>, JsonDeserializer<?>>) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Configure custom deserializers for the given types.
setFailOnEmptyBeans(boolean) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Shortcut for SerializationFeature.FAIL_ON_EMPTY_BEANS option.
setFeaturesToDisable(Object...) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Specify features to disable.
setFeaturesToEnable(Object...) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Specify features to enable.
setHeaders(Map<String, String>) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Sets the headers of this holder.
setIndentOutput(boolean) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Shortcut for SerializationFeature.INDENT_OUTPUT option.
setIntegrationServiceClient(IntegrationAppmasterServiceClient<?>) - Method in class org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer
Sets the integration service client.
setMaxMessageSize(int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
Sets the max message size for transport.
setMessageChannel(SubscribableChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
Sets the message channel where messages are dispatched.
setObjectMapper(ObjectMapper) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Set the ObjectMapper instance to use.
setRequestChannel(MessageChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClient
Set the request channel for outgoing messages.
setRequestChannel(MessageChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
Sets the outbount request channel.
setResmsg(String) - Method in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
 
setResponseChannel(PollableChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClient
Set the response channel for incoming messages.
setResponseChannel(PollableChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
Sets the inbound response channel.
setResstate(String) - Method in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject
 
setSerializers(JsonSerializer<?>...) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Configure custom serializers.
setSerializersByType(Map<Class<?>, JsonSerializer<?>>) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Configure custom serializers for the given types.
setServiceImpl(Class<AppmasterServiceClient>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean
Set the class implementing appmaster service client.
setServiceImpl(Class<AppmasterService>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
Set the class implementing appmaster service.
setServiceRef(IntegrationAppmasterService<?>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
Sets the appmaster service as an instance.
setSimpleDateFormat(String) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean
Define the date/time format with a SimpleDateFormat.
setSocketSupport(PortExposingTcpSocketSupport) - Method in class org.springframework.yarn.integration.IntegrationAppmasterService
Sets the socket support for this service.
setSocketSupport(PortExposingTcpSocketSupport) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean
Sets the socket support to be used to get port info from a server socket.

T

TASK_SCHEDULER_BEAN_NAME - Static variable in class org.springframework.yarn.integration.support.IntegrationContextUtils
 
toBytes() - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
Gets the complete protocol representation of this holder as array of bytes.
toString() - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
 
type - Variable in class org.springframework.yarn.integration.ip.mind.binding.BaseObject
Type identifier of the object

Y

YARN_INTEGRATION_CONVERSION_SERVICE_BEAN_NAME - Static variable in class org.springframework.yarn.integration.support.IntegrationContextUtils
 

A B C D G H I J M O P R S T Y