public class StompConnection extends Object implements RemotingConnection
| Modifier and Type | Method and Description |
|---|---|
void |
addCloseListener(CloseListener listener)
add a CloseListener.
|
void |
addFailureListener(FailureListener listener)
add a failure listener.
|
void |
bufferReceived(Object connectionID,
HornetQBuffer buffer)
called by the remoting connection when a buffer is received.
|
boolean |
checkDataReceived()
returns true if any data has been received since the last time this method was called.
|
HornetQBuffer |
createBuffer(int size)
creates a new HornetQBuffer of the specified size.
|
void |
destroy()
destroys this connection.
|
void |
disconnect(boolean criticalError)
Disconnect the connection, closing all channels
|
boolean |
enableMessageID() |
void |
fail(HornetQException me)
called when the underlying connection fails.
|
void |
flush()
flush all outstanding data from the connection.
|
String |
getClientID() |
long |
getCreationTime()
Returns the creation time of the Remoting connection
|
StompDecoder |
getDecoder() |
List<FailureListener> |
getFailureListeners()
return all the failure listeners
|
Object |
getID()
returns the unique id of the Remoting Connection
|
String |
getLogin() |
String |
getPasscode() |
String |
getRemoteAddress()
returns a string representation of the remote address of this connection
|
Connection |
getTransportConnection()
return the underlying Connection.
|
boolean |
isClient()
returns whether or not the Remoting Connection is a client
|
boolean |
isDestroyed()
returns true if this Remoting Connection has been destroyed.
|
boolean |
isValid() |
boolean |
removeCloseListener(CloseListener listener)
remove a Close Listener
|
List<CloseListener> |
removeCloseListeners() |
boolean |
removeFailureListener(FailureListener listener)
remove the failure listener
|
List<FailureListener> |
removeFailureListeners() |
void |
setClientID(String clientID) |
void |
setCloseListeners(List<CloseListener> listeners) |
void |
setDataReceived() |
void |
setFailureListeners(List<FailureListener> listeners)
set the failure listeners.
|
void |
setLogin(String login) |
void |
setPasscode(String passcode) |
void |
setValid(boolean valid) |
public StompDecoder getDecoder()
public void addFailureListener(FailureListener listener)
RemotingConnectionaddFailureListener in interface RemotingConnectionlistener - the listenerpublic boolean removeFailureListener(FailureListener listener)
RemotingConnectionremoveFailureListener in interface RemotingConnectionlistener - the lister to removepublic void addCloseListener(CloseListener listener)
RemotingConnectionaddCloseListener in interface RemotingConnectionlistener - the listener to addpublic boolean removeCloseListener(CloseListener listener)
RemotingConnectionremoveCloseListener in interface RemotingConnectionlistener - the listener to removepublic List<CloseListener> removeCloseListeners()
removeCloseListeners in interface RemotingConnectionpublic List<FailureListener> removeFailureListeners()
removeFailureListeners in interface RemotingConnectionpublic void setCloseListeners(List<CloseListener> listeners)
setCloseListeners in interface RemotingConnectionpublic void setFailureListeners(List<FailureListener> listeners)
RemotingConnectionsetFailureListeners in interface RemotingConnectionlisteners - the listeners to add.public void setDataReceived()
public boolean checkDataReceived()
RemotingConnectioncheckDataReceived in interface RemotingConnectionpublic HornetQBuffer createBuffer(int size)
RemotingConnectioncreateBuffer in interface RemotingConnectionsize - the size of buffer requiredpublic void destroy()
RemotingConnectiondestroy in interface RemotingConnectionpublic void disconnect(boolean criticalError)
RemotingConnectiondisconnect in interface RemotingConnectionpublic void fail(HornetQException me)
RemotingConnectionfail in interface RemotingConnectionme - the exception that caused the failurepublic void flush()
RemotingConnectionflush in interface RemotingConnectionpublic List<FailureListener> getFailureListeners()
RemotingConnectiongetFailureListeners in interface RemotingConnectionpublic Object getID()
RemotingConnectiongetID in interface RemotingConnectionpublic String getRemoteAddress()
RemotingConnectiongetRemoteAddress in interface RemotingConnectionpublic long getCreationTime()
RemotingConnectiongetCreationTime in interface RemotingConnectionpublic Connection getTransportConnection()
RemotingConnectiongetTransportConnection in interface RemotingConnectionpublic boolean isClient()
RemotingConnectionisClient in interface RemotingConnectionpublic boolean isDestroyed()
RemotingConnectionisDestroyed in interface RemotingConnectionpublic void bufferReceived(Object connectionID, HornetQBuffer buffer)
BufferHandlerbufferReceived in interface BufferHandlerconnectionID - the connection the buffer was received onbuffer - the buffer to decodepublic void setLogin(String login)
public String getLogin()
public void setPasscode(String passcode)
public String getPasscode()
public void setClientID(String clientID)
public String getClientID()
public boolean isValid()
public void setValid(boolean valid)
public boolean enableMessageID()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.