org.springframework.cloud.netflix.turbine.stream

Class HystrixStreamAggregator

java.lang.Object

org.springframework.cloud.netflix.turbine.stream.HystrixStreamAggregator

@Component
public class HystrixStreamAggregator
extends Object

Author:

Spencer Gibb

Constructor Summary

Constructors

Constructor and Description
HystrixStreamAggregator(com.fasterxml.jackson.databind.ObjectMapper objectMapper, rx.subjects.PublishSubject<Map<String,Object>> subject)

Method Summary

Modifier and Type	Method and Description
static Map<String,Object>	getPayloadData(Map<String,Object> jsonMap)
void	sendToSubject(byte[] bytePayload)

Methods inherited from class java.lang.Object

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

Constructor Detail

HystrixStreamAggregator

@Autowired
public HystrixStreamAggregator(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                          rx.subjects.PublishSubject<Map<String,Object>> subject)

Method Detail

sendToSubject

@ServiceActivator(inputChannel="turbineStreamInput")
public void sendToSubject(@Payload
                                                                               byte[] bytePayload)

getPayloadData

public static Map<String,Object> getPayloadData(Map<String,Object> jsonMap)