public class ManagementRemotingConnection extends Object implements RemotingConnection
Modifier and Type | Field and Description |
---|---|
SessionCallback |
callback |
Constructor and Description |
---|
ManagementRemotingConnection() |
Modifier and Type | Method and Description |
---|---|
void |
addCloseListener(CloseListener listener)
add a CloseListener.
|
void |
addFailureListener(FailureListener listener)
add a failure listener.
|
Future |
asyncFail(ActiveMQException me)
Same thing as fail, but using an executor.
|
void |
bufferReceived(Object connectionID,
ActiveMQBuffer 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.
|
ActiveMQBuffer |
createTransportBuffer(int size)
creates a new ActiveMQBuffer of the specified size.
|
void |
destroy()
destroys this connection.
|
void |
disconnect(boolean criticalError)
Disconnect the connection, closing all channels
|
void |
disconnect(String scaleDownNodeID,
boolean criticalError)
Disconnect the connection, closing all channels
|
void |
fail(ActiveMQException me)
called when the underlying connection fails.
|
void |
fail(ActiveMQException me,
String scaleDownTargetNodeID)
called when the underlying connection fails.
|
void |
flush()
flush all outstanding data from the connection.
|
String |
getClientID()
Returns the Client ID associated with this connection
|
long |
getCreationTime()
Returns the creation time of the
RemotingConnection . |
List<FailureListener> |
getFailureListeners()
return all the failure listeners
|
Object |
getID()
Returns the unique id of the
RemotingConnection . |
String |
getProtocolName()
Returns the name of the protocol for this Remoting Connection
|
String |
getRemoteAddress()
returns a string representation of the remote address of this connection
|
Subject |
getSubject()
the possibly null identity associated with this connection
|
Connection |
getTransportConnection()
return the underlying Connection.
|
String |
getTransportLocalAddress()
Returns a string representation of the local address this connection is connected to.
|
boolean |
isClient()
Returns whether or not the
RemotingConnection is a client |
boolean |
isDestroyed()
Returns true if this
RemotingConnection has been destroyed. |
boolean |
isSupportReconnect()
This will check if reconnects are supported on the protocol and configuration.
|
boolean |
isSupportsFlowControl()
Return true if the protocol supports flow control.
|
boolean |
isWritable(ReadyListener callback) |
void |
killMessage(SimpleString nodeID)
if slow consumer is killed,send the msessage to client.
|
boolean |
removeCloseListener(CloseListener listener)
remove a Close Listener
|
List<CloseListener> |
removeCloseListeners() |
boolean |
removeFailureListener(FailureListener listener)
remove the failure listener
|
List<FailureListener> |
removeFailureListeners() |
void |
scheduledFlush() |
void |
setClientID(String cID)
Sets the client ID associated with this connection
|
void |
setCloseListeners(List<CloseListener> listeners) |
void |
setFailureListeners(List<FailureListener> listeners)
set the failure listeners.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isSameTarget
public SessionCallback callback
public Object getID()
RemotingConnection
RemotingConnection
.getID
in interface RemotingConnection
public long getCreationTime()
RemotingConnection
RemotingConnection
.getCreationTime
in interface RemotingConnection
public String getRemoteAddress()
RemotingConnection
getRemoteAddress
in interface RemotingConnection
public void scheduledFlush()
scheduledFlush
in interface RemotingConnection
public void addFailureListener(FailureListener listener)
RemotingConnection
The listener will be called in the event of connection failure.
addFailureListener
in interface RemotingConnection
listener
- the listenerpublic boolean removeFailureListener(FailureListener listener)
RemotingConnection
removeFailureListener
in interface RemotingConnection
listener
- the lister to removepublic void addCloseListener(CloseListener listener)
RemotingConnection
This will be called in the event of the connection being closed.
addCloseListener
in interface RemotingConnection
listener
- the listener to addpublic boolean removeCloseListener(CloseListener listener)
RemotingConnection
removeCloseListener
in interface RemotingConnection
listener
- the listener to removepublic List<CloseListener> removeCloseListeners()
removeCloseListeners
in interface RemotingConnection
public void setCloseListeners(List<CloseListener> listeners)
setCloseListeners
in interface RemotingConnection
public List<FailureListener> getFailureListeners()
RemotingConnection
getFailureListeners
in interface RemotingConnection
public List<FailureListener> removeFailureListeners()
removeFailureListeners
in interface RemotingConnection
public void setFailureListeners(List<FailureListener> listeners)
RemotingConnection
These will be called in the event of the connection being closed. Any previously added listeners will be removed.
setFailureListeners
in interface RemotingConnection
listeners
- the listeners to add.public ActiveMQBuffer createTransportBuffer(int size)
RemotingConnection
createTransportBuffer
in interface RemotingConnection
size
- the size of buffer requiredpublic void fail(ActiveMQException me)
RemotingConnection
fail
in interface RemotingConnection
me
- the exception that caused the failurepublic Future asyncFail(ActiveMQException me)
RemotingConnection
asyncFail
in interface RemotingConnection
public void fail(ActiveMQException me, String scaleDownTargetNodeID)
RemotingConnection
fail
in interface RemotingConnection
me
- the exception that caused the failurescaleDownTargetNodeID
- the ID of the node where scale down is targetedpublic void destroy()
RemotingConnection
destroy
in interface RemotingConnection
public Connection getTransportConnection()
RemotingConnection
getTransportConnection
in interface RemotingConnection
public boolean isClient()
RemotingConnection
RemotingConnection
is a clientisClient
in interface RemotingConnection
public boolean isDestroyed()
RemotingConnection
RemotingConnection
has been destroyed.isDestroyed
in interface RemotingConnection
public void disconnect(boolean criticalError)
RemotingConnection
disconnect
in interface RemotingConnection
public void disconnect(String scaleDownNodeID, boolean criticalError)
RemotingConnection
disconnect
in interface RemotingConnection
public boolean checkDataReceived()
RemotingConnection
checkDataReceived
in interface RemotingConnection
public void flush()
RemotingConnection
flush
in interface RemotingConnection
public boolean isWritable(ReadyListener callback)
isWritable
in interface RemotingConnection
public void killMessage(SimpleString nodeID)
RemotingConnection
killMessage
in interface RemotingConnection
public boolean isSupportReconnect()
RemotingConnection
isSupportReconnect
in interface RemotingConnection
public boolean isSupportsFlowControl()
RemotingConnection
isSupportsFlowControl
in interface RemotingConnection
public Subject getSubject()
RemotingConnection
getSubject
in interface RemotingConnection
public String getProtocolName()
RemotingConnection
getProtocolName
in interface RemotingConnection
public void setClientID(String cID)
RemotingConnection
setClientID
in interface RemotingConnection
public String getClientID()
RemotingConnection
getClientID
in interface RemotingConnection
public String getTransportLocalAddress()
RemotingConnection
getTransportLocalAddress
in interface RemotingConnection
public void bufferReceived(Object connectionID, ActiveMQBuffer buffer)
BufferHandler
bufferReceived
in interface BufferHandler
connectionID
- the connection the buffer was received onbuffer
- the buffer to decodeCopyright © 2020 JBoss by Red Hat. All rights reserved.