|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.devexperts.qd.qtp.MessageConsumerAdapter
com.devexperts.qd.qtp.MessageAdapter
com.devexperts.qd.qtp.DistributorAdapter
public class DistributorAdapter
The DistributorAdapter
adapts distributor side of QD to message API.
The distributor side of an QD is an aggregation of QDDistributor
for all its APIs (the DistributorAdapter
creates its own distributors,
one distributor per API). Thus, the DistributorAdapter
can be used
to represent an outside data provider in the specific QD.
if you are a QD client - use this Adapter
Nested Class Summary | |
---|---|
static class |
DistributorAdapter.Factory
The factory for distributor side of an QD. |
Nested classes/interfaces inherited from class com.devexperts.qd.qtp.MessageAdapter |
---|
MessageAdapter.AbstractFactory, MessageAdapter.CloseListener |
Field Summary |
---|
Fields inherited from class com.devexperts.qd.qtp.MessageAdapter |
---|
closeListener, messageListener |
Fields inherited from interface com.devexperts.qd.SubscriptionListener |
---|
VOID |
Constructor Summary | |
---|---|
DistributorAdapter(QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDStats stats)
|
Method Summary | |
---|---|
protected void |
closeImpl()
|
protected QDDistributor |
createDistributor(QDCollector collector,
SubscriptionFilter filter,
java.lang.String keyProperties)
This method is used internally by distributor adapter to create agent for the corresponding collector, filter, and keyProperties from this adapter's constructor. |
DataScheme |
getScheme()
|
java.lang.String |
getSymbol(char[] chars,
int offset,
int length)
Returns symbol used for specified characters or null if not found. |
boolean |
isProtocolDescriptorCompatible(ProtocolDescriptor desc)
|
long |
nextRetrieveTime(long currentTime)
|
void |
prepareProtocolDescriptor(ProtocolDescriptor desc)
Prepares outgoing protocol descriptor. |
protected void |
processData(DataIterator iterator,
MessageType message)
|
void |
processDescribeProtocol(ProtocolDescriptor desc)
Process incoming protocol descriptor. |
boolean |
retrieveMessages(MessageVisitor visitor)
Retrieves accumulated message into specified message visitor. |
protected void |
startImpl()
|
void |
subscriptionAvailable(SubscriptionProvider provider)
Notifies this listener that subscription is available in the specified subscription provider. |
protected void |
subscriptionChanged(SubscriptionProvider provider,
MessageType message)
|
java.lang.String |
toString()
Returns description of this MessageAdapter for management and logging purposes. |
void |
useDescribeProtocol()
Invocation of this method causes this MessageAdapter to send
DESCRIBE_PROTOCOL message if it is capable of doing so. |
protected boolean |
visitSubscription(MessageVisitor visitor,
SubscriptionProvider provider,
MessageType message)
|
Methods inherited from class com.devexperts.qd.qtp.MessageAdapter |
---|
addMask, clearMessageMask, close, getCommonScheme, getConnectionVariables, getMessageMask, getRemoteHostAddress, getStats, getStatus, getSubscriptionFilterFactory, handleCorruptedMessage, handleCorruptedStream, handleUnknownMessage, hasMessageMask, isAlive, isClosed, notifyListener, reportIgnoredMessage, retrieveDescribeProtocolMessage, retrieveMask, setCloseListener, setConnectionVariables, setMessageListener, start |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public DistributorAdapter(QDTicker ticker, QDStream stream, QDHistory history, SubscriptionFilter filter, QDStats stats)
Method Detail |
---|
protected QDDistributor createDistributor(QDCollector collector, SubscriptionFilter filter, java.lang.String keyProperties)
collector.createDistributor(filter, keyProperties)
.
This method may be overridden to create agent with other filter, otherwise customize the agent
that is being created, or to keep track of created agents.
public java.lang.String toString()
MessageAdapter
MessageAdapter
for management and logging purposes.
toString
in class MessageAdapter
public DataScheme getScheme()
getScheme
in class MessageAdapter
public java.lang.String getSymbol(char[] chars, int offset, int length)
MessageConsumerAdapter
null
if not found.
getSymbol
in class MessageConsumerAdapter
public void useDescribeProtocol()
MessageAdapter
MessageAdapter
to send
DESCRIBE_PROTOCOL
message if it is capable of doing so.
It should be invoked once before calling MessageAdapter.start()
.
The code that calls this method shall also consult MessageAdapter.nextRetrieveTime(long)
.
useDescribeProtocol
in class MessageAdapter
protected void startImpl()
startImpl
in class MessageAdapter
protected void closeImpl()
closeImpl
in class MessageAdapter
protected void processData(DataIterator iterator, MessageType message)
processData
in class MessageConsumerAdapter
public long nextRetrieveTime(long currentTime)
nextRetrieveTime
in class MessageAdapter
public boolean retrieveMessages(MessageVisitor visitor)
MessageProvider
true
if some messages still remains in the provider
or false
if all accumulated messages were retrieved.
retrieveMessages
in interface MessageProvider
retrieveMessages
in class MessageAdapter
public void prepareProtocolDescriptor(ProtocolDescriptor desc)
MessageAdapter
super.prepareProtocolDescriptor(desc)
.
prepareProtocolDescriptor
in class MessageAdapter
desc
- outgoing protocol descriptorpublic void processDescribeProtocol(ProtocolDescriptor desc)
MessageAdapter
super.processDescribeProtocol(desc)
.
processDescribeProtocol
in interface MessageConsumer
processDescribeProtocol
in class MessageAdapter
desc
- incoming protocol descriptorpublic boolean isProtocolDescriptorCompatible(ProtocolDescriptor desc)
isProtocolDescriptorCompatible
in class MessageAdapter
protected boolean visitSubscription(MessageVisitor visitor, SubscriptionProvider provider, MessageType message)
public void subscriptionAvailable(SubscriptionProvider provider)
SubscriptionListener
subscriptionAvailable
in interface SubscriptionListener
protected void subscriptionChanged(SubscriptionProvider provider, MessageType message)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |