public class ServiceBrokerConfig
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected Cacher |
cacher |
protected Eventbus |
eventbus |
protected java.util.concurrent.ExecutorService |
executor |
protected java.util.concurrent.atomic.AtomicLong |
instanceCounter
Service Broker instance counter (0...N)
|
protected boolean |
internalServices
Install internal ($node) services?
|
protected java.lang.String |
jsonReaders
Name (or comma-separated list) of the JSON deserializer API ("jackson",
"boon", "builtin", "gson", "fastjson", "genson", etc., null = autodetect
/ fastest)
|
protected java.lang.String |
jsonWriters
Name (or comma-separated list) of the JSON serializer API ("jackson",
"boon", "builtin", "gson", "fast", "genson", "flex", "nano", etc., null =
autodetect / fastest)
|
protected Metrics |
metrics |
protected boolean |
metricsEnabled |
protected Monitor |
monitor |
protected java.lang.String |
namespace
Namespace of Broker.
|
protected java.lang.String |
nodeID
Unique NodeID of Broker.
|
protected java.util.concurrent.ScheduledExecutorService |
scheduler |
protected ServiceInvoker |
serviceInvoker |
protected ServiceRegistry |
serviceRegistry |
protected boolean |
shutDownThreadPools |
protected StrategyFactory |
strategyFactory |
protected Transporter |
transporter |
protected UidGenerator |
uidGenerator |
| Constructor and Description |
|---|
ServiceBrokerConfig() |
ServiceBrokerConfig(java.lang.String nodeID,
Cacher cacher,
Transporter transporter) |
| Modifier and Type | Method and Description |
|---|---|
Cacher |
getCacher() |
Eventbus |
getEventbus() |
java.util.concurrent.ExecutorService |
getExecutor() |
java.lang.String |
getJsonReaders() |
java.lang.String |
getJsonWriters() |
Metrics |
getMetrics() |
Monitor |
getMonitor() |
java.lang.String |
getNamespace() |
java.lang.String |
getNodeID() |
java.util.concurrent.ScheduledExecutorService |
getScheduler() |
ServiceInvoker |
getServiceInvoker() |
ServiceRegistry |
getServiceRegistry() |
StrategyFactory |
getStrategyFactory() |
Transporter |
getTransporter() |
UidGenerator |
getUidGenerator() |
boolean |
isInternalServices() |
boolean |
isMetricsEnabled() |
boolean |
isShutDownThreadPools() |
void |
setCacher(Cacher cacher) |
void |
setEventbus(Eventbus eventbus) |
void |
setExecutor(java.util.concurrent.ExecutorService executor) |
void |
setInternalServices(boolean internalServices) |
void |
setJsonReaders(java.lang.String jsonReader) |
void |
setJsonWriters(java.lang.String jsonWriter) |
void |
setMetrics(Metrics metrics) |
void |
setMetricsEnabled(boolean metricsEnabled) |
void |
setMonitor(Monitor monitor) |
void |
setNamespace(java.lang.String namespace) |
void |
setNodeID(java.lang.String nodeID) |
void |
setScheduler(java.util.concurrent.ScheduledExecutorService scheduler) |
void |
setServiceInvoker(ServiceInvoker serviceInvoker) |
void |
setServiceRegistry(ServiceRegistry serviceRegistry) |
void |
setShutDownThreadPools(boolean shutDownThreadPools) |
void |
setStrategyFactory(StrategyFactory strategyFactory) |
void |
setTransporter(Transporter transporter) |
void |
setUidGenerator(UidGenerator uidGenerator) |
protected java.util.concurrent.ExecutorService executor
protected java.util.concurrent.ScheduledExecutorService scheduler
protected boolean shutDownThreadPools
protected java.lang.String namespace
protected java.lang.String nodeID
protected boolean internalServices
protected java.lang.String jsonReaders
protected java.lang.String jsonWriters
protected java.util.concurrent.atomic.AtomicLong instanceCounter
protected UidGenerator uidGenerator
protected StrategyFactory strategyFactory
protected Eventbus eventbus
protected ServiceRegistry serviceRegistry
protected ServiceInvoker serviceInvoker
protected Metrics metrics
protected Cacher cacher
protected Transporter transporter
protected Monitor monitor
protected boolean metricsEnabled
public ServiceBrokerConfig()
public ServiceBrokerConfig(java.lang.String nodeID,
Cacher cacher,
Transporter transporter)
public java.util.concurrent.ExecutorService getExecutor()
public void setExecutor(java.util.concurrent.ExecutorService executor)
public java.util.concurrent.ScheduledExecutorService getScheduler()
public void setScheduler(java.util.concurrent.ScheduledExecutorService scheduler)
public boolean isShutDownThreadPools()
public void setShutDownThreadPools(boolean shutDownThreadPools)
public java.lang.String getNamespace()
public void setNamespace(java.lang.String namespace)
public java.lang.String getNodeID()
public void setNodeID(java.lang.String nodeID)
public boolean isInternalServices()
public void setInternalServices(boolean internalServices)
public java.lang.String getJsonReaders()
public void setJsonReaders(java.lang.String jsonReader)
public java.lang.String getJsonWriters()
public void setJsonWriters(java.lang.String jsonWriter)
public ServiceRegistry getServiceRegistry()
public void setServiceRegistry(ServiceRegistry serviceRegistry)
public StrategyFactory getStrategyFactory()
public void setStrategyFactory(StrategyFactory strategyFactory)
public UidGenerator getUidGenerator()
public void setUidGenerator(UidGenerator uidGenerator)
public Eventbus getEventbus()
public void setEventbus(Eventbus eventbus)
public Cacher getCacher()
public void setCacher(Cacher cacher)
public Monitor getMonitor()
public void setMonitor(Monitor monitor)
public Transporter getTransporter()
public void setTransporter(Transporter transporter)
public ServiceInvoker getServiceInvoker()
public void setServiceInvoker(ServiceInvoker serviceInvoker)
public Metrics getMetrics()
public void setMetrics(Metrics metrics)
public boolean isMetricsEnabled()
public void setMetricsEnabled(boolean metricsEnabled)