Package oracle.communication.brm.charging.appconfiguration.beans.kafka

Class KafkaConfiguration

java.lang.Object

java.util.Observable

oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean

oracle.communication.brm.charging.appconfiguration.beans.kafka.KafkaConfiguration

All Implemented Interfaces:

Cloneable, KafkaConfigurationMBean, oracle.communication.brm.charging.appconfiguration.ChildConfigBean, oracle.communication.brm.charging.appconfiguration.ConfigurationBean, oracle.communication.brm.charging.util.directevolution.DEvolvable

public class KafkaConfiguration
extends oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean
implements KafkaConfigurationMBean, oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Created with IntelliJ IDEA. User: vaishali Date: 10/10/19 Time: 10:43 AM To change this template use File | Settings | File Templates.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	KafkaConfiguration.Initializer

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_EXTERNAL_PARTITIONS
static final String	DEFAULT_EXTERNAL_TOPIC_NAME
static final String	DEFAULT_FAILURE_TOPIC_NAME
static final String	DEFAULT_HOSTNAME
static final int	DEFAULT_KAFKA_BRM_RECONNECTION_INTERVAL
static final int	DEFAULT_KAFKA_BRM_RECONNECTION_MAX
static final String	DEFAULT_KAFKA_CDR_COMPRESSION_TYPE
static final int	DEFAULT_KAFKA_CDR_PARTITIONS
static final String	DEFAULT_KAFKA_CDR_TOPIC_NAME
static final int	DEFAULT_KAFKA_DGW_RECONNECTION_INTERVAL
static final int	DEFAULT_KAFKA_DGW_RECONNECTION_MAX
static final String	DEFAULT_KAFKA_EXTERNAL_TOPIC_ENABLED
static final String	DEFAULT_KAFKA_FAILURE_TOPIC_PERSISTENCE_ENABLED
static final int	DEFAULT_KAFKA_HTTP_RECONNECTION_INTERVAL
static final int	DEFAULT_KAFKA_HTTP_RECONNECTION_MAX
static final int	DEFAULT_KAFKA_PRODUCER_RECONNECTION_INTERVAL
static final int	DEFAULT_KAFKA_PRODUCER_RECONNECTION_MAX
static final int	DEFAULT_KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS
static final int	DEFAULT_KAFKA_RGW_RECONNECTION_MAX_MILLIS
static final String	DEFAULT_KAFKA_RGW_TOPIC_NAME
static final boolean	DEFAULT_KAFKA_SSL_ENABLED
static final String	DEFAULT_KAFKA_TRUST_STORE_LOCATION
static final String	DEFAULT_NAME
static final String	DEFAULT_OVERAGE_TOPIC_NAME
static final int	DEFAULT_PARTITIONS
static final String	DEFAULT_SUSPENSE_TOPIC_NAME
static final String	DEFAULT_TOPICNAME
static final String	DEFAULT_WALLET_LOCATION
static final String	EXTERNAL_PARTITIONS
static final String	EXTERNAL_TOPIC_ENABLED
static final String	EXTERNAL_TOPIC_NAME
static final String	FAILURE_PARTITIONS
static final String	FAILURE_TOPIC_NAME
static final String	FAILURE_TOPIC_PERSISTENCE_ENABLED
static final String	HOSTNAME
static final String	KAFKA_BRM_RECONNECTION_INTERVAL
static final String	KAFKA_BRM_RECONNECTION_MAX
static final String	KAFKA_CDR_COMPRESSION_TYPE
static final String	KAFKA_CDR_PARTITIONS
static final String	KAFKA_CDR_TOPIC_NAME
static final String	KAFKA_DGW_RECONNECTION_INTERVAL
static final String	KAFKA_DGW_RECONNECTION_MAX
static final String	KAFKA_HTTP_RECONNECTION_INTERVAL
static final String	KAFKA_HTTP_RECONNECTION_MAX
static final String	KAFKA_PRODUCER_RECONNECTION_INTERVAL
static final String	KAFKA_PRODUCER_RECONNECTION_MAX
static final String	KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS
static final String	KAFKA_RGW_RECONNECTION_MAX_MILLIS
static final String	KAFKA_RGW_TOPIC_NAME
static final String	KAFKA_SSL_ENABLED
static final String	KAFKA_TRUSTSTORE_LOCATION
static final String	NAME
static final String	OVERAGE_TOPIC_NAME
static final String	PARTITIONS
static final int	POF_EXTERNAL_PARTITIONS
static final int	POF_EXTERNAL_TOPIC_NAME
static final int	POF_FAILURE_PARTITIONS
static final int	POF_FAILURE_TOPIC_NAME
static final int	POF_HOSTNAME
static final int	POF_KAFKA_BRM_RECONNECTION_INTERVAL
static final int	POF_KAFKA_BRM_RECONNECTION_MAX
static final int	POF_KAFKA_CDR_COMPRESSION_TYPE
static final int	POF_KAFKA_CDR_PARTITIONS
static final int	POF_KAFKA_CDR_TOPIC_NAME
static final int	POF_KAFKA_DGW_RECONNECTION_INTERVAL
static final int	POF_KAFKA_DGW_RECONNECTION_MAX
static final int	POF_KAFKA_EXTERNAL_TOPIC_ENABLED
static final int	POF_KAFKA_FAILURE_TOPIC_PERSISTENCE_ENABLED
static final int	POF_KAFKA_HTTP_RECONNECTION_INTERVAL
static final int	POF_KAFKA_HTTP_RECONNECTION_MAX
static final int	POF_KAFKA_PRODUCER_RECONNECTION_INTERVAL
static final int	POF_KAFKA_PRODUCER_RECONNECTION_MAX
static final int	POF_KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS
static final int	POF_KAFKA_RGW_RECONNECTION_MAX_MILlIS
static final int	POF_KAFKA_RGW_TOPIC_NAME
static final int	POF_KAFKA_SSL_ENABLED
static final int	POF_KAFKA_TRUST_STORE_LOCATION
static final int	POF_NAME
static final int	POF_OVERAGE_TOPIC_NAME
static final int	POF_PARTITIONS
static final int	POF_SUSPENSE_TOPIC_NAME
static final int	POF_TOPICNAME
static final int	POF_WALLET_LOCATION
static final String	SUSPENSE_TOPIC_NAME
static final String	TOPICNAME
static final String	WALLET_LOCATION

