Class StompProtocolManager

java.lang.Object

org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManager<StompFrame, StompFrameInterceptor, StompConnection, org.apache.activemq.artemis.core.server.routing.RoutingHandler>

org.apache.activemq.artemis.core.protocol.stomp.StompProtocolManager

All Implemented Interfaces:

ProtocolManager<StompFrameInterceptor, org.apache.activemq.artemis.core.server.routing.RoutingHandler>

public class StompProtocolManager
extends AbstractProtocolManager<StompFrame, StompFrameInterceptor, StompConnection, org.apache.activemq.artemis.core.server.routing.RoutingHandler>

Method Summary

Modifier and Type	Method	Description
void	abortTransaction(StompConnection connection, String txID)
boolean	acceptsNoHandshake()
void	acknowledge(StompConnection connection, String messageID, String subscriptionID)
void	addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
void	beginTransaction(StompConnection connection, String txID)
void	cleanup(StompConnection connection)
void	commitTransaction(StompConnection connection, String txID)
ConnectionEntry	createConnectionEntry(Acceptor acceptorUsed, Connection connection)
org.apache.activemq.artemis.core.message.impl.CoreMessage	createServerMessage()
boolean	destinationExists(String destination)
ProtocolManagerFactory<StompFrameInterceptor>	getFactory()
org.apache.activemq.artemis.core.server.routing.RoutingHandler	getRoutingHandler()
org.apache.activemq.artemis.core.server.ActiveMQServer	getServer()
StompSession	getSession(StompConnection connection)
Collection<StompSession>	getSessions()
String	getSupportedVersionsAsErrorVersion()
String	getSupportedVersionsAsString()
StompSession	getTransactedSession(StompConnection connection, String txID)
Map<Object, Map<Object, StompSession>>	getTransactedSessions()
String	getVirtualHostName()
void	handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
void	handshake(org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection connection, ActiveMQBuffer buffer)
boolean	isProtocol(byte[] array)
boolean	send(StompConnection connection, StompFrame frame)
void	sendReply(StompConnection connection, StompFrame frame, StompPostReceiptFunction function)
StompPostReceiptFunction	subscribe(StompConnection connection, String subscriptionID, String durableSubscriptionName, String destination, String selector, String ack, boolean noLocal, Integer consumerWindowSize)
void	unsubscribe(StompConnection connection, String subscriptionID, String durableSubscriberName)
void	updateInterceptors(List<BaseInterceptor> incoming, List<BaseInterceptor> outgoing)
List<String>	websocketSubprotocolIdentifiers()

Methods inherited from class AbstractProtocolManager

getPrefixes, getSecurityDomain, invokeInterceptors, setAnycastPrefix, setMulticastPrefix, setSecurityDomain

Methods inherited from class Object

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

Methods inherited from interface ProtocolManager

removeHandler

Method Details

acceptsNoHandshake

public boolean acceptsNoHandshake()

getFactory

public ProtocolManagerFactory<StompFrameInterceptor> getFactory()

updateInterceptors

public void updateInterceptors(List<BaseInterceptor> incoming,
 List<BaseInterceptor> outgoing)

createConnectionEntry

public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
 Connection connection)

handleBuffer

public void handleBuffer(RemotingConnection connection,
 ActiveMQBuffer buffer)

addChannelHandlers

public void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)

isProtocol

public boolean isProtocol(byte[] array)

handshake

public void handshake(org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection connection,
 ActiveMQBuffer buffer)

websocketSubprotocolIdentifiers

public List<String> websocketSubprotocolIdentifiers()

getRoutingHandler

public org.apache.activemq.artemis.core.server.routing.RoutingHandler getRoutingHandler()

send

public boolean send(StompConnection connection,
 StompFrame frame)

getSession

public StompSession getSession(StompConnection connection)
                        throws Exception

Throws:

Exception

getTransactedSession

public StompSession getTransactedSession(StompConnection connection,
 String txID)
                                  throws Exception

Throws:

Exception

getTransactedSessions

public Map<Object, Map<Object, StompSession>> getTransactedSessions()

cleanup

public void cleanup(StompConnection connection)

sendReply

public void sendReply(StompConnection connection,
 StompFrame frame,
 StompPostReceiptFunction function)

getSupportedVersionsAsString

public String getSupportedVersionsAsString()

getSupportedVersionsAsErrorVersion

public String getSupportedVersionsAsErrorVersion()

getVirtualHostName

public String getVirtualHostName()

createServerMessage

public org.apache.activemq.artemis.core.message.impl.CoreMessage createServerMessage()

commitTransaction

public void commitTransaction(StompConnection connection,
 String txID)
                       throws Exception

Throws:

Exception

abortTransaction

public void abortTransaction(StompConnection connection,
 String txID)
                      throws Exception

Throws:

Exception

subscribe

public StompPostReceiptFunction subscribe(StompConnection connection,
 String subscriptionID,
 String durableSubscriptionName,
 String destination,
 String selector,
 String ack,
 boolean noLocal,
 Integer consumerWindowSize)
                                   throws Exception

Throws:

Exception

unsubscribe

public void unsubscribe(StompConnection connection,
 String subscriptionID,
 String durableSubscriberName)
                 throws Exception

Throws:

Exception

acknowledge

public void acknowledge(StompConnection connection,
 String messageID,
 String subscriptionID)
                 throws Exception

Throws:

Exception

beginTransaction

public void beginTransaction(StompConnection connection,
 String txID)
                      throws Exception

Throws:

Exception

destinationExists

public boolean destinationExists(String destination)

getServer

public org.apache.activemq.artemis.core.server.ActiveMQServer getServer()

getSessions

public Collection<StompSession> getSessions()