public class TransportMessageSubscriber extends Object
Constructor and Description |
---|
TransportMessageSubscriber(TransportFactory transportFactory,
boolean isUseReplay) |
Modifier and Type | Method and Description |
---|---|
void |
dispose() |
void |
removeIncrementalStreamMessageListener(StreamListener streamListener)
Remove incremental stream message listener.
|
void |
removeInstrumentStreamStreamMessageListener(StreamListener streamListener)
Sets instrument stream message listener.
|
void |
removeRecoveryStreamMessageListener(StreamListener streamListener)
Remove recovery stream message listener.
|
void |
removeSubscriptionToIncremental(StreamListener streamListener) |
void |
removeSubscriptionToInstrument(StreamListener streamListener) |
void |
removeSubscriptionToRecovery(StreamListener streamListener) |
void |
removeSubscriptionToReplay(StreamListener streamListener) |
void |
setIncrementalStreamMessageListener(StreamListener streamListener)
Sets incremental stream message listener.
|
void |
setInstrumentStreamStreamMessageListener(StreamListener streamListener)
Sets instrument stream message listener.
|
void |
setRecoveryStreamMessageListener(StreamListener streamListener)
Sets recovery stream message listener.
|
void |
subscribeToIncremental(StreamListener streamListener) |
void |
subscribeToInstrument(StreamListener streamListener) |
void |
subscribeToRecovery(StreamListener streamListener) |
void |
subscribeToReplay(StreamListener streamListener) |
protected final Log log
public TransportMessageSubscriber(TransportFactory transportFactory, boolean isUseReplay)
public void subscribeToIncremental(StreamListener streamListener) throws IOException
IOException
public void setIncrementalStreamMessageListener(StreamListener streamListener) throws IOException
streamListener
- the stream listenerIOException
public void removeIncrementalStreamMessageListener(StreamListener streamListener) throws IOException
streamListener
- the stream listenerIOException
public void removeSubscriptionToIncremental(StreamListener streamListener) throws IOException
IOException
public void subscribeToRecovery(StreamListener streamListener) throws IOException
IOException
public void removeSubscriptionToRecovery(StreamListener streamListener) throws IOException
IOException
public void setRecoveryStreamMessageListener(StreamListener streamListener) throws IOException
streamListener
- the stream listenerIOException
public void removeRecoveryStreamMessageListener(StreamListener streamListener) throws IOException
streamListener
- the stream listenerIOException
public void subscribeToInstrument(StreamListener streamListener) throws IOException
IOException
public void removeSubscriptionToInstrument(StreamListener streamListener) throws IOException
IOException
public void setInstrumentStreamStreamMessageListener(StreamListener streamListener) throws IOException
streamListener
- the stream listenerIOException
public void removeInstrumentStreamStreamMessageListener(StreamListener streamListener) throws IOException
streamListener
- the stream listenerIOException
public void subscribeToReplay(StreamListener streamListener) throws IOException
IOException
public void removeSubscriptionToReplay(StreamListener streamListener) throws IOException
IOException
public void dispose()
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.