public class ConnectionInfo extends BaseCommand
Modifier and Type | Field and Description |
---|---|
protected boolean |
brokerMasterConnector |
protected BrokerId[] |
brokerPath |
protected org.fusesource.hawtbuf.UTF8Buffer |
clientId |
protected org.fusesource.hawtbuf.UTF8Buffer |
clientIp |
protected boolean |
clientMaster |
protected ConnectionId |
connectionId |
static byte |
DATA_STRUCTURE_TYPE |
protected boolean |
faultTolerant |
protected boolean |
manageable |
protected org.fusesource.hawtbuf.UTF8Buffer |
password |
protected java.lang.Object |
transportContext |
protected org.fusesource.hawtbuf.UTF8Buffer |
userName |
commandId, responseRequired
Constructor and Description |
---|
ConnectionInfo() |
ConnectionInfo(ConnectionId connectionId) |
Modifier and Type | Method and Description |
---|---|
ConnectionInfo |
copy() |
RemoveInfo |
createRemoveCommand() |
BrokerId[] |
getBrokerPath()
The route of brokers the command has moved through.
|
org.fusesource.hawtbuf.UTF8Buffer |
getClientId() |
org.fusesource.hawtbuf.UTF8Buffer |
getClientIp() |
ConnectionId |
getConnectionId() |
byte |
getDataStructureType() |
org.fusesource.hawtbuf.UTF8Buffer |
getPassword() |
java.lang.Object |
getTransportContext()
Transports may wish to associate additional data with the connection.
|
org.fusesource.hawtbuf.UTF8Buffer |
getUserName() |
boolean |
isBrokerMasterConnector() |
boolean |
isClientMaster() |
boolean |
isFailoverReconnect() |
boolean |
isFaultTolerant() |
boolean |
isManageable() |
void |
setBrokerMasterConnector(boolean slaveBroker) |
void |
setBrokerPath(BrokerId[] brokerPath) |
void |
setClientId(org.fusesource.hawtbuf.UTF8Buffer clientId) |
void |
setClientIp(org.fusesource.hawtbuf.UTF8Buffer clientIp) |
void |
setClientMaster(boolean clientMaster) |
void |
setConnectionId(ConnectionId connectionId) |
void |
setFailoverReconnect(boolean failoverReconnect) |
void |
setFaultTolerant(boolean faultTolerant) |
void |
setManageable(boolean manageable) |
void |
setPassword(org.fusesource.hawtbuf.UTF8Buffer password) |
void |
setTransportContext(java.lang.Object transportContext)
Transports may wish to associate additional data with the connection.
|
void |
setUserName(org.fusesource.hawtbuf.UTF8Buffer userName) |
copy, getCommandId, isBrokerInfo, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setResponseRequired, toString, toString
public static final byte DATA_STRUCTURE_TYPE
protected ConnectionId connectionId
protected org.fusesource.hawtbuf.UTF8Buffer clientId
protected org.fusesource.hawtbuf.UTF8Buffer clientIp
protected org.fusesource.hawtbuf.UTF8Buffer userName
protected org.fusesource.hawtbuf.UTF8Buffer password
protected BrokerId[] brokerPath
protected boolean brokerMasterConnector
protected boolean manageable
protected boolean clientMaster
protected boolean faultTolerant
protected transient java.lang.Object transportContext
public ConnectionInfo()
public ConnectionInfo(ConnectionId connectionId)
public byte getDataStructureType()
public ConnectionInfo copy()
public ConnectionId getConnectionId()
public void setConnectionId(ConnectionId connectionId)
public org.fusesource.hawtbuf.UTF8Buffer getClientId()
public void setClientId(org.fusesource.hawtbuf.UTF8Buffer clientId)
public RemoveInfo createRemoveCommand()
public org.fusesource.hawtbuf.UTF8Buffer getPassword()
public void setPassword(org.fusesource.hawtbuf.UTF8Buffer password)
public org.fusesource.hawtbuf.UTF8Buffer getUserName()
public void setUserName(org.fusesource.hawtbuf.UTF8Buffer userName)
public BrokerId[] getBrokerPath()
public void setBrokerPath(BrokerId[] brokerPath)
public boolean isBrokerMasterConnector()
public void setBrokerMasterConnector(boolean slaveBroker)
slaveBroker
- The brokerMasterConnector to set.public boolean isManageable()
public void setManageable(boolean manageable)
manageable
- The manageable to set.public java.lang.Object getTransportContext()
public void setTransportContext(java.lang.Object transportContext)
transportContext
- value used to set the transport contextpublic boolean isClientMaster()
public void setClientMaster(boolean clientMaster)
clientMaster
- the clientMaster to setpublic boolean isFaultTolerant()
public void setFaultTolerant(boolean faultTolerant)
faultTolerant
- the faultTolerant to setpublic boolean isFailoverReconnect()
public void setFailoverReconnect(boolean failoverReconnect)
public org.fusesource.hawtbuf.UTF8Buffer getClientIp()
public void setClientIp(org.fusesource.hawtbuf.UTF8Buffer clientIp)
Copyright © 2011-2014 Red Hat. All Rights Reserved.