org.fusesource.stomp.jms

Class ApolloServerAdaptor

java.lang.Object

org.fusesource.stomp.jms.StompServerAdaptor

org.fusesource.stomp.jms.ApolloServerAdaptor

public class ApolloServerAdaptor
extends StompServerAdaptor

Constructor Summary

Constructors

Constructor and Description
ApolloServerAdaptor()

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

ApolloServerAdaptor

public ApolloServerAdaptor()

Method Detail

matchesServerAndVersion

public boolean matchesServerAndVersion(java.lang.String server)

Overrides:

matchesServerAndVersion in class StompServerAdaptor

isTempQueue

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

Overrides:

isTempQueue in class StompServerAdaptor

isTempTopic

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

Overrides:

isTempTopic in class StompServerAdaptor

Throws:

javax.jms.JMSException

createCreditFrame

public StompFrame createCreditFrame(StompJmsMessageConsumer consumer,
                           StompFrame messageFrame)

Overrides:

createCreditFrame in class StompServerAdaptor

createTemporaryQueue

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

Overrides:

createTemporaryQueue in class StompServerAdaptor

Throws:

javax.jms.JMSException

createTemporaryTopic

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

Overrides:

createTemporaryTopic in class StompServerAdaptor

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

Overrides:

addSubscribeHeaders in class StompServerAdaptor

Throws:

javax.jms.JMSException

createUnsubscribeFrame

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

Overrides:

createUnsubscribeFrame in class StompServerAdaptor

Throws:

javax.jms.JMSException