Package deltix.qsrv.hf.tickdb.ui.tbshell.benchmark.channel

Class TopicAccessor

java.lang.Object

deltix.qsrv.hf.tickdb.ui.tbshell.benchmark.channel.TopicAccessor

All Implemented Interfaces:

ChannelAccessor

Direct Known Subclasses:

UdpSingleProducerTopicAccessor

public class TopicAccessor
extends java.lang.Object
implements ChannelAccessor

Constructor Summary

Constructors

Constructor	Description
TopicAccessor()

Method Summary

Modifier and Type	Method	Description
void	createChannel(RemoteTickDB tickDB, java.lang.String channelKey, RecordClassDescriptor[] rcd)
deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>	createConsumer(RemoteTickDB tickDB, java.lang.String channelKey)
deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>	createLoader(RemoteTickDB tickDB, java.lang.String channelKey)
void	deleteChannel(RemoteTickDB tickDB, java.lang.String channelKey)

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicAccessor

public TopicAccessor()

Method Detail

createChannel

public void createChannel(RemoteTickDB tickDB,
                          java.lang.String channelKey,
                          RecordClassDescriptor[] rcd)

Specified by:

createChannel in interface ChannelAccessor

deleteChannel

public void deleteChannel(RemoteTickDB tickDB,
                          java.lang.String channelKey)

Specified by:

deleteChannel in interface ChannelAccessor

createLoader

public deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> createLoader(RemoteTickDB tickDB,
                                                                                            java.lang.String channelKey)

Specified by:

createLoader in interface ChannelAccessor

createConsumer

public deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage> createConsumer(RemoteTickDB tickDB,
                                                                                             java.lang.String channelKey)

Specified by:

createConsumer in interface ChannelAccessor