Package overit.geocall.event.model

Class ConsumerProperties

java.lang.Object

overit.geocall.event.model.ConsumerProperties

All Implemented Interfaces:

Serializable

public class ConsumerProperties
extends Object
implements Serializable

A ConsumerProperties entity is in charge to handle the parameters defined via system or company configuration, it contains all properties needed to define a consumer

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ConsumerProperties(Company company, String subscription, String source, String type, String endpoint, int nThreads)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getAgent()
List<Company>	getCompanies()
Company	getCompany()
String	getEmergencyTopic()
String	getEndpoint()
int	getNThreads()
Properties	getParameters()
String	getPartition()
long	getPoolTimeout()
String	getSource()
List<String>	getSpins()
String	getSubscription()
String	getTenant()
List<String>	getTopics()
String	getType()
int	hashCode()
boolean	isLogging()
boolean	isTopicSegregation()
void	setAgent(String agent)
void	setCompanies(List<Company> companies)
void	setEmergencyTopic(String emergencyTopic)
void	setLogging(boolean logging)
void	setNThreads(int nThreads)
void	setParameters(Properties parameters)
void	setPartition(String partition)
void	setPoolTimeout(long poolTimeout)
void	setSpins(List<String> spins)
void	setTenant(String tenant)
void	setTopics(List<String> topics)
void	setTopicSegregation(boolean topicSegregation)

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerProperties

public ConsumerProperties(Company company,
 String subscription,
 String source,
 String type,
 String endpoint,
 int nThreads)

Method Details

getSubscription

public String getSubscription()

getSource

public String getSource()

getType

public String getType()

getTopics

public List<String> getTopics()

getSpins

public List<String> getSpins()

getEndpoint

public String getEndpoint()

getPartition

public String getPartition()

getEmergencyTopic

public String getEmergencyTopic()

getParameters

public Properties getParameters()

getNThreads

public int getNThreads()

getCompany

public Company getCompany()

setTopics

public void setTopics(List<String> topics)

setSpins

public void setSpins(List<String> spins)

setPartition

public void setPartition(String partition)

setEmergencyTopic

public void setEmergencyTopic(String emergencyTopic)

setNThreads

public void setNThreads(int nThreads)

isLogging

public boolean isLogging()

setLogging

public void setLogging(boolean logging)

setParameters

public void setParameters(Properties parameters)

isTopicSegregation

public boolean isTopicSegregation()

setTopicSegregation

public void setTopicSegregation(boolean topicSegregation)

getAgent

public String getAgent()

setAgent

public void setAgent(String agent)

getTenant

public String getTenant()

setTenant

public void setTenant(String tenant)

getCompanies

public List<Company> getCompanies()

setCompanies

public void setCompanies(List<Company> companies)

getPoolTimeout

public long getPoolTimeout()

setPoolTimeout

public void setPoolTimeout(long poolTimeout)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object