com.epam.cmemdp.impl.transport
Class TransportMessageSubscriber

java.lang.Object
  com.epam.cmemdp.impl.transport.TransportMessageSubscriber

public class TransportMessageSubscriber
extends java.lang.Object

Provides ability to access to raw transport.

Field Summary

protected Log

log

Constructor Summary

TransportMessageSubscriber(MDChannel channel)

Method Summary

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 Log log

Constructor Detail

TransportMessageSubscriber

public TransportMessageSubscriber(MDChannel channel)

Method Detail

subscribeToIncremental

public void subscribeToIncremental(StreamListener streamListener)
                            throws java.io.IOException

Throws:

java.io.IOException

setIncrementalStreamMessageListener

public void setIncrementalStreamMessageListener(StreamListener streamListener)
                                         throws java.io.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:

java.io.IOException

removeIncrementalStreamMessageListener

public void removeIncrementalStreamMessageListener(StreamListener streamListener)
                                            throws java.io.IOException

Remove incremental stream message listener.

Use this method in pair with setIncrementalStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

java.io.IOException

removeSubscriptionToIncremental

public void removeSubscriptionToIncremental(StreamListener streamListener)
                                     throws java.io.IOException

Throws:

java.io.IOException

subscribeToRecovery

public void subscribeToRecovery(StreamListener streamListener)
                         throws java.io.IOException

Throws:

java.io.IOException

removeSubscriptionToRecovery

public void removeSubscriptionToRecovery(StreamListener streamListener)
                                  throws java.io.IOException

Throws:

java.io.IOException

setRecoveryStreamMessageListener

public void setRecoveryStreamMessageListener(StreamListener streamListener)
                                      throws java.io.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:

java.io.IOException

removeRecoveryStreamMessageListener

public void removeRecoveryStreamMessageListener(StreamListener streamListener)
                                         throws java.io.IOException

Remove recovery stream message listener.

Use this method in pair with setRecoveryStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

java.io.IOException

subscribeToInstrument

public void subscribeToInstrument(StreamListener streamListener)
                           throws java.io.IOException

Throws:

java.io.IOException

removeSubscriptionToInstrument

public void removeSubscriptionToInstrument(StreamListener streamListener)
                                    throws java.io.IOException

Throws:

java.io.IOException

setInstrumentStreamStreamMessageListener

public void setInstrumentStreamStreamMessageListener(StreamListener streamListener)
                                              throws java.io.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:

java.io.IOException

removeInstrumentStreamStreamMessageListener

public void removeInstrumentStreamStreamMessageListener(StreamListener streamListener)
                                                 throws java.io.IOException

Sets instrument stream message listener.

Use this method in pair with setInstrumentStreamStreamMessageListener.

Parameters:

streamListener - the stream listener

Throws:

java.io.IOException

subscribeToReplay

public void subscribeToReplay(StreamListener streamListener)
                       throws java.io.IOException

Throws:

java.io.IOException

removeSubscriptionToReplay

public void removeSubscriptionToReplay(StreamListener streamListener)
                                throws java.io.IOException

Throws:

java.io.IOException

dispose

public void dispose()