Fields inherited from class oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean

CONFIG_CLASS, M_BEAN_CATEGORY, POF_IMPL

Constructor Summary

Constructors

Constructor	Description
KafkaConfiguration()
KafkaConfiguration(String name, String beanId)	Constructor

Method Summary

Modifier and Type	Method	Description
oracle.communication.brm.charging.util.directevolution.DEvolvable	createInstance()
boolean	equals(Object o)
String	getClusterName()	Cluster name of the child configuration MBean.
int	getExternalPartitions()
String	getExternalTopicEnabled()
String	getExternalTopicName()
int	getFailurePartitions()
String	getFailureTopicName()
String	getHostname()
Class	getImplementingClass()	The implementing class is needed for dynamic instantiation in abstract class.
int	getKafkaBRMReconnectionInterval()
int	getKafkaBRMReconnectionMax()
String	getKafkaCDRCompressionType()
int	getKafkaCDRPartitions()
String	getKafkaCDRTopicName()
int	getKafkaDGWReconnectionInterval()
int	getKafkaDGWReconnectionMax()
int	getKafkaHTTPReconnectionInterval()
int	getKafkaHTTPReconnectionMax()
int	getKafkaProducerReconnectionInterval()
int	getKafkaProducerReconnectionMax()
int	getKafkaRGWReconnectionIntervalMillis()
int	getKafkaRGWReconnectionMaxMillis()
String	getKafkaRGWTopicName()
boolean	getKafkaSSLEnabled()
String	getKafkaTrustStoreLocation()
String	getKafkaTrustStorePwd()
String	getKafkaTrustStorePwdFromWallet()
String	getName()	Unique name of the child configuration MBean.
String	getOverageTopicName()
int	getPartitions()
String	getPersistFailedRequestsToKafkaTopic()
String	getSuspenseTopicName()
String	getTopicName()
String	getWalletLocation()
void	giveInitializerTo(oracle.communication.brm.charging.util.directevolution.DEvolvableHelper DEvolvableHelper)
protected void	handlePrintConfiguration(org.apache.logging.log4j.Logger logger)	Method used by subclasses to dump their configuration settings to a log file.
int	hashCode()
void	republishAll()	Method used to persist and synchronize all app configuration beans to charging-settings.xml.
void	setClusterName(String clusterName)	Cluster name of the child configuration MBean.
void	setExternalPartitions(int externalPartitions)
void	setExternalTopicEnabled(String externalTopicEnabled)
void	setExternalTopicName(String externalTopicName)
void	setFailurePartitions(int failurePartitions)
void	setFailureTopicName(String failureTopicName)
void	setHostname(String hostname)
void	setKafkaBRMReconnectionInterval(int kafkaBRMReconnectionInterval)
void	setKafkaBRMReconnectionMax(int kafkaBRMReconnectionMax)
void	setKafkaCDRCompressionType(String kafkaCDRCompressionType)
void	setKafkaCDRPartitions(int kafkaCDRPartitions)
void	setKafkaCDRTopicName(String kafkaCDRTopicName)
void	setKafkaDGWReconnectionInterval(int kafkaDGWReconnectionInterval)
void	setKafkaDGWReconnectionMax(int kafkaDGWReconnectionMax)
void	setKafkaHTTPReconnectionInterval(int kafkaHTTPReconnectionInterval)
void	setKafkaHTTPReconnectionMax(int kafkaHTTPReconnectionMax)
void	setKafkaProducerReconnectionInterval(int kafkaProducerReconnectionInterval)
void	setKafkaProducerReconnectionMax(int kafkaProducerReconnectionMax)
void	setKafkaRGWReconnectionIntervalMillis(int kafkaRGWReconnectionIntervalMillis)
void	setKafkaRGWReconnectionMaxMillis(int kafkaRGWReconnectionMaxMillis)
void	setKafkaRGWTopicName(String kafkaRGWTopicName)
void	setkafkaSSLEnabled(boolean kafkaSSLEnabled)
void	setkafkaTrustStoreLocation(String kafkaTrustStoreLocation)
void	setkafkaTrustStorePwd(String kafkaTrustStorePwd, String walletPwd)
void	setName(String name)	Unique name of the child configuration MBean.
void	setOverageTopicName(String overageTopicName)
void	setPartitions(int partitions)
void	setPersistFailedRequestsToKafkaTopic(String persistFailedRequestsToKafkaTopic)
void	setSuspenseTopicName(String suspenseTopicName)
void	setTopicName(String topicName)
void	setWalletLocation(String walletLocation)

