org.projectodd.stilts.conduit.stomp
Class ConduitStompProvider

java.lang.Object
  org.projectodd.stilts.conduit.stomp.ConduitStompProvider

All Implemented Interfaces:

StompProvider

public class ConduitStompProvider
extends Object
implements StompProvider

Constructor Summary

ConduitStompProvider(TransactionManager transactionManager, XAMessageConduitFactory messageConduitFactory)

ConduitStompProvider(TransactionManager transactionManager, XAMessageConduitFactory messageConduitFactory, Authenticator authenticator)

Method Summary

StompConnection	createConnection(TransactionalAcknowledgeableMessageSink messageSink, Headers headers, StompFrame.Version version, Heartbeat hb)
protected ConduitStompConnection	createStompConnection(TransactionalAcknowledgeableMessageSink messageSink, String sessionId, Headers headers, StompFrame.Version version, Heartbeat hb)
Authenticator	getAuthenticator()
protected String	getNextSessionId()
TransactionManager	getTransactionManager()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConduitStompProvider

public ConduitStompProvider(TransactionManager transactionManager,
                            XAMessageConduitFactory messageConduitFactory)

ConduitStompProvider

public ConduitStompProvider(TransactionManager transactionManager,
                            XAMessageConduitFactory messageConduitFactory,
                            Authenticator authenticator)

Method Detail

getAuthenticator

public Authenticator getAuthenticator()

getTransactionManager

public TransactionManager getTransactionManager()

createConnection

public StompConnection createConnection(TransactionalAcknowledgeableMessageSink messageSink,
                                        Headers headers,
                                        StompFrame.Version version,
                                        Heartbeat hb)
                                 throws StompException

Specified by:

createConnection in interface StompProvider

Throws:

StompException

stop

public void stop()
          throws Exception

Throws:

Exception

getNextSessionId

protected String getNextSessionId()

createStompConnection

protected ConduitStompConnection createStompConnection(TransactionalAcknowledgeableMessageSink messageSink,
                                                       String sessionId,
                                                       Headers headers,
                                                       StompFrame.Version version,
                                                       Heartbeat hb)
                                                throws Exception

Throws:

Exception