org.apache.qpid.client
Class AMQConnectionURL
java.lang.Object
org.apache.qpid.client.AMQConnectionURL
- All Implemented Interfaces:
- ConnectionURL
public class AMQConnectionURL
- extends Object
- implements ConnectionURL
Fields inherited from interface org.apache.qpid.jms.ConnectionURL |
AMQ_PROTOCOL, OPTIONS_BROKERLIST, OPTIONS_DEFAULT_QUEUE_EXCHANGE, OPTIONS_DEFAULT_TOPIC_EXCHANGE, OPTIONS_FAILOVER, OPTIONS_FAILOVER_CYCLE, OPTIONS_MAXPREFETCH, OPTIONS_SYNC_ACK, OPTIONS_SYNC_PERSISTENCE, OPTIONS_SYNC_PUBLISH, OPTIONS_TEMPORARY_QUEUE_EXCHANGE, OPTIONS_TEMPORARY_TOPIC_EXCHANGE, OPTIONS_USE_LEGACY_MAP_MESSAGE_FORMAT, URL_0_10, URL_0_8 |
AMQConnectionURL
public AMQConnectionURL(String fullURL)
throws org.apache.qpid.url.URLSyntaxException
- Throws:
org.apache.qpid.url.URLSyntaxException
getURL
public String getURL()
- Specified by:
getURL
in interface ConnectionURL
getOptions
public Map<String,String> getOptions()
getFailoverMethod
public String getFailoverMethod()
- Specified by:
getFailoverMethod
in interface ConnectionURL
setFailoverMethod
public void setFailoverMethod(String failoverMethod)
getFailoverOptions
public Map<String,String> getFailoverOptions()
getFailoverOption
public String getFailoverOption(String key)
- Specified by:
getFailoverOption
in interface ConnectionURL
setFailoverOption
public void setFailoverOption(String key,
String value)
getBrokerCount
public int getBrokerCount()
- Specified by:
getBrokerCount
in interface ConnectionURL
getBrokerDetails
public BrokerDetails getBrokerDetails(int index)
- Specified by:
getBrokerDetails
in interface ConnectionURL
addBrokerDetails
public void addBrokerDetails(BrokerDetails broker)
- Specified by:
addBrokerDetails
in interface ConnectionURL
setBrokerDetails
public void setBrokerDetails(List<BrokerDetails> brokers)
- Specified by:
setBrokerDetails
in interface ConnectionURL
getAllBrokerDetails
public List<BrokerDetails> getAllBrokerDetails()
- Specified by:
getAllBrokerDetails
in interface ConnectionURL
getClientName
public String getClientName()
- Specified by:
getClientName
in interface ConnectionURL
setClientName
public void setClientName(String clientName)
- Specified by:
setClientName
in interface ConnectionURL
getUsername
public String getUsername()
- Specified by:
getUsername
in interface ConnectionURL
setUsername
public void setUsername(String username)
- Specified by:
setUsername
in interface ConnectionURL
getPassword
public String getPassword()
- Specified by:
getPassword
in interface ConnectionURL
setPassword
public void setPassword(String password)
- Specified by:
setPassword
in interface ConnectionURL
getVirtualHost
public String getVirtualHost()
- Specified by:
getVirtualHost
in interface ConnectionURL
setVirtualHost
public void setVirtualHost(String virtuaHost)
- Specified by:
setVirtualHost
in interface ConnectionURL
getOption
public String getOption(String key)
- Specified by:
getOption
in interface ConnectionURL
setOption
public void setOption(String key,
String value)
- Specified by:
setOption
in interface ConnectionURL
getDefaultQueueExchangeName
public org.apache.qpid.framing.AMQShortString getDefaultQueueExchangeName()
- Specified by:
getDefaultQueueExchangeName
in interface ConnectionURL
setDefaultQueueExchangeName
public void setDefaultQueueExchangeName(org.apache.qpid.framing.AMQShortString defaultQueueExchangeName)
getDefaultTopicExchangeName
public org.apache.qpid.framing.AMQShortString getDefaultTopicExchangeName()
- Specified by:
getDefaultTopicExchangeName
in interface ConnectionURL
setDefaultTopicExchangeName
public void setDefaultTopicExchangeName(org.apache.qpid.framing.AMQShortString defaultTopicExchangeName)
getTemporaryQueueExchangeName
public org.apache.qpid.framing.AMQShortString getTemporaryQueueExchangeName()
- Specified by:
getTemporaryQueueExchangeName
in interface ConnectionURL
setTemporaryQueueExchangeName
public void setTemporaryQueueExchangeName(org.apache.qpid.framing.AMQShortString temporaryQueueExchangeName)
getTemporaryTopicExchangeName
public org.apache.qpid.framing.AMQShortString getTemporaryTopicExchangeName()
- Specified by:
getTemporaryTopicExchangeName
in interface ConnectionURL
setTemporaryTopicExchangeName
public void setTemporaryTopicExchangeName(org.apache.qpid.framing.AMQShortString temporaryTopicExchangeName)
toString
public String toString()
- Overrides:
toString
in class Object
main
public static void main(String[] args)
throws org.apache.qpid.url.URLSyntaxException
- Throws:
org.apache.qpid.url.URLSyntaxException
Licensed to the Apache Software Foundation