Methods inherited from class oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean

broadcast, clone, getBeanId, getEvolutionData, getFilename, getImpl, getModifyingClusterName, getModifyingMemberId, printConfiguration, publish, publish, publishArrayItem, publishClearArray, publishRemoveArrayItem, registerBean, setBeanId, setEvolutionData, setFilename, setModifyingClusterName, toBinary, toString, unRegisterBean

Methods inherited from class java.util.Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Methods inherited from interface oracle.communication.brm.charging.appconfiguration.ConfigurationBean

getBeanId, getFilename, getModifyingClusterName, getModifyingMemberId, printConfiguration, setBeanId, setFilename, setModifyingClusterName

Methods inherited from interface oracle.communication.brm.charging.util.directevolution.DEvolvable

clone, getEvolutionData, setEvolutionData

Field Details

POF_NAME

public static final int POF_NAME

See Also:

• Constant Field Values

POF_HOSTNAME

public static final int POF_HOSTNAME

See Also:

• Constant Field Values

POF_TOPICNAME

public static final int POF_TOPICNAME

See Also:

• Constant Field Values

POF_SUSPENSE_TOPIC_NAME

public static final int POF_SUSPENSE_TOPIC_NAME

See Also:

• Constant Field Values

POF_PARTITIONS

public static final int POF_PARTITIONS

See Also:

• Constant Field Values

POF_KAFKA_PRODUCER_RECONNECTION_INTERVAL

public static final int POF_KAFKA_PRODUCER_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

POF_KAFKA_PRODUCER_RECONNECTION_MAX

public static final int POF_KAFKA_PRODUCER_RECONNECTION_MAX

See Also:

• Constant Field Values

POF_KAFKA_DGW_RECONNECTION_INTERVAL

public static final int POF_KAFKA_DGW_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

POF_KAFKA_DGW_RECONNECTION_MAX

public static final int POF_KAFKA_DGW_RECONNECTION_MAX

See Also:

• Constant Field Values

POF_KAFKA_BRM_RECONNECTION_INTERVAL

public static final int POF_KAFKA_BRM_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

POF_KAFKA_BRM_RECONNECTION_MAX

public static final int POF_KAFKA_BRM_RECONNECTION_MAX

See Also:

• Constant Field Values

POF_KAFKA_HTTP_RECONNECTION_INTERVAL

public static final int POF_KAFKA_HTTP_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

POF_KAFKA_HTTP_RECONNECTION_MAX

public static final int POF_KAFKA_HTTP_RECONNECTION_MAX

See Also:

• Constant Field Values

POF_FAILURE_TOPIC_NAME

public static final int POF_FAILURE_TOPIC_NAME

See Also:

• Constant Field Values

POF_FAILURE_PARTITIONS

public static final int POF_FAILURE_PARTITIONS

See Also:

• Constant Field Values

POF_KAFKA_FAILURE_TOPIC_PERSISTENCE_ENABLED

public static final int POF_KAFKA_FAILURE_TOPIC_PERSISTENCE_ENABLED

See Also:

• Constant Field Values

POF_OVERAGE_TOPIC_NAME

public static final int POF_OVERAGE_TOPIC_NAME

