org.apache.qpid.topic
Class Config
java.lang.Object
org.apache.qpid.config.AbstractConfig
org.apache.qpid.topic.Config
- All Implemented Interfaces:
- ConnectorConfig
public class Config
- extends AbstractConfig
- implements ConnectorConfig
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Config
public Config()
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