public class AMQConnectionURL extends Object implements ConnectionURL, Serializable
AMQ_PROTOCOL, OPTIONS_BROKERLIST, OPTIONS_CLOSE_WHEN_NO_ROUTE, OPTIONS_COMPRESS_MESSAGES, OPTIONS_DEFAULT_QUEUE_EXCHANGE, OPTIONS_DEFAULT_TOPIC_EXCHANGE, OPTIONS_FAILOVER, OPTIONS_FAILOVER_CYCLE, OPTIONS_MAXPREFETCH, OPTIONS_MESSAGES_COMPRESSION_THRESHOLD_SIZE, OPTIONS_OBJECT_MESSAGE_CLASS_HIERARCHY_BLACK_LIST, OPTIONS_OBJECT_MESSAGE_CLASS_HIERARCHY_WHITE_LIST, OPTIONS_POPULATE_USER_ID, OPTIONS_REJECT_BEHAVIOUR, OPTIONS_SSL, OPTIONS_SYNC_ACK, OPTIONS_SYNC_PERSISTENCE, OPTIONS_SYNC_PUBLISH, OPTIONS_TEMPORARY_QUEUE_EXCHANGE, OPTIONS_TEMPORARY_TOPIC_EXCHANGE, OPTIONS_USE_LEGACY_MAP_MESSAGE_FORMAT, OPTIONS_USE_LEGACY_STREAM_MESSAGE_FORMAT, OPTIONS_VERIFY_QUEUE_ON_SEND, URL_0_10, URL_0_8
Constructor and Description |
---|
AMQConnectionURL(String fullURL) |
public AMQConnectionURL(String fullURL) throws URLSyntaxException
URLSyntaxException
public String getURL()
getURL
in interface ConnectionURL
public String getFailoverMethod()
getFailoverMethod
in interface ConnectionURL
public void setFailoverMethod(String failoverMethod)
public String getFailoverOption(String key)
getFailoverOption
in interface ConnectionURL
public int getBrokerCount()
getBrokerCount
in interface ConnectionURL
public BrokerDetails getBrokerDetails(int index)
getBrokerDetails
in interface ConnectionURL
public void addBrokerDetails(BrokerDetails broker)
addBrokerDetails
in interface ConnectionURL
public void setBrokerDetails(List<BrokerDetails> brokers)
setBrokerDetails
in interface ConnectionURL
public List<BrokerDetails> getAllBrokerDetails()
getAllBrokerDetails
in interface ConnectionURL
public String getClientName()
getClientName
in interface ConnectionURL
public void setClientName(String clientName)
setClientName
in interface ConnectionURL
public String getUsername()
getUsername
in interface ConnectionURL
public void setUsername(String username)
setUsername
in interface ConnectionURL
public String getPassword()
getPassword
in interface ConnectionURL
public void setPassword(String password)
setPassword
in interface ConnectionURL
public String getVirtualHost()
getVirtualHost
in interface ConnectionURL
public void setVirtualHost(String virtuaHost)
setVirtualHost
in interface ConnectionURL
public String getOption(String key)
getOption
in interface ConnectionURL
public void setOption(String key, String value)
setOption
in interface ConnectionURL
public String getDefaultQueueExchangeName()
getDefaultQueueExchangeName
in interface ConnectionURL
public void setDefaultQueueExchangeName(String defaultQueueExchangeName)
public String getDefaultTopicExchangeName()
getDefaultTopicExchangeName
in interface ConnectionURL
public void setDefaultTopicExchangeName(String defaultTopicExchangeName)
public String getTemporaryQueueExchangeName()
getTemporaryQueueExchangeName
in interface ConnectionURL
public void setTemporaryQueueExchangeName(String temporaryQueueExchangeName)
public String getTemporaryTopicExchangeName()
getTemporaryTopicExchangeName
in interface ConnectionURL
public void setTemporaryTopicExchangeName(String temporaryTopicExchangeName)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.