Package com.tangosol.net.topic
Interface TopicDependencies
-
public interface TopicDependenciesThe dependencies for a topic.- Since:
- 23.03
- Author:
- Jonathan Knight 2002.09.10
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static intcomputeChannelCount(int cPartitions)Compute the channel count based on the supplied partition count.intgetConfiguredChannelCount()Returns the number of channels configured for the topic, orPagedTopic.DEFAULT_CHANNEL_COUNTto indicate that the topic uses the default number of channels.NamedTopic.ElementCalculatorgetElementCalculator()Return the calculator used to calculate element sizes.longgetElementExpiryMillis()Obtain the expiry delay to apply to elements in ths topic.longgetMaxBatchSizeBytes()Return the maximum size of a batch.longgetNotificationTimeout()Returns the timeout that a subscriber will use when waiting for its first allocation of channels.longgetReconnectRetryMillis()Return the amount of time publishers and subscribers will wait between attempts to reconnect after being disconnected.longgetReconnectTimeoutMillis()Returns the maximum amount of time publishers and subscribers will attempt to reconnect after being disconnected.longgetReconnectWaitMillis()Return the amount of time publishers and subscribers will wait before attempting to reconnect after being disconnected.longgetSubscriberTimeoutMillis()Returns number of milliseconds within which a subscriber must issue a heartbeat or be forcefully considered closed.booleanisAllowUnownedCommits()Returnstrueif the topic allows commits of a position in a channel to be made by subscribers that do not own the channel.booleanisOnlyOwnedCommits()Returnstrueif the topic only allows commits of a position in a channel to be made by subscribers that own the channel.booleanisRetainConsumed()Returnstrueif this topic retains messages after they have been committed orfalseif messages are removed after all known subscribers have committed them.
-
-
-
Method Detail
-
getConfiguredChannelCount
int getConfiguredChannelCount()
Returns the number of channels configured for the topic, orPagedTopic.DEFAULT_CHANNEL_COUNTto indicate that the topic uses the default number of channels.This number may be less than the actual number of channels, which is controlled by the
TopicService, if another cluster member has configured a higher number of channels.The actual number of channels in use for a topic can be obtained by calling the
TopicService.getChannelCount(String)method.- Returns:
- the number of channels configured for the topic
-
computeChannelCount
static int computeChannelCount(int cPartitions)
Compute the channel count based on the supplied partition count.- Parameters:
cPartitions- the partition count- Returns:
- the channel count based on the supplied partition count
-
getElementExpiryMillis
long getElementExpiryMillis()
Obtain the expiry delay to apply to elements in ths topic.- Returns:
- the expiry delay to apply to elements in ths topic
-
getMaxBatchSizeBytes
long getMaxBatchSizeBytes()
Return the maximum size of a batch.- Returns:
- the max batch size
-
isRetainConsumed
boolean isRetainConsumed()
Returnstrueif this topic retains messages after they have been committed orfalseif messages are removed after all known subscribers have committed them.- Returns:
trueif this topic retains messages after they have been committed orfalseif messages are removed after all known subscribers have committed them
-
getSubscriberTimeoutMillis
long getSubscriberTimeoutMillis()
Returns number of milliseconds within which a subscriber must issue a heartbeat or be forcefully considered closed.- Returns:
- number of milliseconds within which a subscriber must issue a heartbeat
-
getNotificationTimeout
long getNotificationTimeout()
Returns the timeout that a subscriber will use when waiting for its first allocation of channels.- Returns:
- the timeout that a subscriber will use when waiting for its first allocation of channels
-
isAllowUnownedCommits
boolean isAllowUnownedCommits()
Returnstrueif the topic allows commits of a position in a channel to be made by subscribers that do not own the channel.- Returns:
trueif the topic allows commits of a position in a channel to be made by subscribers that do not own the channel
-
isOnlyOwnedCommits
boolean isOnlyOwnedCommits()
Returnstrueif the topic only allows commits of a position in a channel to be made by subscribers that own the channel.- Returns:
trueif the topic only allows commits of a position in a channel to be made by subscribers that own the channel
-
getElementCalculator
NamedTopic.ElementCalculator getElementCalculator()
Return the calculator used to calculate element sizes.- Returns:
- the calculator used to calculate element sizes
-
getReconnectTimeoutMillis
long getReconnectTimeoutMillis()
Returns the maximum amount of time publishers and subscribers will attempt to reconnect after being disconnected.- Returns:
- the maximum amount of time publishers and subscribers will attempt to reconnect after being disconnected
-
getReconnectRetryMillis
long getReconnectRetryMillis()
Return the amount of time publishers and subscribers will wait between attempts to reconnect after being disconnected.- Returns:
- the maximum amount of time publishers and subscribers will wait between attempts to reconnect after being disconnected
-
getReconnectWaitMillis
long getReconnectWaitMillis()
Return the amount of time publishers and subscribers will wait before attempting to reconnect after being disconnected.- Returns:
- the maximum amount of time publishers and subscribers will wait before attempting to reconnect after being disconnected
-
-