org.springframework.xd.spark.streaming

Class SparkMessageSender

java.lang.Object

org.springframework.xd.spark.streaming.SparkMessageSender

All Implemented Interfaces:

java.io.Serializable

public abstract class SparkMessageSender
extends java.lang.Object
implements java.io.Serializable

Abstract class that defines abstract methods to support sending the computed messages out of Spark cluster to XD MessageBus etc.

Since:

1.1

Author:

Ilayaperumal Gopinathan

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkMessageSender()

Method Summary

Methods

Modifier and Type	Method and Description
abstract boolean	isRunning() Check if the message sender is running
abstract void	send(org.springframework.messaging.Message message) Send a message out of Spark cluster.
abstract void	start() Start the message sender
abstract void	stop() Stop the message sender

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkMessageSender

public SparkMessageSender()

Method Detail

start

public abstract void start()

Start the message sender

stop

public abstract void stop()

Stop the message sender

isRunning

public abstract boolean isRunning()

Check if the message sender is running

Returns:

boolean true if the sender is running

send

public abstract void send(org.springframework.messaging.Message message)

Send a message out of Spark cluster.

Parameters:

message - the message to send