com.hazelcast.config

Class TopicConfig

java.lang.Object

com.hazelcast.config.TopicConfig

Direct Known Subclasses:

TopicConfigReadOnly

public class TopicConfig
extends Object

Contains the configuration for a ITopic.

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DEFAULT_GLOBAL_ORDERING_ENABLED Default global ordering configuration.

Constructor Summary

Constructors

Constructor and Description
TopicConfig() Creates a TopicConfig.
TopicConfig(String name) Creates a TopicConfig with the given name.
TopicConfig(TopicConfig config) Creates a TopicConfig by cloning another TopicConfig.

Method Summary

Modifier and Type	Method and Description
TopicConfig	addMessageListenerConfig(ListenerConfig listenerConfig) Adds a message listener to this topic (listens for when messages are added or removed).
boolean	equals(Object obj) Checks if the given object is equal to this topic.
TopicConfigReadOnly	getAsReadOnly() Deprecated. this method will be removed in 4.0; it is meant for internal usage only.
List<ListenerConfig>	getMessageListenerConfigs() Gets the list of message listeners (listens for when messages are added or removed) for this topic.
String	getName() Gets the name of the topic, null if nothing is set.
int	hashCode()
boolean	isGlobalOrderingEnabled() Checks if global ordering is enabled (all nodes listening to the same topic get their messages in the same order), or disabled (nodes get the messages in the order that the messages are published).
boolean	isMultiThreadingEnabled() Checks if multi-threaded processing of incoming messages is enabled or not.
boolean	isStatisticsEnabled() Checks if statistics are enabled for this topic.
TopicConfig	setGlobalOrderingEnabled(boolean globalOrderingEnabled) Enable global ordering (all nodes listening to the same topic get their messages in the same order), or disable it (nodes get the messages in the order that the messages are published).
TopicConfig	setMessageListenerConfigs(List<ListenerConfig> listenerConfigs) Sets the list of message listeners (listens for when messages are added or removed) for this topic.
TopicConfig	setMultiThreadingEnabled(boolean multiThreadingEnabled) Enable multi-threaded message handling.
TopicConfig	setName(String name) Sets the name of the topic.
TopicConfig	setStatisticsEnabled(boolean statisticsEnabled) Enables or disables statistics for this topic.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

DEFAULT_GLOBAL_ORDERING_ENABLED

public static final boolean DEFAULT_GLOBAL_ORDERING_ENABLED

Default global ordering configuration.

See Also:

Constant Field Values

Constructor Detail

TopicConfig

public TopicConfig()

Creates a TopicConfig.

TopicConfig

public TopicConfig(String name)

Creates a TopicConfig with the given name.

Parameters:

name - the name of the Topic.

TopicConfig

public TopicConfig(TopicConfig config)

Creates a TopicConfig by cloning another TopicConfig.

Parameters:

config - the TopicConfig to clone.

Method Detail

getAsReadOnly

public TopicConfigReadOnly getAsReadOnly()

Deprecated. this method will be removed in 4.0; it is meant for internal usage only.

Gets immutable version of this configuration.

Returns:

Immutable version of this configuration.

getName

public String getName()

Gets the name of the topic, null if nothing is set.

Returns:

the name of the topic

setName

public TopicConfig setName(String name)

Sets the name of the topic.

Parameters:

name - the topic name to set.

Returns:

the updated TopicConfig

Throws:

IllegalArgumentException - if name is null or an empty string.

isGlobalOrderingEnabled

public boolean isGlobalOrderingEnabled()

Checks if global ordering is enabled (all nodes listening to the same topic get their messages in the same order), or disabled (nodes get the messages in the order that the messages are published).

Returns:

true if global ordering is enabled, false if disabled

setGlobalOrderingEnabled

public TopicConfig setGlobalOrderingEnabled(boolean globalOrderingEnabled)

Enable global ordering (all nodes listening to the same topic get their messages in the same order), or disable it (nodes get the messages in the order that the messages are published).

Parameters:

globalOrderingEnabled - set to true to enable global ordering, false to disable

Returns:

The updated TopicConfig

isMultiThreadingEnabled

public boolean isMultiThreadingEnabled()

Checks if multi-threaded processing of incoming messages is enabled or not. When disabled only one dedicated thread will handle all topic messages. Otherwise any thread from events thread pool can be used for message handling.

Returns:

true if multi-threading is enabled, false if disabled

setMultiThreadingEnabled

public TopicConfig setMultiThreadingEnabled(boolean multiThreadingEnabled)

Enable multi-threaded message handling. When enabled any thread from events thread pool can be used for incoming message processing. Otherwise only one dedicated thread will be used to handle topic messages. Note: it can be enabled only in case when global ordering is disabled. Moreover, the local message ordering is not supported in this mode also. This means the messages produced by local publisher can be processed by several threads with no ordering guarantee.

Parameters:

multiThreadingEnabled - set to true to enable multi-threaded message processing, false to disable

Returns:

The updated TopicConfig

addMessageListenerConfig

public TopicConfig addMessageListenerConfig(ListenerConfig listenerConfig)

Adds a message listener to this topic (listens for when messages are added or removed).

Parameters:

listenerConfig - The message listener to add to this topic.

getMessageListenerConfigs

public List<ListenerConfig> getMessageListenerConfigs()

Gets the list of message listeners (listens for when messages are added or removed) for this topic.

Returns:

The list of message listeners for this topic.

setMessageListenerConfigs

public TopicConfig setMessageListenerConfigs(List<ListenerConfig> listenerConfigs)

Sets the list of message listeners (listens for when messages are added or removed) for this topic.

Parameters:

listenerConfigs - The list of message listeners for this topic.

Returns:

This updated topic configuration.

isStatisticsEnabled

public boolean isStatisticsEnabled()

Checks if statistics are enabled for this topic.

Returns:

true if statistics are enabled, false otherwise.

setStatisticsEnabled

public TopicConfig setStatisticsEnabled(boolean statisticsEnabled)

Enables or disables statistics for this topic.

Parameters:

statisticsEnabled - True to enable statistics for this topic, false to disable.

Returns:

the updated TopicConfig

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Checks if the given object is equal to this topic.

Overrides:

equals in class Object

Returns:

true if the object is equal to this topic, false otherwise.

toString

public String toString()

Overrides:

toString in class Object