org.hornetq.core.protocol.stomp
public final class StompConnection extends Object implements RemotingConnection
Modifier and Type | Field and Description |
---|---|
protected static String |
CONNECTION_ID_PROP |
protected static final String CONNECTION_ID_PROP
public StompFrame decode(HornetQBuffer buffer) throws HornetQStompException
HornetQStompException
public boolean hasBytes()
public void addFailureListener(FailureListener listener)
addFailureListener
in interface RemotingConnection
public boolean removeFailureListener(FailureListener listener)
removeFailureListener
in interface RemotingConnection
public void addCloseListener(CloseListener listener)
addCloseListener
in interface RemotingConnection
public boolean removeCloseListener(CloseListener listener)
removeCloseListener
in interface RemotingConnection
public List<CloseListener> removeCloseListeners()
removeCloseListeners
in interface RemotingConnection
public List<FailureListener> removeFailureListeners()
removeFailureListeners
in interface RemotingConnection
public void setCloseListeners(List<CloseListener> listeners)
setCloseListeners
in interface RemotingConnection
public void setFailureListeners(List<FailureListener> listeners)
setFailureListeners
in interface RemotingConnection
protected void setDataReceived()
public boolean checkDataReceived()
checkDataReceived
in interface RemotingConnection
public void checkDestination(String destination) throws HornetQStompException
HornetQStompException
public HornetQBuffer createBuffer(int size)
createBuffer
in interface RemotingConnection
public void destroy()
destroy
in interface RemotingConnection
public void fail(HornetQException me)
fail
in interface RemotingConnection
public void flush()
flush
in interface RemotingConnection
public List<FailureListener> getFailureListeners()
getFailureListeners
in interface RemotingConnection
public Object getID()
getID
in interface RemotingConnection
public String getRemoteAddress()
getRemoteAddress
in interface RemotingConnection
public long getCreationTime()
getCreationTime
in interface RemotingConnection
public Connection getTransportConnection()
getTransportConnection
in interface RemotingConnection
public boolean isClient()
isClient
in interface RemotingConnection
public boolean isDestroyed()
isDestroyed
in interface RemotingConnection
public void bufferReceived(Object connectionID, HornetQBuffer buffer)
bufferReceived
in interface BufferHandler
public String getLogin()
public String getPasscode()
public void setClientID(String clientID)
public String getClientID()
public boolean isValid()
public void setValid(boolean valid)
public void negotiateVersion(StompFrame frame) throws HornetQStompException
HornetQStompException
public void setHost(String host) throws HornetQStompException
HornetQStompException
public void handleFrame(StompFrame request)
public void sendFrame(StompFrame frame)
public ServerMessageImpl createServerMessage()
public StompSession getSession(String txID) throws HornetQStompException
HornetQStompException
protected void validate() throws HornetQStompException
HornetQStompException
protected void sendServerMessage(ServerMessageImpl message, String txID) throws HornetQStompException
HornetQStompException
public void disconnect(boolean criticalError)
disconnect
in interface RemotingConnection
protected void beginTransaction(String txID) throws HornetQStompException
HornetQStompException
public void commitTransaction(String txID) throws HornetQStompException
HornetQStompException
public void abortTransaction(String txID) throws HornetQStompException
HornetQStompException
public void unsubscribe(String subscriptionID, String durableSubscriberName) throws HornetQStompException
HornetQStompException
public void acknowledge(String messageID, String subscriptionID) throws HornetQStompException
HornetQStompException
public String getVersion()
public String getHornetQServerName()
public StompFrame createStompMessage(ServerMessage serverMessage, StompSubscription subscription, int deliveryCount) throws Exception
Exception
public void addStompEventListener(FrameEventListener listener)
public void ping(StompFrame pingFrame)
public void physicalSend(StompFrame frame) throws Exception
Exception
public VersionedStompFrameHandler getFrameHandler()
public boolean enableMessageID()
public int getMinLargeMessageSize()
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.