Package deltix.data.stream
Interface DXChannel<T>
-
- All Superinterfaces:
deltix.util.security.AuthorizationController.ProtectedResource
- All Known Subinterfaces:
DirectChannel
,DXTickStream
,TickStream
,WritableTickStream
- All Known Implementing Classes:
TopicClientChannel
public interface DXChannel<T> extends deltix.util.security.AuthorizationController.ProtectedResource
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description deltix.data.stream.MessageSource<T>
createConsumer(ChannelPreferences options)
Opens a source for reading data from this channel, according to the specified preferences.deltix.data.stream.MessageChannel<T>
createPublisher(ChannelPreferences options)
Creates a channel for loading data.java.lang.String
getDescription()
Returns a user-readable multi-line description.java.lang.String
getKey()
Returns the key, which uniquely identifies the channeljava.lang.String
getName()
Returns a user-readable short name.RecordClassDescriptor[]
getTypes()
Returns the class descriptors associated with this channel
-
-
-
Method Detail
-
getKey
java.lang.String getKey()
Returns the key, which uniquely identifies the channel
-
getName
java.lang.String getName()
Returns a user-readable short name.
-
getDescription
java.lang.String getDescription()
Returns a user-readable multi-line description.
-
getTypes
RecordClassDescriptor[] getTypes()
Returns the class descriptors associated with this channel
-
createConsumer
deltix.data.stream.MessageSource<T> createConsumer(ChannelPreferences options)
Opens a source for reading data from this channel, according to the specified preferences. Iterator-like approach to consume messages:
while (source.next()) source.getMessage()
- Returns:
- A message source to read messages from.
-
createPublisher
deltix.data.stream.MessageChannel<T> createPublisher(ChannelPreferences options)
Creates a channel for loading data. The publisher must be closed when the loading process is finished.- Returns:
- A consumer of messages to be loaded into the channel.
-
-