com.epam.cmemdp.channel
Class MDChannel

java.lang.Object
  com.epam.cmemdp.channel.MDChannel

public class MDChannel
extends java.lang.Object

Field Summary

java.lang.String	channelID
MDFeed	feedA
MDFeed	feedB
java.util.concurrent.atomic.AtomicInteger	incrementalUserCount
java.util.concurrent.locks.Lock	replayLock
java.util.concurrent.atomic.AtomicInteger	replayUserCount
com.epam.mdp.full.coders.stream.SeqNumHelper	seqNumHelper
java.util.concurrent.atomic.AtomicInteger	snapshotUserCount

Constructor Summary

MDChannel()

MDChannel(java.lang.String channelID)

Method Summary

boolean	bothFeeds(TransportType type)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

channelID

public java.lang.String channelID

feedA

public MDFeed feedA

feedB

public MDFeed feedB

seqNumHelper

public com.epam.mdp.full.coders.stream.SeqNumHelper seqNumHelper

incrementalUserCount

public java.util.concurrent.atomic.AtomicInteger incrementalUserCount

snapshotUserCount

public java.util.concurrent.atomic.AtomicInteger snapshotUserCount

replayUserCount

public java.util.concurrent.atomic.AtomicInteger replayUserCount

replayLock

public java.util.concurrent.locks.Lock replayLock

Constructor Detail

MDChannel

public MDChannel()

MDChannel

public MDChannel(java.lang.String channelID)

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

bothFeeds

public boolean bothFeeds(TransportType type)