|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface RemotingConnection
A RemotingConnection is a connection between a client and a server.
Method Summary | |
---|---|
void |
addCloseListener(org.hornetq.core.remoting.CloseListener listener)
add a CloseListener. |
void |
addFailureListener(org.hornetq.core.remoting.FailureListener listener)
add a failure listener. |
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 |
void |
fail(HornetQException me)
called when the underlying connection fails. |
void |
flush()
flush all outstanding data from the connection. |
long |
getCreationTime()
Returns the creation time of the Remoting connection |
List<org.hornetq.core.remoting.FailureListener> |
getFailureListeners()
return all the failure listeners |
Object |
getID()
returns the unique id of the Remoting Connection |
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 |
removeCloseListener(org.hornetq.core.remoting.CloseListener listener)
remove a Close Listener |
List<org.hornetq.core.remoting.CloseListener> |
removeCloseListeners()
|
boolean |
removeFailureListener(org.hornetq.core.remoting.FailureListener listener)
remove the failure listener |
List<org.hornetq.core.remoting.FailureListener> |
removeFailureListeners()
|
void |
setCloseListeners(List<org.hornetq.core.remoting.CloseListener> listeners)
|
void |
setFailureListeners(List<org.hornetq.core.remoting.FailureListener> listeners)
set the failure listeners. |
Methods inherited from interface org.hornetq.spi.core.remoting.BufferHandler |
---|
bufferReceived |
Method Detail |
---|
Object getID()
long getCreationTime()
String getRemoteAddress()
void addFailureListener(org.hornetq.core.remoting.FailureListener listener)
listener
- the listenerboolean removeFailureListener(org.hornetq.core.remoting.FailureListener listener)
listener
- the lister to remove
void addCloseListener(org.hornetq.core.remoting.CloseListener listener)
listener
- the listener to addboolean removeCloseListener(org.hornetq.core.remoting.CloseListener listener)
listener
- the listener to remove
List<org.hornetq.core.remoting.CloseListener> removeCloseListeners()
void setCloseListeners(List<org.hornetq.core.remoting.CloseListener> listeners)
List<org.hornetq.core.remoting.FailureListener> getFailureListeners()
List<org.hornetq.core.remoting.FailureListener> removeFailureListeners()
void setFailureListeners(List<org.hornetq.core.remoting.FailureListener> listeners)
listeners
- the listeners to add.HornetQBuffer createBuffer(int size)
size
- the size of buffer required
void fail(HornetQException me)
me
- the exception that caused the failurevoid destroy()
Connection getTransportConnection()
boolean isClient()
boolean isDestroyed()
void disconnect(boolean criticalError)
boolean checkDataReceived()
void flush()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |