org.apache.streams.monitoring.persist.impl

Class LogstashUdpMessagePersister

java.lang.Object

org.apache.streams.monitoring.persist.impl.LogstashUdpMessagePersister

All Implemented Interfaces:

MessagePersister

public class LogstashUdpMessagePersister
extends Object
implements MessagePersister

Constructor Summary

Constructors

Constructor and Description
LogstashUdpMessagePersister(String broadcastUri)

Method Summary

Modifier and Type	Method and Description
int	persistMessages(List<String> messages) Given a list of messages, persist them out through whatever appropriate broadcast mechanism (HTTP request, SLF4J log, etc.).
void	setup() setup.

Methods inherited from class java.lang.Object

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

Constructor Detail

LogstashUdpMessagePersister

public LogstashUdpMessagePersister(String broadcastUri)

Method Detail

setup

public void setup()

setup.

persistMessages

public int persistMessages(List<String> messages)

Description copied from interface: MessagePersister

Given a list of messages, persist them out through whatever appropriate broadcast mechanism (HTTP request, SLF4J log, etc.).

Specified by:

persistMessages in interface MessagePersister

Parameters:

messages - List of String messages

Returns:

statusCode represents whether or not the persist was successful