See Also:

• Constant Field Values

POF_KAFKA_CDR_TOPIC_NAME

public static final int POF_KAFKA_CDR_TOPIC_NAME

See Also:

• Constant Field Values

POF_KAFKA_CDR_PARTITIONS

public static final int POF_KAFKA_CDR_PARTITIONS

See Also:

• Constant Field Values

POF_KAFKA_SSL_ENABLED

public static final int POF_KAFKA_SSL_ENABLED

See Also:

• Constant Field Values

POF_KAFKA_TRUST_STORE_LOCATION

public static final int POF_KAFKA_TRUST_STORE_LOCATION

See Also:

• Constant Field Values

POF_KAFKA_CDR_COMPRESSION_TYPE

public static final int POF_KAFKA_CDR_COMPRESSION_TYPE

See Also:

• Constant Field Values

POF_WALLET_LOCATION

public static final int POF_WALLET_LOCATION

See Also:

• Constant Field Values

POF_EXTERNAL_TOPIC_NAME

public static final int POF_EXTERNAL_TOPIC_NAME

See Also:

• Constant Field Values

POF_EXTERNAL_PARTITIONS

public static final int POF_EXTERNAL_PARTITIONS

See Also:

• Constant Field Values

POF_KAFKA_EXTERNAL_TOPIC_ENABLED

public static final int POF_KAFKA_EXTERNAL_TOPIC_ENABLED

See Also:

• Constant Field Values

POF_KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS

public static final int POF_KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS

See Also:

• Constant Field Values

POF_KAFKA_RGW_RECONNECTION_MAX_MILlIS

public static final int POF_KAFKA_RGW_RECONNECTION_MAX_MILlIS

See Also:

• Constant Field Values

POF_KAFKA_RGW_TOPIC_NAME

public static final int POF_KAFKA_RGW_TOPIC_NAME

See Also:

• Constant Field Values

DEFAULT_NAME

public static final String DEFAULT_NAME

See Also:

• Constant Field Values

DEFAULT_HOSTNAME

public static final String DEFAULT_HOSTNAME

See Also:

• Constant Field Values

DEFAULT_TOPICNAME

public static final String DEFAULT_TOPICNAME

See Also:

• Constant Field Values

DEFAULT_SUSPENSE_TOPIC_NAME

public static final String DEFAULT_SUSPENSE_TOPIC_NAME

See Also:

• Constant Field Values

DEFAULT_KAFKA_FAILURE_TOPIC_PERSISTENCE_ENABLED

public static final String DEFAULT_KAFKA_FAILURE_TOPIC_PERSISTENCE_ENABLED

See Also:

• Constant Field Values

DEFAULT_FAILURE_TOPIC_NAME

public static final String DEFAULT_FAILURE_TOPIC_NAME

See Also:

• Constant Field Values

DEFAULT_OVERAGE_TOPIC_NAME

public static final String DEFAULT_OVERAGE_TOPIC_NAME

See Also:

• Constant Field Values

DEFAULT_PARTITIONS

public static final int DEFAULT_PARTITIONS

See Also:

• Constant Field Values

DEFAULT_KAFKA_PRODUCER_RECONNECTION_INTERVAL

public static final int DEFAULT_KAFKA_PRODUCER_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

DEFAULT_KAFKA_PRODUCER_RECONNECTION_MAX

public static final int DEFAULT_KAFKA_PRODUCER_RECONNECTION_MAX

See Also:

• Constant Field Values

DEFAULT_KAFKA_DGW_RECONNECTION_INTERVAL

public static final int DEFAULT_KAFKA_DGW_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

DEFAULT_KAFKA_DGW_RECONNECTION_MAX

public static final int DEFAULT_KAFKA_DGW_RECONNECTION_MAX

See Also:

• Constant Field Values

DEFAULT_KAFKA_BRM_RECONNECTION_INTERVAL

public static final int DEFAULT_KAFKA_BRM_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

DEFAULT_KAFKA_BRM_RECONNECTION_MAX

public static final int DEFAULT_KAFKA_BRM_RECONNECTION_MAX

See Also:

• Constant Field Values

DEFAULT_KAFKA_HTTP_RECONNECTION_INTERVAL

public static final int DEFAULT_KAFKA_HTTP_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

DEFAULT_KAFKA_HTTP_RECONNECTION_MAX

public static final int DEFAULT_KAFKA_HTTP_RECONNECTION_MAX

See Also:

• Constant Field Values

DEFAULT_KAFKA_CDR_TOPIC_NAME

public static final String DEFAULT_KAFKA_CDR_TOPIC_NAME

See Also:

• Constant Field Values

DEFAULT_KAFKA_CDR_PARTITIONS

