com.infoscape.proteus.jms
Class JMSSink

java.lang.Object
  |
  +--com.infoscape.proteus.MessageHandlerImpl
        |
        +--com.infoscape.proteus.SinkImpl
              |
              +--com.infoscape.proteus.jms.JMSSink

All Implemented Interfaces:

MessageHandler, MessageSink, Transactional

public class JMSSink

extends SinkImpl

Constructor Summary

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

Method Summary

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

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

JMSSink

public JMSSink(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 on)
                  throws java.lang.Exception

Specified by:

setSyncPoint in interface Transactional

Overrides:

setSyncPoint in class MessageHandlerImpl

Parameters:

on -

Throws:

java.lang.Exception