com.infoscape.proteus
Class SourceImpl

java.lang.Object
  |
  +--com.infoscape.proteus.MessageHandlerImpl
        |
        +--com.infoscape.proteus.SourceImpl

All Implemented Interfaces:

MessageHandler, MessageSource, Transactional

Direct Known Subclasses:

JMSSource, MQSource, PolledSource

public abstract class SourceImpl

extends MessageHandlerImpl

implements MessageSource

Base class for sources. Descendants don't implement getMessage() themselves; instead they implement a protected method called _getMessage(). SourceImpl wraps reconnect logic around the call to _getMessage().

Constructor Summary

SourceImpl(Connection conn)

Method Summary

protected abstract java.lang.Object	_getMessage()
java.lang.Object	getMessage()

Methods inherited from class com.infoscape.proteus.MessageHandlerImpl

commit, disconnect, getConnection, log, log, reconnect, rollback, setSyncPoint

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.infoscape.proteus.MessageHandler

disconnect, getConnection, reconnect

Methods inherited from interface com.infoscape.proteus.Transactional

commit, rollback, setSyncPoint

Constructor Detail

SourceImpl

public SourceImpl(Connection conn)
           throws java.lang.Exception

Parameters:

conn -

Throws:

java.lang.Exception

Method Detail

getMessage

public java.lang.Object getMessage()
                            throws java.lang.Exception

Specified by:

getMessage in interface MessageSource

Throws:

java.lang.Exception

_getMessage

protected abstract java.lang.Object _getMessage()
                                         throws java.lang.Exception

Throws:

java.lang.Exception