com.infoscape.proteus.mq
Class MQSink

java.lang.Object
  |
  +--com.infoscape.proteus.MessageHandlerImpl
        |
        +--com.infoscape.proteus.SinkImpl
              |
              +--com.infoscape.proteus.mq.MQSink

All Implemented Interfaces:

MessageHandler, MessageSink, Transactional

public class MQSink

extends SinkImpl

Constructor Summary

MQSink(Connection conn, org.jdom.Element elt)

Method Summary

protected void	_putMessage(java.lang.Object msg)
void	setSyncPoint(boolean sync)

Methods inherited from class com.infoscape.proteus.SinkImpl

putMessage

Methods inherited from class com.infoscape.proteus.MessageHandlerImpl

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

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

Constructor Detail

MQSink

public MQSink(Connection conn,
              org.jdom.Element elt)
       throws java.lang.Exception

Method Detail

_putMessage

protected void _putMessage(java.lang.Object msg)
                    throws java.lang.Exception

Specified by:

_putMessage in class SinkImpl

Parameters:

msg -

Throws:

java.lang.Exception

setSyncPoint

public void setSyncPoint(boolean sync)

Specified by:

setSyncPoint in interface Transactional

Overrides:

setSyncPoint in class MessageHandlerImpl

Parameters:

sync -