public class ConsumerConfig extends Object
| 限定符和类型 | 字段和说明 |
|---|---|
static long |
NONE_ACK_TIMEOUT |
static int |
NONE_BATCH_SIZE |
static int |
NONE_BROADCAST_INDEX_EXPIRE_TIME |
| 构造器和说明 |
|---|
ConsumerConfig() |
public static final int NONE_BATCH_SIZE
public static final long NONE_ACK_TIMEOUT
public static final int NONE_BROADCAST_INDEX_EXPIRE_TIME
public ConsumerConfig copy()
public String getAppFullName()
public String getApp()
public void setApp(String app)
public void setGroup(String group)
public String getGroup()
public void setBatchSize(int batchSize)
public int getBatchSize()
public void setAckTimeout(long ackTimeout)
public long getAckTimeout()
public void setTimeout(long timeout)
public long getTimeout()
public void setPollTimeout(long pollTimeout)
public long getPollTimeout()
public long getLongPollTimeout()
public void setLongPollTimeout(long longPollTimeout)
public long getInterval()
public void setInterval(long interval)
public long getIdleInterval()
public void setIdleInterval(long idleInterval)
public long getSessionTimeout()
public void setSessionTimeout(long sessionTimeout)
public void setThread(int thread)
public int getThread()
public void setFailover(boolean failover)
public boolean isFailover()
public void setLoadBalance(boolean loadBalance)
public boolean isLoadBalance()
public void setLoadBalanceType(String loadBalanceType)
public String getLoadBalanceType()
public String getBroadcastGroup()
public void setBroadcastGroup(String broadcastGroup)
public void setBroadcastLocalPath(String broadcastLocalPath)
public String getBroadcastLocalPath()
public int getBroadcastPersistInterval()
public void setBroadcastPersistInterval(int broadcastPersistInterval)
public int getBroadcastIndexExpireTime()
public void setBroadcastIndexExpireTime(int broadcastIndexExpireTime)
Copyright © 2020 Joyqueue Community. All rights reserved.