public static final int DEFAULT_KAFKA_CDR_PARTITIONS

See Also:

• Constant Field Values

DEFAULT_KAFKA_SSL_ENABLED

public static final boolean DEFAULT_KAFKA_SSL_ENABLED

See Also:

• Constant Field Values

DEFAULT_KAFKA_TRUST_STORE_LOCATION

public static final String DEFAULT_KAFKA_TRUST_STORE_LOCATION

See Also:

• Constant Field Values

DEFAULT_KAFKA_CDR_COMPRESSION_TYPE

public static final String DEFAULT_KAFKA_CDR_COMPRESSION_TYPE

See Also:

• Constant Field Values

DEFAULT_WALLET_LOCATION

public static final String DEFAULT_WALLET_LOCATION

See Also:

• Constant Field Values

DEFAULT_EXTERNAL_TOPIC_NAME

public static final String DEFAULT_EXTERNAL_TOPIC_NAME

See Also:

• Constant Field Values

DEFAULT_EXTERNAL_PARTITIONS

public static final int DEFAULT_EXTERNAL_PARTITIONS

See Also:

• Constant Field Values

DEFAULT_KAFKA_EXTERNAL_TOPIC_ENABLED

public static final String DEFAULT_KAFKA_EXTERNAL_TOPIC_ENABLED

See Also:

• Constant Field Values

DEFAULT_KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS

public static final int DEFAULT_KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS

See Also:

• Constant Field Values

DEFAULT_KAFKA_RGW_RECONNECTION_MAX_MILLIS

public static final int DEFAULT_KAFKA_RGW_RECONNECTION_MAX_MILLIS

See Also:

• Constant Field Values

DEFAULT_KAFKA_RGW_TOPIC_NAME

public static final String DEFAULT_KAFKA_RGW_TOPIC_NAME

See Also:

• Constant Field Values

NAME

public static final String NAME

See Also:

• Constant Field Values

HOSTNAME

public static final String HOSTNAME

See Also:

• Constant Field Values

TOPICNAME

public static final String TOPICNAME

See Also:

• Constant Field Values

SUSPENSE_TOPIC_NAME

public static final String SUSPENSE_TOPIC_NAME

See Also:

• Constant Field Values

FAILURE_TOPIC_PERSISTENCE_ENABLED

public static final String FAILURE_TOPIC_PERSISTENCE_ENABLED

See Also:

• Constant Field Values

FAILURE_TOPIC_NAME

public static final String FAILURE_TOPIC_NAME

See Also:

• Constant Field Values

PARTITIONS

public static final String PARTITIONS

See Also:

• Constant Field Values

FAILURE_PARTITIONS

public static final String FAILURE_PARTITIONS

See Also:

• Constant Field Values

OVERAGE_TOPIC_NAME

public static final String OVERAGE_TOPIC_NAME

See Also:

• Constant Field Values

KAFKA_PRODUCER_RECONNECTION_INTERVAL

public static final String KAFKA_PRODUCER_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

KAFKA_PRODUCER_RECONNECTION_MAX

public static final String KAFKA_PRODUCER_RECONNECTION_MAX

See Also:

• Constant Field Values

KAFKA_DGW_RECONNECTION_INTERVAL

public static final String KAFKA_DGW_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

KAFKA_DGW_RECONNECTION_MAX

public static final String KAFKA_DGW_RECONNECTION_MAX

See Also:

• Constant Field Values

KAFKA_BRM_RECONNECTION_INTERVAL

public static final String KAFKA_BRM_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

KAFKA_BRM_RECONNECTION_MAX

public static final String KAFKA_BRM_RECONNECTION_MAX

See Also:

• Constant Field Values

KAFKA_HTTP_RECONNECTION_INTERVAL

public static final String KAFKA_HTTP_RECONNECTION_INTERVAL

See Also:

• Constant Field Values

KAFKA_HTTP_RECONNECTION_MAX

public static final String KAFKA_HTTP_RECONNECTION_MAX

See Also:

• Constant Field Values

KAFKA_CDR_TOPIC_NAME

public static final String KAFKA_CDR_TOPIC_NAME

See Also:

• Constant Field Values

KAFKA_CDR_PARTITIONS

public static final String KAFKA_CDR_PARTITIONS

See Also:

• Constant Field Values

KAFKA_SSL_ENABLED

public static final String KAFKA_SSL_ENABLED

See Also:

• Constant Field Values

KAFKA_TRUSTSTORE_LOCATION

public static final String KAFKA_TRUSTSTORE_LOCATION

See Also:

• Constant Field Values

KAFKA_CDR_COMPRESSION_TYPE

public static final String KAFKA_CDR_COMPRESSION_TYPE

See Also:

• Constant Field Values

