Stilts 0.1.0-SNAPSHOT

org.projectodd.stilts.conduit.stomp
Class ConduitStompProvider

java.lang.Object
  extended by 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

Stilts 0.1.0-SNAPSHOT

Copyright © 2011 JBoss, a division of Red Hat, Inc.. All Rights Reserved.