org.apache.qpid.client
Class AMQConnectionURL

java.lang.Object
  extended by org.apache.qpid.client.AMQConnectionURL
All Implemented Interfaces:
ConnectionURL

public class AMQConnectionURL
extends Object
implements ConnectionURL


Field Summary
 
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
 
Constructor Summary
AMQConnectionURL(String fullURL)
           
 
Method Summary
 void addBrokerDetails(BrokerDetails broker)
           
 List<BrokerDetails> getAllBrokerDetails()
           
 int getBrokerCount()
           
 BrokerDetails getBrokerDetails(int index)
           
 String getClientName()
           
 org.apache.qpid.framing.AMQShortString getDefaultQueueExchangeName()
           
 org.apache.qpid.framing.AMQShortString getDefaultTopicExchangeName()
           
 String getFailoverMethod()
           
 String getFailoverOption(String key)
           
 Map<String,String> getFailoverOptions()
           
 String getOption(String key)
           
 Map<String,String> getOptions()
           
 String getPassword()
           
 org.apache.qpid.framing.AMQShortString getTemporaryQueueExchangeName()
           
 org.apache.qpid.framing.AMQShortString getTemporaryTopicExchangeName()
           
 String getURL()
           
 String getUsername()
           
 String getVirtualHost()
           
static void main(String[] args)
           
 void setBrokerDetails(List<BrokerDetails> brokers)
           
 void setClientName(String clientName)
           
 void setDefaultQueueExchangeName(org.apache.qpid.framing.AMQShortString defaultQueueExchangeName)
           
 void setDefaultTopicExchangeName(org.apache.qpid.framing.AMQShortString defaultTopicExchangeName)
           
 void setFailoverMethod(String failoverMethod)
           
 void setFailoverOption(String key, String value)
           
 void setOption(String key, String value)
           
 void setPassword(String password)
           
 void setTemporaryQueueExchangeName(org.apache.qpid.framing.AMQShortString temporaryQueueExchangeName)
           
 void setTemporaryTopicExchangeName(org.apache.qpid.framing.AMQShortString temporaryTopicExchangeName)
           
 void setUsername(String username)
           
 void setVirtualHost(String virtuaHost)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AMQConnectionURL

public AMQConnectionURL(String fullURL)
                 throws org.apache.qpid.url.URLSyntaxException
Throws:
org.apache.qpid.url.URLSyntaxException
Method Detail

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