WALLET_LOCATION

public static final String WALLET_LOCATION

See Also:

• Constant Field Values

EXTERNAL_TOPIC_NAME

public static final String EXTERNAL_TOPIC_NAME

See Also:

• Constant Field Values

EXTERNAL_PARTITIONS

public static final String EXTERNAL_PARTITIONS

See Also:

• Constant Field Values

EXTERNAL_TOPIC_ENABLED

public static final String EXTERNAL_TOPIC_ENABLED

See Also:

• Constant Field Values

KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS

public static final String KAFKA_RGW_RECONNECTION_INTERVAL_MILLIS

See Also:

• Constant Field Values

KAFKA_RGW_RECONNECTION_MAX_MILLIS

public static final String KAFKA_RGW_RECONNECTION_MAX_MILLIS

See Also:

• Constant Field Values

KAFKA_RGW_TOPIC_NAME

public static final String KAFKA_RGW_TOPIC_NAME

See Also:

• Constant Field Values

Constructor Details

KafkaConfiguration

public KafkaConfiguration()

KafkaConfiguration

public KafkaConfiguration(String name,
 String beanId)

Constructor

Parameters:

name - bean name

beanId - bean id

Method Details

getHostname

public String getHostname()

Specified by:

getHostname in interface KafkaConfigurationMBean

setHostname

public void setHostname(String hostname)

Specified by:

setHostname in interface KafkaConfigurationMBean

getTopicName

public String getTopicName()

Specified by:

getTopicName in interface KafkaConfigurationMBean

setTopicName

public void setTopicName(String topicName)

Specified by:

setTopicName in interface KafkaConfigurationMBean

getSuspenseTopicName

public String getSuspenseTopicName()

Specified by:

getSuspenseTopicName in interface KafkaConfigurationMBean

setSuspenseTopicName

public void setSuspenseTopicName(String suspenseTopicName)

Specified by:

setSuspenseTopicName in interface KafkaConfigurationMBean

getPersistFailedRequestsToKafkaTopic

public String getPersistFailedRequestsToKafkaTopic()

Specified by:

getPersistFailedRequestsToKafkaTopic in interface KafkaConfigurationMBean

setPersistFailedRequestsToKafkaTopic

public void setPersistFailedRequestsToKafkaTopic(String persistFailedRequestsToKafkaTopic)

Specified by:

setPersistFailedRequestsToKafkaTopic in interface KafkaConfigurationMBean

getFailureTopicName

public String getFailureTopicName()

Specified by:

getFailureTopicName in interface KafkaConfigurationMBean

setFailureTopicName

public void setFailureTopicName(String failureTopicName)

Specified by:

setFailureTopicName in interface KafkaConfigurationMBean

getOverageTopicName

public String getOverageTopicName()

Specified by:

getOverageTopicName in interface KafkaConfigurationMBean

setOverageTopicName

public void setOverageTopicName(String overageTopicName)

Specified by:

setOverageTopicName in interface KafkaConfigurationMBean

getExternalTopicName

public String getExternalTopicName()

Specified by:

getExternalTopicName in interface KafkaConfigurationMBean

setExternalTopicName

public void setExternalTopicName(String externalTopicName)

Specified by:

setExternalTopicName in interface KafkaConfigurationMBean

getExternalTopicEnabled

public String getExternalTopicEnabled()

Specified by:

getExternalTopicEnabled in interface KafkaConfigurationMBean

setExternalTopicEnabled

public void setExternalTopicEnabled(String externalTopicEnabled)

Specified by:

setExternalTopicEnabled in interface KafkaConfigurationMBean

getExternalPartitions

public int getExternalPartitions()

Specified by:

getExternalPartitions in interface KafkaConfigurationMBean

setExternalPartitions

public void setExternalPartitions(int externalPartitions)

Specified by:

setExternalPartitions in interface KafkaConfigurationMBean

getKafkaRGWTopicName

public String getKafkaRGWTopicName()

Specified by:

getKafkaRGWTopicName in interface KafkaConfigurationMBean

setKafkaRGWTopicName

public void setKafkaRGWTopicName(String kafkaRGWTopicName)

Specified by:

setKafkaRGWTopicName in interface KafkaConfigurationMBean

getName

public String getName()

Description copied from interface: oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Unique name of the child configuration MBean. This name will be used to construct the Mbean name

Specified by:

getName in interface oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Returns:

name of the child bean

setName

public void setName(String name)

Description copied from interface: oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Unique name of the child configuration MBean. This name will be used to construct the Mbean name

Specified by:

setName in interface oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Parameters:

name -

getPartitions

public int getPartitions()

Specified by:

getPartitions in interface KafkaConfigurationMBean

setPartitions

