org.gridgain.grid.kernal.visor.cmd.dto.node

Class VisorStreamerConfig

java.lang.Object

org.gridgain.grid.kernal.visor.cmd.dto.node.VisorStreamerConfig

All Implemented Interfaces:

Serializable

public class VisorStreamerConfig
extends Object
implements Serializable

Data transfer object for streamer configuration properties.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
VisorStreamerConfig()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	atLeastOnce()
void	atLeastOnce(boolean atLeastOnce)
boolean	executorServiceShutdown()
void	executorServiceShutdown(boolean executorSrvcShutdown)
static VisorStreamerConfig	from(GridStreamerConfiguration scfg)
static Iterable<VisorStreamerConfig>	list(GridStreamerConfiguration[] streamers) Construct data transfer object for streamer configurations properties.
int	maximumConcurrentSessions()
void	maximumConcurrentSessions(int maxConcurrentSessions)
int	maximumFailoverAttempts()
void	maximumFailoverAttempts(int maxFailoverAttempts)
String	name()
void	name(String name)
String	router()
void	router(String router)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

VisorStreamerConfig

public VisorStreamerConfig()

Method Detail

from

public static VisorStreamerConfig from(GridStreamerConfiguration scfg)

Parameters:

scfg - Streamer configuration.

Returns:

Data transfer object for streamer configuration properties.

list

public static Iterable<VisorStreamerConfig> list(GridStreamerConfiguration[] streamers)

Construct data transfer object for streamer configurations properties.

Parameters:

streamers - streamer configurations.

Returns:

streamer configurations properties.

name

@Nullable
public String name()

Returns:

Streamer name.

name

public void name(@Nullable
        String name)

Parameters:

name - New streamer name.

router

@Nullable
public String router()

Returns:

Events router.

router

public void router(@Nullable
          String router)

Parameters:

router - New events router.

atLeastOnce

public boolean atLeastOnce()

Returns:

Flag indicating whether event should be processed at least once.

atLeastOnce

public void atLeastOnce(boolean atLeastOnce)

Parameters:

atLeastOnce - New flag indicating whether event should be processed at least once.

maximumFailoverAttempts

public int maximumFailoverAttempts()

Returns:

Maximum number of failover attempts to try.

maximumFailoverAttempts

public void maximumFailoverAttempts(int maxFailoverAttempts)

Parameters:

maxFailoverAttempts - New maximum number of failover attempts to try.

maximumConcurrentSessions

public int maximumConcurrentSessions()

Returns:

Maximum number of concurrent events to be processed.

maximumConcurrentSessions

public void maximumConcurrentSessions(int maxConcurrentSessions)

Parameters:

maxConcurrentSessions - New maximum number of concurrent events to be processed.

executorServiceShutdown

public boolean executorServiceShutdown()

Returns:

Flag indicating whether streamer executor service should be shut down on GridGain stop.

executorServiceShutdown

public void executorServiceShutdown(boolean executorSrvcShutdown)

Parameters:

executorSrvcShutdown - New flag indicating whether streamer executor service should be shutdown on GridGain stop.

toString

public String toString()

Overrides:

toString in class Object