public class QDEndpoint extends Object implements Closeable
newBuilder()
.build()
to create an instance of this class.
Modifier and Type | Class and Description |
---|---|
static class |
QDEndpoint.Builder
Builder that creates instances of
QDEndpoint objects. |
static interface |
QDEndpoint.ConnectorInitializer
A strategy that defines how to create
MessageConnectors ,
which should be used QDEndpoint for connect(String) . |
static class |
QDEndpoint.Plugin |
Modifier and Type | Field and Description |
---|---|
static String |
NAME_PROPERTY
Defines property for endpoint name that is used to distinguish multiple endpoints
in the same JVM in logs and in other diagnostic means.
|
Modifier | Constructor and Description |
---|---|
protected |
QDEndpoint(String name,
DataScheme scheme,
QDStats rootStats,
List<QDCollector.Factory> collectors,
boolean withEventTimeSequence,
boolean storeEverything)
Creates custom endpoint with a specified name, scheme, and root stats, without management.
|
public static final String NAME_PROPERTY
QDEndpoint.Builder.withProperty(String, String)
method.
This property is also changed by QDEndpoint.Builder.withName(String)
method.protected QDEndpoint(String name, DataScheme scheme, QDStats rootStats, List<QDCollector.Factory> collectors, boolean withEventTimeSequence, boolean storeEverything)
For routine case, always use QDEndpoint.Builder.build()
.
public static QDEndpoint.Builder newBuilder()
QDEndpoint.Builder
instance.
Use QDEndpoint.Builder.build()
to build an instance of QDEndpoint
when
all configuration properties were set.public Object getLock()
public void connect(String address)
connectorInitializer
, otherwise it will be
IllegalStateException
.address
- address(es) to connect to.hasConnectorInitializer()
public void initializeConnectorsForAddress(String address)
connectorInitializer
, otherwise it will be
IllegalStateException
.address
- address(es) to connect to.hasConnectorInitializer()
public void setConnectorInitializer(QDEndpoint.ConnectorInitializer connectorInitializer)
QDEndpoint.ConnectorInitializer
for this endpoint, which is used in connect(String)
connectorInitializer
- QDEndpoint.ConnectorInitializer
, which is used in connect(String)
public boolean hasConnectorInitializer()
true
if this endpoint has a QDEndpoint.ConnectorInitializer
, otherwise returns false
public boolean hasEventTimeSequence()
true
if this endpoint supports event time sequence
or any it's collector supports event time sequencetrue
if this endpoint supports event time sequence
or any it's collector supports event time sequencepublic boolean isClosed()
public final String getName()
public final DataScheme getScheme()
public QDStats getRootStats()
public final QDTicker getTicker()
public final QDStream getStream()
public final QDHistory getHistory()
public QDCollector getCollector(QDContract contract)
public Set<QDContract> getContracts()
public Collection<QDCollector> getCollectors()
public List<MessageConnector> getConnectors()
public QDEndpoint addCollector(QDCollector collector)
QDEndpoint(String, DataScheme, QDStats, List, boolean, boolean)
. If this endpoint was created by using
QDEndpoint.Builder.build()
, collectors had to be added by QDEndpoint.Builder.withCollectors(Collection)
.collector
- which to be added to this endpointpublic QDEndpoint addCollectors(QDCollector... collectors)
QDEndpoint(String, DataScheme, QDStats, List, boolean, boolean)
. If this endpoint was created by using
QDEndpoint.Builder.build()
, collectors had to be added by QDEndpoint.Builder.withCollectors(Collection)
.collectors
- which to be added to this endpointpublic final void addPlugin(QDEndpoint.Plugin plugin)
public final void removePlugin(QDEndpoint.Plugin plugin)
public QDEndpoint user(String user)
public QDEndpoint password(String password)
public final QDEndpoint addConnectors(Collection<MessageConnector> connectors)
protected void addConnectorsImpl(Collection<MessageConnector> connectors)
public QDEndpoint startConnectors()
public final void restartActiveConnectors()
public final void awaitProcessed() throws InterruptedException
InterruptedException
public final void stopConnectors()
public final void stopConnectorsAndWait() throws InterruptedException
InterruptedException
public final void stopConnectorsAndWaitUninterruptibly()
public final void cleanupConnectors()
protected void cleanupConnectorsImpl(Collection<MessageConnector> connectors)
public QDEndpoint addMessageConnectionListener(MessageConnectorListener listener)
public QDEndpoint removeMessageConnectionListener(MessageConnectorListener listener)
public void registerMonitoringTask(Runnable task)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
protected void closeImpl()
public com.devexperts.connector.proto.EndpointId getEndpointId()
Copyright © 2002-2020 Devexperts LLC. All Rights Reserved.