public class ActiveMQServerAdaptor extends StompServerAdaptor
| Constructor and Description |
|---|
ActiveMQServerAdaptor() |
| 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) |
boolean |
matchesServerAndVersion(java.lang.String server) |
createCreditFrame, createTemporaryQueue, createTemporaryTopic, createUnsubscribeFrame, isTempQueue, isTempTopicpublic boolean matchesServerAndVersion(java.lang.String server)
matchesServerAndVersion in class StompServerAdaptorpublic 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
addSubscribeHeaders in class StompServerAdaptorjavax.jms.JMSExceptionCopyright © 2010-2014 FuseSource, Corp.. All Rights Reserved.