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

Class StompConnection

java.lang.Object

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

All Implemented Interfaces:

RemotingConnection, BufferHandler

public final class StompConnection
extends Object
implements RemotingConnection

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	CONNECTION_ID_PROP

Method Summary

Modifier and Type	Method and Description
void	abortTransaction(String txID)
void	acknowledge(String messageID, String subscriptionID)
void	addCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)
void	addFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)
void	addStompEventListener(FrameEventListener listener)
void	autoCreateDestinationIfPossible(String queue)
protected void	beginTransaction(String txID)
void	bufferReceived(Object connectionID, org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
boolean	checkDataReceived()
void	checkDestination(String destination)
void	commitTransaction(String txID)
ServerMessageImpl	createServerMessage()
StompFrame	createStompMessage(ServerMessage serverMessage, StompSubscription subscription, int deliveryCount)
org.apache.activemq.artemis.api.core.ActiveMQBuffer	createTransportBuffer(int size)
StompFrame	decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
void	destroy()
void	disconnect(boolean criticalError)
void	disconnect(String scaleDownNodeID, boolean criticalError)
boolean	enableMessageID()
void	fail(org.apache.activemq.artemis.api.core.ActiveMQException me)
void	fail(org.apache.activemq.artemis.api.core.ActiveMQException me, String scaleDownTargetNodeID)
void	flush()
Acceptor	getAcceptorUsed()
String	getActiveMQServerName()
String	getClientID()
long	getCreationTime()
List<org.apache.activemq.artemis.core.remoting.FailureListener>	getFailureListeners()
VersionedStompFrameHandler	getFrameHandler()
Object	getID()
String	getLogin()
StompProtocolManager	getManager()
int	getMinLargeMessageSize()
String	getPasscode()
String	getRemoteAddress()
StompSession	getSession(String txID)
Connection	getTransportConnection()
String	getVersion()
void	handleFrame(StompFrame request)
boolean	hasBytes()
boolean	isClient()
boolean	isDestroyed()
boolean	isSupportReconnect()
boolean	isSupportsFlowControl()
boolean	isValid()
boolean	isWritable(ReadyListener callback)
void	killMessage(org.apache.activemq.artemis.api.core.SimpleString nodeID)
void	negotiateVersion(StompFrame frame)
void	physicalSend(StompFrame frame)
void	ping(StompFrame pingFrame)
boolean	removeCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)
List<org.apache.activemq.artemis.core.remoting.CloseListener>	removeCloseListeners()
boolean	removeFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)
List<org.apache.activemq.artemis.core.remoting.FailureListener>	removeFailureListeners()
void	sendFrame(StompFrame frame)
protected void	sendServerMessage(ServerMessageImpl message, String txID)
void	setClientID(String clientID)
void	setCloseListeners(List<org.apache.activemq.artemis.core.remoting.CloseListener> listeners)
protected void	setDataReceived()
void	setFailureListeners(List<org.apache.activemq.artemis.core.remoting.FailureListener> listeners)
void	setHost(String host)
void	setValid(boolean valid)
void	unsubscribe(String subscriptionID, String durableSubscriptionName)
protected void	validate()
boolean	validateUser(String login, String pass, X509Certificate[] certificates)

Methods inherited from class java.lang.Object

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

Field Detail

CONNECTION_ID_PROP

protected static final String CONNECTION_ID_PROP

See Also:

Constant Field Values

Method Detail

isSupportReconnect

public boolean isSupportReconnect()

Specified by:

isSupportReconnect in interface RemotingConnection

decode

public StompFrame decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
                  throws ActiveMQStompException

Throws:

ActiveMQStompException

isWritable

public boolean isWritable(ReadyListener callback)

Specified by:

isWritable in interface RemotingConnection

hasBytes

public boolean hasBytes()

addFailureListener

public void addFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)

Specified by:

addFailureListener in interface RemotingConnection

removeFailureListener

public boolean removeFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)

Specified by:

removeFailureListener in interface RemotingConnection

addCloseListener

public void addCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)

Specified by:

addCloseListener in interface RemotingConnection

removeCloseListener

public boolean removeCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)

Specified by:

removeCloseListener in interface RemotingConnection

removeCloseListeners

public List<org.apache.activemq.artemis.core.remoting.CloseListener> removeCloseListeners()

Specified by:

removeCloseListeners in interface RemotingConnection

removeFailureListeners

public List<org.apache.activemq.artemis.core.remoting.FailureListener> removeFailureListeners()

Specified by:

removeFailureListeners in interface RemotingConnection

setCloseListeners

public void setCloseListeners(List<org.apache.activemq.artemis.core.remoting.CloseListener> listeners)

Specified by:

setCloseListeners in interface RemotingConnection

setFailureListeners

public void setFailureListeners(List<org.apache.activemq.artemis.core.remoting.FailureListener> listeners)

Specified by:

setFailureListeners in interface RemotingConnection

setDataReceived

protected void setDataReceived()

checkDataReceived

public boolean checkDataReceived()

Specified by:

checkDataReceived in interface RemotingConnection

checkDestination

public void checkDestination(String destination)
                      throws ActiveMQStompException

Throws:

ActiveMQStompException

autoCreateDestinationIfPossible

public void autoCreateDestinationIfPossible(String queue)
                                     throws ActiveMQStompException

Throws:

ActiveMQStompException

createTransportBuffer

public org.apache.activemq.artemis.api.core.ActiveMQBuffer createTransportBuffer(int size)

Specified by:

createTransportBuffer in interface RemotingConnection

destroy

public void destroy()

Specified by:

destroy in interface RemotingConnection

getAcceptorUsed

public Acceptor getAcceptorUsed()

fail

public void fail(org.apache.activemq.artemis.api.core.ActiveMQException me)

Specified by:

fail in interface RemotingConnection

fail

public void fail(org.apache.activemq.artemis.api.core.ActiveMQException me,
                 String scaleDownTargetNodeID)

Specified by:

fail in interface RemotingConnection

flush

public void flush()

Specified by:

flush in interface RemotingConnection

getFailureListeners

public List<org.apache.activemq.artemis.core.remoting.FailureListener> getFailureListeners()

Specified by:

getFailureListeners in interface RemotingConnection

getID

public Object getID()

Specified by:

getID in interface RemotingConnection

getRemoteAddress

public String getRemoteAddress()

Specified by:

getRemoteAddress in interface RemotingConnection

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface RemotingConnection

getTransportConnection

public Connection getTransportConnection()

Specified by:

getTransportConnection in interface RemotingConnection

isClient

public boolean isClient()

Specified by:

isClient in interface RemotingConnection

isDestroyed

public boolean isDestroyed()

Specified by:

isDestroyed in interface RemotingConnection

bufferReceived

public void bufferReceived(Object connectionID,
                           org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

Specified by:

bufferReceived in interface BufferHandler

getLogin

public String getLogin()

getPasscode

public String getPasscode()

setClientID

public void setClientID(String clientID)

getClientID

public String getClientID()

isValid

public boolean isValid()

setValid

public void setValid(boolean valid)

negotiateVersion

public void negotiateVersion(StompFrame frame)
                      throws ActiveMQStompException

Throws:

ActiveMQStompException

setHost

public void setHost(String host)
             throws ActiveMQStompException

Throws:

ActiveMQStompException

handleFrame

public void handleFrame(StompFrame request)

sendFrame

public void sendFrame(StompFrame frame)

validateUser

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

createServerMessage

public ServerMessageImpl createServerMessage()

getSession

public StompSession getSession(String txID)
                        throws ActiveMQStompException

Throws:

ActiveMQStompException

validate

protected void validate()
                 throws ActiveMQStompException

Throws:

ActiveMQStompException

sendServerMessage

protected void sendServerMessage(ServerMessageImpl message,
                                 String txID)
                          throws ActiveMQStompException

Throws:

ActiveMQStompException

disconnect

public void disconnect(boolean criticalError)

Specified by:

disconnect in interface RemotingConnection

disconnect

public void disconnect(String scaleDownNodeID,
                       boolean criticalError)

Specified by:

disconnect in interface RemotingConnection

beginTransaction

protected void beginTransaction(String txID)
                         throws ActiveMQStompException

Throws:

ActiveMQStompException

commitTransaction

public void commitTransaction(String txID)
                       throws ActiveMQStompException

Throws:

ActiveMQStompException

abortTransaction

public void abortTransaction(String txID)
                      throws ActiveMQStompException

Throws:

ActiveMQStompException

unsubscribe

public void unsubscribe(String subscriptionID,
                        String durableSubscriptionName)
                 throws ActiveMQStompException

Throws:

ActiveMQStompException

acknowledge

public void acknowledge(String messageID,
                        String subscriptionID)
                 throws ActiveMQStompException

Throws:

ActiveMQStompException

getVersion

public String getVersion()

getActiveMQServerName

public String getActiveMQServerName()

createStompMessage

public StompFrame createStompMessage(ServerMessage serverMessage,
                                     StompSubscription subscription,
                                     int deliveryCount)
                              throws Exception

Throws:

Exception

addStompEventListener

public void addStompEventListener(FrameEventListener listener)

ping

public void ping(StompFrame pingFrame)

physicalSend

public void physicalSend(StompFrame frame)
                  throws Exception

Throws:

Exception

getFrameHandler

public VersionedStompFrameHandler getFrameHandler()

enableMessageID

public boolean enableMessageID()

getMinLargeMessageSize

public int getMinLargeMessageSize()

getManager

public StompProtocolManager getManager()

killMessage

public void killMessage(org.apache.activemq.artemis.api.core.SimpleString nodeID)

Specified by:

killMessage in interface RemotingConnection

isSupportsFlowControl

public boolean isSupportsFlowControl()

Specified by:

isSupportsFlowControl in interface RemotingConnection