org.apache.qpid.topic
Class Config

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

public class Config
extends AbstractConfig
implements ConnectorConfig


Constructor Summary
Config()
           
 
Method Summary
 Connection createConnection()
           
 int getAckMode()
           
(package private) static String getAckModeDescription(int ackMode)
           
(package private)  int getBatch()
           
 int getBatchSize()
           
 String getClientId()
           
(package private)  int getClients()
           
 long getDelay()
           
 String getDestination()
           
 int getDestinationsCount()
           
 String getFactory()
           
 String getHost()
           
 int getMessages()
           
 int getPayload()
           
 int getPort()
           
 int getRate()
           
 String getSelector()
           
 String getSubscriptionId()
           
 long getTimeout()
           
(package private)  int getWarmup()
           
 boolean isPubSub()
           
 boolean isTransacted()
           
(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)
           
 void setPayload(int payload)
           
 void setPort(int port)
           
 void setTimeout(long time)
           
(package private)  void setWarmup(int warmup)
           
 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

public int getAckMode()

setPayload

public void setPayload(int payload)

getPayload

public int getPayload()

setClients

void setClients(int clients)

getClients

int getClients()

setMessages

void setMessages(int messages)

getMessages

public int getMessages()

getBatchSize

public int getBatchSize()

getRate

public int getRate()

getDestinationsCount

public int getDestinationsCount()

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)

getTimeout

public long getTimeout()

setTimeout

public void setTimeout(long time)

getClientId

public String getClientId()

getSubscriptionId

public String getSubscriptionId()

getSelector

public String getSelector()

getDestination

public String getDestination()

usePersistentMessages

public boolean usePersistentMessages()

isTransacted

public boolean isTransacted()

isPubSub

public boolean isPubSub()

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