org.fusesource.stomp.jms

Class StompServerAdaptor

java.lang.Object

org.fusesource.stomp.jms.StompServerAdaptor

Direct Known Subclasses:

ActiveMQServerAdaptor, ApolloServerAdaptor

public class StompServerAdaptor
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
StompServerAdaptor()

Method Summary

Methods

Modifier and Type	Method and Description
void	addSubscribeHeaders(java.util.Map<org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.AsciiBuffer> headerMap, boolean persistent, boolean browser, boolean noLocal, StompJmsPrefetch prefetch)
StompFrame	createCreditFrame(StompJmsMessageConsumer consumer, StompFrame messageFrame)
javax.jms.TemporaryQueue	createTemporaryQueue(StompJmsSession session)
javax.jms.TemporaryTopic	createTemporaryTopic(StompJmsSession session)
StompFrame	createUnsubscribeFrame(org.fusesource.hawtbuf.AsciiBuffer consumerId, boolean persistent)
StompJmsTempQueue	isTempQueue(StompJmsConnection connection, java.lang.String value)
StompJmsTempTopic	isTempTopic(StompJmsConnection connection, java.lang.String value)
boolean	matchesServerAndVersion(java.lang.String server)

Methods inherited from class java.lang.Object

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

Constructor Detail

StompServerAdaptor

public StompServerAdaptor()

Method Detail

matchesServerAndVersion

public boolean matchesServerAndVersion(java.lang.String server)

isTempQueue

public StompJmsTempQueue isTempQueue(StompJmsConnection connection,
                            java.lang.String value)

isTempTopic

public StompJmsTempTopic isTempTopic(StompJmsConnection connection,
                            java.lang.String value)
                              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createCreditFrame

public StompFrame createCreditFrame(StompJmsMessageConsumer consumer,
                           StompFrame messageFrame)

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue(StompJmsSession session)
                                              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic(StompJmsSession session)
                                              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

addSubscribeHeaders

public void addSubscribeHeaders(java.util.Map<org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.AsciiBuffer> headerMap,
                       boolean persistent,
                       boolean browser,
                       boolean noLocal,
                       StompJmsPrefetch prefetch)
                         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createUnsubscribeFrame

public StompFrame createUnsubscribeFrame(org.fusesource.hawtbuf.AsciiBuffer consumerId,
                                boolean persistent)
                                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException