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

Class StreamAccessor

java.lang.Object

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

All Implemented Interfaces:

ChannelAccessor

public class StreamAccessor
extends java.lang.Object
implements ChannelAccessor

Constructor Summary

Constructors

Constructor	Description
StreamAccessor(StreamScope scope, ChannelPerformance channelPerformance)

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

StreamAccessor

public StreamAccessor(StreamScope scope,
                      ChannelPerformance channelPerformance)

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