org.apache.qpid.oldtopic
Class Config

java.lang.Object
  extended by org.apache.qpid.config.AbstractConfig
      extended by org.apache.qpid.oldtopic.Config
All Implemented Interfaces:
ConnectorConfig

 class Config
extends AbstractConfig
implements ConnectorConfig


Constructor Summary
Config()
           
 
Method Summary
 Connection createConnection()
           
(package private)  int getAckMode()
           
(package private) static String getAckModeDescription(int ackMode)
           
(package private)  int getBatch()
           
(package private)  String getClientId()
           
(package private)  int getClients()
           
 long getDelay()
           
 String getFactory()
           
 String getHost()
           
(package private)  int getMessages()
           
(package private)  int getPayload()
           
 int getPort()
           
(package private)  String getSubscriptionId()
           
(package private)  int getWarmup()
           
(package private)  void setBatch(int batch)
           
(package private)  void setClients(int clients)
           
 void setDelay(long delay)
           
 void setHost(String host)
           
(package private)  void setMessages(int messages)
           
 void setOption(String key, String value)
           
(package private)  void setPayload(int payload)
           
 void setPort(int port)
           
(package private)  void setWarmup(int warmup)
           
(package private)  boolean usePersistentMessages()
           
 
Methods inherited from class org.apache.qpid.config.AbstractConfig
parseInt, parseLong, setOptions
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Config

public Config()
Method Detail

getAckMode

int getAckMode()

setPayload

void setPayload(int payload)

getPayload

int getPayload()

setClients

void setClients(int clients)

getClients

int getClients()

setMessages

void setMessages(int messages)

getMessages

int getMessages()

getHost

public String getHost()
Specified by:
getHost in interface ConnectorConfig

setHost

public void setHost(String host)

getPort

public int getPort()
Specified by:
getPort in interface ConnectorConfig

getFactory

public String getFactory()
Specified by:
getFactory in interface ConnectorConfig

setPort

public void setPort(int port)

getBatch

int getBatch()

setBatch

void setBatch(int batch)

getWarmup

int getWarmup()

setWarmup

void setWarmup(int warmup)

getDelay

public long getDelay()

setDelay

public void setDelay(long delay)

getClientId

String getClientId()

getSubscriptionId

String getSubscriptionId()

usePersistentMessages

boolean usePersistentMessages()

setOption

public void setOption(String key,
                      String value)
Specified by:
setOption in class AbstractConfig

getAckModeDescription

static String getAckModeDescription(int ackMode)

createConnection

public Connection createConnection()
                            throws Exception
Throws:
Exception


Licensed to the Apache Software Foundation