public void setPartitions(int partitions)

Specified by:

setPartitions in interface KafkaConfigurationMBean

getFailurePartitions

public int getFailurePartitions()

Specified by:

getFailurePartitions in interface KafkaConfigurationMBean

setFailurePartitions

public void setFailurePartitions(int failurePartitions)

Specified by:

setFailurePartitions in interface KafkaConfigurationMBean

getKafkaProducerReconnectionInterval

public int getKafkaProducerReconnectionInterval()

Specified by:

getKafkaProducerReconnectionInterval in interface KafkaConfigurationMBean

setKafkaProducerReconnectionInterval

public void setKafkaProducerReconnectionInterval(int kafkaProducerReconnectionInterval)

Specified by:

setKafkaProducerReconnectionInterval in interface KafkaConfigurationMBean

getKafkaProducerReconnectionMax

public int getKafkaProducerReconnectionMax()

Specified by:

getKafkaProducerReconnectionMax in interface KafkaConfigurationMBean

setKafkaProducerReconnectionMax

public void setKafkaProducerReconnectionMax(int kafkaProducerReconnectionMax)

Specified by:

setKafkaProducerReconnectionMax in interface KafkaConfigurationMBean

getKafkaDGWReconnectionInterval

public int getKafkaDGWReconnectionInterval()

Specified by:

getKafkaDGWReconnectionInterval in interface KafkaConfigurationMBean

setKafkaDGWReconnectionInterval

public void setKafkaDGWReconnectionInterval(int kafkaDGWReconnectionInterval)

Specified by:

setKafkaDGWReconnectionInterval in interface KafkaConfigurationMBean

getKafkaDGWReconnectionMax

public int getKafkaDGWReconnectionMax()

Specified by:

getKafkaDGWReconnectionMax in interface KafkaConfigurationMBean

setKafkaDGWReconnectionMax

public void setKafkaDGWReconnectionMax(int kafkaDGWReconnectionMax)

Specified by:

setKafkaDGWReconnectionMax in interface KafkaConfigurationMBean

getKafkaBRMReconnectionInterval

public int getKafkaBRMReconnectionInterval()

Specified by:

getKafkaBRMReconnectionInterval in interface KafkaConfigurationMBean

setKafkaBRMReconnectionInterval

public void setKafkaBRMReconnectionInterval(int kafkaBRMReconnectionInterval)

Specified by:

setKafkaBRMReconnectionInterval in interface KafkaConfigurationMBean

getKafkaBRMReconnectionMax

public int getKafkaBRMReconnectionMax()

Specified by:

getKafkaBRMReconnectionMax in interface KafkaConfigurationMBean

setKafkaBRMReconnectionMax

public void setKafkaBRMReconnectionMax(int kafkaBRMReconnectionMax)

Specified by:

setKafkaBRMReconnectionMax in interface KafkaConfigurationMBean

getKafkaHTTPReconnectionInterval

public int getKafkaHTTPReconnectionInterval()

Specified by:

getKafkaHTTPReconnectionInterval in interface KafkaConfigurationMBean

setKafkaHTTPReconnectionInterval

public void setKafkaHTTPReconnectionInterval(int kafkaHTTPReconnectionInterval)

Specified by:

setKafkaHTTPReconnectionInterval in interface KafkaConfigurationMBean

getKafkaHTTPReconnectionMax

public int getKafkaHTTPReconnectionMax()

Specified by:

getKafkaHTTPReconnectionMax in interface KafkaConfigurationMBean

setKafkaHTTPReconnectionMax

public void setKafkaHTTPReconnectionMax(int kafkaHTTPReconnectionMax)

Specified by:

setKafkaHTTPReconnectionMax in interface KafkaConfigurationMBean

getKafkaRGWReconnectionIntervalMillis

public int getKafkaRGWReconnectionIntervalMillis()

Specified by:

getKafkaRGWReconnectionIntervalMillis in interface KafkaConfigurationMBean

setKafkaRGWReconnectionIntervalMillis

public void setKafkaRGWReconnectionIntervalMillis(int kafkaRGWReconnectionIntervalMillis)

Specified by:

setKafkaRGWReconnectionIntervalMillis in interface KafkaConfigurationMBean

getKafkaRGWReconnectionMaxMillis

public int getKafkaRGWReconnectionMaxMillis()

Specified by:

getKafkaRGWReconnectionMaxMillis in interface KafkaConfigurationMBean

setKafkaRGWReconnectionMaxMillis

public void setKafkaRGWReconnectionMaxMillis(int kafkaRGWReconnectionMaxMillis)

Specified by:

setKafkaRGWReconnectionMaxMillis in interface KafkaConfigurationMBean

getKafkaCDRTopicName

