Package org.apache.activemq.artemis.core.config.amqpBrokerConnectivity

Class AMQPBrokerConnectConfiguration

java.lang.Object

org.apache.activemq.artemis.core.config.brokerConnectivity.BrokerConnectConfiguration

org.apache.activemq.artemis.core.config.amqpBrokerConnectivity.AMQPBrokerConnectConfiguration

All Implemented Interfaces:

Serializable

public class AMQPBrokerConnectConfiguration
extends BrokerConnectConfiguration

This is a specific AMQP Broker Connection Configuration

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
AMQPBrokerConnectConfiguration()
AMQPBrokerConnectConfiguration(String name, String uri)

Method Summary

Modifier and Type	Method	Description
AMQPBrokerConnectConfiguration	addConnectionElement(AMQPMirrorBrokerConnectionElement amqpBrokerConnectionElement)
AMQPBrokerConnectConfiguration	addElement(AMQPBrokerConnectionElement amqpBrokerConnectionElement)
AMQPBrokerConnectConfiguration	addFederation(AMQPFederatedBrokerConnectionElement amqpFederationElement)
AMQPBrokerConnectConfiguration	addMirror(AMQPMirrorBrokerConnectionElement amqpMirrorBrokerConnectionElement)
AMQPBrokerConnectConfiguration	addPeer(AMQPBrokerConnectionElement element)
AMQPBrokerConnectConfiguration	addReceiver(AMQPBrokerConnectionElement element)
AMQPBrokerConnectConfiguration	addSender(AMQPBrokerConnectionElement element)
boolean	equals(Object obj)
List<AMQPBrokerConnectionElement>	getConnectionElements()
List<AMQPBrokerConnectionElement>	getFederations()
List<AMQPBrokerConnectionElement>	getMirrors()
List<AMQPBrokerConnectionElement>	getPeers()
List<AMQPBrokerConnectionElement>	getReceivers()
List<AMQPBrokerConnectionElement>	getSenders()
List<TransportConfiguration>	getTransportConfigurations()
int	hashCode()
void	parseURI()
AMQPBrokerConnectConfiguration	setAutostart(boolean autostart)
AMQPBrokerConnectConfiguration	setName(String name)
AMQPBrokerConnectConfiguration	setPassword(String password)
AMQPBrokerConnectConfiguration	setReconnectAttempts(int reconnectAttempts)
AMQPBrokerConnectConfiguration	setRetryInterval(int retryInterval)
AMQPBrokerConnectConfiguration	setUri(String uri)
AMQPBrokerConnectConfiguration	setUser(String user)

Methods inherited from class org.apache.activemq.artemis.core.config.brokerConnectivity.BrokerConnectConfiguration

getName, getPassword, getReconnectAttempts, getRetryInterval, getUri, getUser, isAutostart

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AMQPBrokerConnectConfiguration

public AMQPBrokerConnectConfiguration()

AMQPBrokerConnectConfiguration

public AMQPBrokerConnectConfiguration(String name,
 String uri)

Method Details

addElement

public AMQPBrokerConnectConfiguration addElement(AMQPBrokerConnectionElement amqpBrokerConnectionElement)

addConnectionElement

public AMQPBrokerConnectConfiguration addConnectionElement(AMQPMirrorBrokerConnectionElement amqpBrokerConnectionElement)

getConnectionElements

public List<AMQPBrokerConnectionElement> getConnectionElements()

addFederation

public AMQPBrokerConnectConfiguration addFederation(AMQPFederatedBrokerConnectionElement amqpFederationElement)

getFederations

public List<AMQPBrokerConnectionElement> getFederations()

addMirror

public AMQPBrokerConnectConfiguration addMirror(AMQPMirrorBrokerConnectionElement amqpMirrorBrokerConnectionElement)

getMirrors

public List<AMQPBrokerConnectionElement> getMirrors()

addPeer

public AMQPBrokerConnectConfiguration addPeer(AMQPBrokerConnectionElement element)

getPeers

public List<AMQPBrokerConnectionElement> getPeers()

addSender

public AMQPBrokerConnectConfiguration addSender(AMQPBrokerConnectionElement element)

getSenders

public List<AMQPBrokerConnectionElement> getSenders()

addReceiver

public AMQPBrokerConnectConfiguration addReceiver(AMQPBrokerConnectionElement element)

getReceivers

public List<AMQPBrokerConnectionElement> getReceivers()

parseURI

public void parseURI()
              throws Exception

Specified by:

parseURI in class BrokerConnectConfiguration

Throws:

Exception

getTransportConfigurations

public List<TransportConfiguration> getTransportConfigurations()
                                                        throws Exception

Throws:

Exception

setReconnectAttempts

public AMQPBrokerConnectConfiguration setReconnectAttempts(int reconnectAttempts)

Overrides:

setReconnectAttempts in class BrokerConnectConfiguration

setUser

public AMQPBrokerConnectConfiguration setUser(String user)

Overrides:

setUser in class BrokerConnectConfiguration

setRetryInterval

public AMQPBrokerConnectConfiguration setRetryInterval(int retryInterval)

Overrides:

setRetryInterval in class BrokerConnectConfiguration

setPassword

public AMQPBrokerConnectConfiguration setPassword(String password)

Overrides:

setPassword in class BrokerConnectConfiguration

setUri

public AMQPBrokerConnectConfiguration setUri(String uri)

Overrides:

setUri in class BrokerConnectConfiguration

setName

public AMQPBrokerConnectConfiguration setName(String name)

Overrides:

setName in class BrokerConnectConfiguration

setAutostart

public AMQPBrokerConnectConfiguration setAutostart(boolean autostart)

Overrides:

setAutostart in class BrokerConnectConfiguration

hashCode

public int hashCode()

Overrides:

hashCode in class BrokerConnectConfiguration

equals

public boolean equals(Object obj)

Overrides:

equals in class BrokerConnectConfiguration