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

Class StompProtocolManager

java.lang.Object

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

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

All Implemented Interfaces:

ProtocolManager<StompFrameInterceptor>

public class StompProtocolManager
extends AbstractProtocolManager<StompFrame,StompFrameInterceptor,StompConnection>

StompProtocolManager

Method Summary

Modifier and Type	Method and 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)
ServerMessageImpl	createServerMessage()
void	createSubscription(StompConnection connection, String subscriptionID, String durableSubscriptionName, String destination, String selector, String ack, boolean noLocal)
boolean	destinationExists(String destination)
MessageConverter	getConverter()
ProtocolManagerFactory<StompFrameInterceptor>	getFactory()
ActiveMQServer	getServer()
StompSession	getSession(StompConnection connection)
String	getSupportedVersionsAsErrorVersion()
String	getSupportedVersionsAsString()
StompSession	getTransactedSession(StompConnection connection, String txID)
String	getVirtualHostName()
void	handleBuffer(RemotingConnection connection, org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
void	handshake(NettyServerConnection connection, org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
boolean	isProtocol(byte[] array)
void	removeHandler(String name)
boolean	send(StompConnection connection, StompFrame frame)
void	sendReply(StompConnection connection, StompFrame frame)
void	unsubscribe(StompConnection connection, String subscriptionID, String durableSubscriberName)
void	updateInterceptors(List<org.apache.activemq.artemis.api.core.BaseInterceptor> incoming, List<org.apache.activemq.artemis.api.core.BaseInterceptor> outgoing)
boolean	validateUser(String login, String passcode, X509Certificate[] certificates)
List<String>	websocketSubprotocolIdentifiers()

Methods inherited from class org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManager

invokeInterceptors

Methods inherited from class java.lang.Object

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

Method Detail

acceptsNoHandshake

public boolean acceptsNoHandshake()

getFactory

public ProtocolManagerFactory<StompFrameInterceptor> getFactory()

updateInterceptors

public void updateInterceptors(List<org.apache.activemq.artemis.api.core.BaseInterceptor> incoming,
                               List<org.apache.activemq.artemis.api.core.BaseInterceptor> outgoing)

getConverter

public MessageConverter getConverter()

createConnectionEntry

public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                             Connection connection)

removeHandler

public void removeHandler(String name)

handleBuffer

public void handleBuffer(RemotingConnection connection,
                         org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

addChannelHandlers

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

isProtocol

public boolean isProtocol(byte[] array)

handshake

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

websocketSubprotocolIdentifiers

public List<String> websocketSubprotocolIdentifiers()

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

cleanup

public void cleanup(StompConnection connection)

sendReply

public void sendReply(StompConnection connection,
                      StompFrame frame)

getSupportedVersionsAsString

public String getSupportedVersionsAsString()

getSupportedVersionsAsErrorVersion

public String getSupportedVersionsAsErrorVersion()

getVirtualHostName

public String getVirtualHostName()

validateUser

public boolean validateUser(String login,
                            String passcode,
                            X509Certificate[] certificates)

createServerMessage

public ServerMessageImpl 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

createSubscription

public void createSubscription(StompConnection connection,
                               String subscriptionID,
                               String durableSubscriptionName,
                               String destination,
                               String selector,
                               String ack,
                               boolean noLocal)
                        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 ActiveMQServer getServer()