public class StompProtocolManager extends AbstractProtocolManager<StompFrame,StompFrameInterceptor,StompConnection>
Modifier and Type | Method and Description |
---|---|
void |
abortTransaction(StompConnection connection,
String txID) |
boolean |
acceptsNoHandshake()
If this protocols accepts connectoins without an initial handshake.
|
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()
Gets the Message Converter towards ActiveMQ Artemis.
|
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,
ActiveMQBuffer buffer) |
void |
handshake(NettyServerConnection connection,
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<BaseInterceptor> incoming,
List<BaseInterceptor> outgoing)
This method will receive all the interceptors on the system and you should filter them out *
|
boolean |
validateUser(String login,
String passcode,
X509Certificate[] certificates) |
List<String> |
websocketSubprotocolIdentifiers()
A list of the IANA websocket subprotocol identifiers supported by this protocol manager.
|
invokeInterceptors
public boolean acceptsNoHandshake()
ProtocolManager
public ProtocolManagerFactory<StompFrameInterceptor> getFactory()
public void updateInterceptors(List<BaseInterceptor> incoming, List<BaseInterceptor> outgoing)
ProtocolManager
public MessageConverter getConverter()
ProtocolManager
public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed, Connection connection)
public void removeHandler(String name)
public void handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
public void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
public boolean isProtocol(byte[] array)
public void handshake(NettyServerConnection connection, ActiveMQBuffer buffer)
public List<String> websocketSubprotocolIdentifiers()
ProtocolManager
public boolean send(StompConnection connection, StompFrame frame)
public StompSession getSession(StompConnection connection) throws Exception
Exception
public StompSession getTransactedSession(StompConnection connection, String txID) throws Exception
Exception
public void cleanup(StompConnection connection)
public void sendReply(StompConnection connection, StompFrame frame)
public String getSupportedVersionsAsString()
public String getSupportedVersionsAsErrorVersion()
public String getVirtualHostName()
public boolean validateUser(String login, String passcode, X509Certificate[] certificates)
public ServerMessageImpl createServerMessage()
public void commitTransaction(StompConnection connection, String txID) throws Exception
Exception
public void abortTransaction(StompConnection connection, String txID) throws Exception
Exception
public void createSubscription(StompConnection connection, String subscriptionID, String durableSubscriptionName, String destination, String selector, String ack, boolean noLocal) throws Exception
Exception
public void unsubscribe(StompConnection connection, String subscriptionID, String durableSubscriberName) throws Exception
Exception
public void acknowledge(StompConnection connection, String messageID, String subscriptionID) throws Exception
Exception
public void beginTransaction(StompConnection connection, String txID) throws Exception
Exception
public boolean destinationExists(String destination)
public ActiveMQServer getServer()
Copyright © 2016 The Apache Software Foundation. All rights reserved.