com.epam.cmefast.impl.transport

Class TransportMessageSubscriber

java.lang.Object

com.epam.cmefast.impl.transport.TransportMessageSubscriber

public class TransportMessageSubscriber
extends Object

Provides ability to access to raw transport.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.epam.common.logging.Log	log

Constructor Summary

Constructors

Constructor and Description
TransportMessageSubscriber(MDChannel channel)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final com.epam.common.logging.Log log

Constructor Detail

TransportMessageSubscriber

public TransportMessageSubscriber(MDChannel channel)

Method Detail

subscribeToIncremental

public void subscribeToIncremental(StreamListener streamListener)
                            throws IOException

Throws:

IOException

setIncrementalStreamMessageListener

public void setIncrementalStreamMessageListener(StreamListener streamListener)
                                         throws IOException

Sets incremental stream message listener.

This listener will be call before messages will be processed. Use this method in pair with removeIncrementalStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

IOException

removeIncrementalStreamMessageListener

public void removeIncrementalStreamMessageListener(StreamListener streamListener)
                                            throws IOException

Remove incremental stream message listener.

Use this method in pair with setIncrementalStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

IOException

removeSubscriptionToIncremental

public void removeSubscriptionToIncremental(StreamListener streamListener)
                                     throws IOException

Throws:

IOException

subscribeToRecovery

public void subscribeToRecovery(StreamListener streamListener)
                         throws IOException

Throws:

IOException

removeSubscriptionToRecovery

public void removeSubscriptionToRecovery(StreamListener streamListener)
                                  throws IOException

Throws:

IOException

setRecoveryStreamMessageListener

public void setRecoveryStreamMessageListener(StreamListener streamListener)
                                      throws IOException

Sets recovery stream message listener.

This listener will be call before messages will be processed. Use this method in pair with removeRecoveryStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

IOException

removeRecoveryStreamMessageListener

public void removeRecoveryStreamMessageListener(StreamListener streamListener)
                                         throws IOException

Remove recovery stream message listener.

Use this method in pair with setRecoveryStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

IOException

subscribeToInstrument

public void subscribeToInstrument(StreamListener streamListener)
                           throws IOException

Throws:

IOException

removeSubscriptionToInstrument

public void removeSubscriptionToInstrument(StreamListener streamListener)
                                    throws IOException

Throws:

IOException

setInstrumentStreamStreamMessageListener

public void setInstrumentStreamStreamMessageListener(StreamListener streamListener)
                                              throws IOException

Sets instrument stream message listener.

This listener will be call before messages will be processed. Use this method in pair with removeInstrumentStreamStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

IOException

removeInstrumentStreamStreamMessageListener

public void removeInstrumentStreamStreamMessageListener(StreamListener streamListener)
                                                 throws IOException

Sets instrument stream message listener.

Use this method in pair with setInstrumentStreamStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

IOException

subscribeToReplay

public void subscribeToReplay(StreamListener streamListener)
                       throws IOException

Throws:

IOException

removeSubscriptionToReplay

public void removeSubscriptionToReplay(StreamListener streamListener)
                                throws IOException

Throws:

IOException

dispose

public void dispose()