org.apache.activemq.command
Class BrokerInfo
java.lang.Object
org.apache.activemq.command.BaseCommand
org.apache.activemq.command.BrokerInfo
- All Implemented Interfaces:
- Command, DataStructure
public class BrokerInfo
- extends BaseCommand
When a client connects to a broker, the broker send the client a BrokerInfo
so that the client knows which broker node he's talking to and also any peers
that the node has in his cluster. This is the broker helping the client out
in discovering other nodes in the cluster.
Methods inherited from class org.apache.activemq.command.BaseCommand |
copy, getCommandId, getFrom, getTo, isConnectionControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
BrokerInfo
public BrokerInfo()
copy
public BrokerInfo copy()
isBrokerInfo
public boolean isBrokerInfo()
- Specified by:
isBrokerInfo
in interface Command
- Overrides:
isBrokerInfo
in class BaseCommand
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
getBrokerId
public BrokerId getBrokerId()
setBrokerId
public void setBrokerId(BrokerId brokerId)
getBrokerURL
public java.lang.String getBrokerURL()
setBrokerURL
public void setBrokerURL(java.lang.String brokerURL)
getPeerBrokerInfos
public BrokerInfo[] getPeerBrokerInfos()
setPeerBrokerInfos
public void setPeerBrokerInfos(BrokerInfo[] peerBrokerInfos)
getBrokerName
public java.lang.String getBrokerName()
setBrokerName
public void setBrokerName(java.lang.String brokerName)
visit
public Response visit(CommandVisitor visitor)
throws java.lang.Exception
- Throws:
java.lang.Exception
isSlaveBroker
public boolean isSlaveBroker()
setSlaveBroker
public void setSlaveBroker(boolean slaveBroker)
isMasterBroker
public boolean isMasterBroker()
setMasterBroker
public void setMasterBroker(boolean masterBroker)
- Parameters:
masterBroker
- The masterBroker to set.
isFaultTolerantConfiguration
public boolean isFaultTolerantConfiguration()
- Returns:
- Returns the faultTolerantConfiguration.
setFaultTolerantConfiguration
public void setFaultTolerantConfiguration(boolean faultTolerantConfiguration)
- Parameters:
faultTolerantConfiguration
- The faultTolerantConfiguration to set.
isDuplexConnection
public boolean isDuplexConnection()
- Returns:
- the duplexConnection
setDuplexConnection
public void setDuplexConnection(boolean duplexConnection)
- Parameters:
duplexConnection
- the duplexConnection to set
isNetworkConnection
public boolean isNetworkConnection()
- Returns:
- the networkConnection
setNetworkConnection
public void setNetworkConnection(boolean networkConnection)
- Parameters:
networkConnection
- the networkConnection to set
getConnectionId
public long getConnectionId()
- The broker assigns a each connection it accepts a connection id.
setConnectionId
public void setConnectionId(long connectionId)
getBrokerUploadUrl
public java.lang.String getBrokerUploadUrl()
- The URL to use when uploading BLOBs to the broker or some other external
file/http server
setBrokerUploadUrl
public void setBrokerUploadUrl(java.lang.String brokerUploadUrl)
getNetworkProperties
public java.lang.String getNetworkProperties()
- Returns:
- the networkProperties
setNetworkProperties
public void setNetworkProperties(java.lang.String networkProperties)
- Parameters:
networkProperties
- the networkProperties to set
isPassiveSlave
public boolean isPassiveSlave()
setPassiveSlave
public void setPassiveSlave(boolean value)
getProperties
public java.util.Properties getProperties()
getRefCount
public int getRefCount()
incrementRefCount
public void incrementRefCount()
decrementRefCount
public int decrementRefCount()
Copyright © 2005-2016. All Rights Reserved.