public String getKafkaCDRTopicName()

Specified by:

getKafkaCDRTopicName in interface KafkaConfigurationMBean

setKafkaCDRTopicName

public void setKafkaCDRTopicName(String kafkaCDRTopicName)

Specified by:

setKafkaCDRTopicName in interface KafkaConfigurationMBean

getKafkaCDRPartitions

public int getKafkaCDRPartitions()

Specified by:

getKafkaCDRPartitions in interface KafkaConfigurationMBean

setKafkaCDRPartitions

public void setKafkaCDRPartitions(int kafkaCDRPartitions)

Specified by:

setKafkaCDRPartitions in interface KafkaConfigurationMBean

getKafkaSSLEnabled

public boolean getKafkaSSLEnabled()

Specified by:

getKafkaSSLEnabled in interface KafkaConfigurationMBean

setkafkaSSLEnabled

public void setkafkaSSLEnabled(boolean kafkaSSLEnabled)

Specified by:

setkafkaSSLEnabled in interface KafkaConfigurationMBean

getKafkaTrustStoreLocation

public String getKafkaTrustStoreLocation()

Specified by:

getKafkaTrustStoreLocation in interface KafkaConfigurationMBean

setkafkaTrustStoreLocation

public void setkafkaTrustStoreLocation(String kafkaTrustStoreLocation)

Specified by:

setkafkaTrustStoreLocation in interface KafkaConfigurationMBean

getKafkaTrustStorePwd

public String getKafkaTrustStorePwd()

Specified by:

getKafkaTrustStorePwd in interface KafkaConfigurationMBean

getKafkaTrustStorePwdFromWallet

public String getKafkaTrustStorePwdFromWallet()

setkafkaTrustStorePwd

public void setkafkaTrustStorePwd(String kafkaTrustStorePwd,
 String walletPwd)

Specified by:

setkafkaTrustStorePwd in interface KafkaConfigurationMBean

getKafkaCDRCompressionType

public String getKafkaCDRCompressionType()

Specified by:

getKafkaCDRCompressionType in interface KafkaConfigurationMBean

setKafkaCDRCompressionType

public void setKafkaCDRCompressionType(String kafkaCDRCompressionType)

Specified by:

setKafkaCDRCompressionType in interface KafkaConfigurationMBean

getWalletLocation

public String getWalletLocation()

Specified by:

getWalletLocation in interface KafkaConfigurationMBean

setWalletLocation

public void setWalletLocation(String walletLocation)

Specified by:

setWalletLocation in interface KafkaConfigurationMBean

getClusterName

public String getClusterName()

Description copied from interface: oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Cluster name of the child configuration MBean. This name will be used to construct the Mbean name

Specified by:

getClusterName in interface oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Returns:

cluster name of the child bean

setClusterName

public void setClusterName(String clusterName)

Description copied from interface: oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Cluster name of the child configuration MBean. This name will be used to construct the Mbean name

Specified by:

setClusterName in interface oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Parameters:

clusterName - cluster name of the child bean

getImplementingClass

public Class getImplementingClass()

Description copied from interface: oracle.communication.brm.charging.appconfiguration.ChildConfigBean

The implementing class is needed for dynamic instantiation in abstract class.

Specified by:

getImplementingClass in interface oracle.communication.brm.charging.appconfiguration.ChildConfigBean

Returns:

Implementing class

republishAll

public void republishAll()

Description copied from interface: oracle.communication.brm.charging.appconfiguration.ConfigurationBean

Method used to persist and synchronize all app configuration beans to charging-settings.xml.

Specified by:

republishAll in interface oracle.communication.brm.charging.appconfiguration.ConfigurationBean

handlePrintConfiguration

protected void handlePrintConfiguration(org.apache.logging.log4j.Logger logger)

Description copied from class: oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean

Method used by subclasses to dump their configuration settings to a log file.

Specified by:

handlePrintConfiguration in class oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean

Parameters:

logger - the logger is provided to subclassers for writing their config values.

createInstance

public oracle.communication.brm.charging.util.directevolution.DEvolvable createInstance()

Specified by:

createInstance in interface oracle.communication.brm.charging.util.directevolution.DEvolvable

giveInitializerTo

public void giveInitializerTo(oracle.communication.brm.charging.util.directevolution.DEvolvableHelper DEvolvableHelper)

Specified by:

giveInitializerTo in interface oracle.communication.brm.charging.util.directevolution.DEvolvable

Overrides:

giveInitializerTo in class oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean

equals

public boolean equals(Object o)

Overrides:

equals in class oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean

hashCode

public int hashCode()

Overrides:

hashCode in class oracle.communication.brm.charging.appconfiguration.AbstractConfigurationBean