public class ConsumerConfig extends Object
| 限定符和类型 | 字段和说明 |
|---|---|
static int |
BROADCAST_AUTO_RESET_CURRENT_INDEX |
static int |
BROADCAST_AUTO_RESET_LEFT_INDEX |
static int |
BROADCAST_AUTO_RESET_RIGHT_INDEX |
static long |
NONE_ACK_TIMEOUT |
static int |
NONE_BATCH_SIZE |
static int |
NONE_BROADCAST_INDEX_EXPIRE_TIME |
static int |
NONE_THREAD |
| 构造器和说明 |
|---|
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 static final int BROADCAST_AUTO_RESET_LEFT_INDEX
public static final int BROADCAST_AUTO_RESET_RIGHT_INDEX
public static final int BROADCAST_AUTO_RESET_CURRENT_INDEX
public static final int NONE_THREAD
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 setForceAck(boolean forceAck)
public boolean isForceAck()
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)
public void setBroadcastIndexAutoReset(int broadcastIndexAutoReset)
public int getBroadcastIndexAutoReset()
Copyright © 2020 Joyqueue Community. All rights reserved.