Package test.de.iip_ecosphere.platform.transport.spring

Class StreamTest.MyProcessor

java.lang.Object

test.de.iip_ecosphere.platform.transport.spring.StreamTest.MyProcessor

Enclosing class:

StreamTest

@SpringBootApplication
public static class StreamTest.MyProcessor
extends Object

A simple processor class.

Author:

Holger Eichelberger, SSE

Constructor Summary

Constructors

Constructor	Description
MyProcessor()

Method Summary

Modifier and Type	Method	Description
org.springframework.messaging.converter.MessageConverter	customMessageConverter()	Creates a custom message converter.
Function<String,String>	transform()	Transforms the received input.

Methods inherited from class java.lang.Object

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

Constructor Details

MyProcessor

public MyProcessor()

Method Details

transform

@Bean
public Function<String,String> transform()

Transforms the received input.

Returns:

function transforming the input

customMessageConverter

@Bean
public org.springframework.messaging.converter.MessageConverter customMessageConverter()

Creates a custom message converter.

Returns:

the custom message converter