Package oracle.kv.pubsub
Class NoSQLPublisherConfig
- java.lang.Object
 - 
- oracle.kv.pubsub.NoSQLPublisherConfig
 
 
- 
public class NoSQLPublisherConfig extends Object
Configuration used to create an instance of NoSQLPublisher. User need to specify- an instance of KVStoreConfig
 - a path to a writable directory to create the publisher root directory.
 
- shard timeout in milliseconds, which represents a warning threshold of time that NoSQLPublisher does not hear from a shard. If a subscription does not hear from a shard for more than this threshold, a ShardTimeoutException will be signaled via NoSQLSubscriber.onWarn;
 - maximum concurrent subscriptions, which represents a upper bound of the maximum number of concurrent subscriptions the publisher can support.
 
- login credentials which will be used to authenticate with NoSQL DB
 - a reauthentication handler which will be used to re-authenticate with the NoSQL DB.
 
 
- 
- 
Nested Class Summary
Nested Classes Modifier and Type Class Description static classNoSQLPublisherConfig.BuilderBuilder to help construct a NoSQLPublisherConfig instance 
- 
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanallowPreexistDir()Returns true if pre-exist directory is allowedbooleanequals(Object obj)String[]getHelperHosts()Gets the list of source kvstore helper hostsintgetMaxConcurrentSubs()Gets the maximum number of concurrent subscriptions supported by this publisher.StringgetPublisherId()Returns the publisher id, or null if not setStringgetRootPath()Gets the root directory of the publisherlonggetShardTimeoutMs()Gets the configured shard timeout in msStringgetStoreName()Gets the source kvstore nameinthashCode() 
 - 
 
- 
- 
Method Detail
- 
getStoreName
public String getStoreName()
Gets the source kvstore name- Returns:
 - the source kvstore name
 
 
- 
getHelperHosts
public String[] getHelperHosts()
Gets the list of source kvstore helper hosts- Returns:
 - the list of source kvstore helper hosts
 
 
- 
getShardTimeoutMs
public long getShardTimeoutMs()
Gets the configured shard timeout in ms- Returns:
 - the configured shard timeout in ms
 
 
- 
getMaxConcurrentSubs
public int getMaxConcurrentSubs()
Gets the maximum number of concurrent subscriptions supported by this publisher.- Returns:
 - the maximum number of concurrent subscriptions
 
 
- 
getRootPath
public String getRootPath()
Gets the root directory of the publisher- Returns:
 - the root directory
 
 
- 
allowPreexistDir
public boolean allowPreexistDir()
Returns true if pre-exist directory is allowed- Returns:
 - true if pre-exist directory is allowed
 - Since:
 - 19.5
 
 
- 
getPublisherId
public String getPublisherId()
Returns the publisher id, or null if not set- Returns:
 - the publisher id, or null if not set
 - Since:
 - 19.5
 
 
 - 
 
 -