public class MRvcmqSession extends MRvcmSession
m_daemon, m_enableHttp, m_host, m_isRvaSession, m_network, m_port, m_rvdTransport, m_service, m_sessionName, m_tibrvqueue, m_tibrvtransport, m_TransportName
Constructor and Description |
---|
MRvcmqSession(java.lang.String sessionName,
java.lang.String cmqName,
java.lang.String service,
java.lang.String network,
java.lang.String daemon,
int schedulerWeight,
int schedulerHeartbeat,
int schedulerActivation,
int workerWeight,
int workerTasks) |
Modifier and Type | Method and Description |
---|---|
protected com.tibco.tibrv.TibrvTransport |
createRvTransport() |
java.lang.String |
getCmqName()
Return the CM/Q handshake name
|
double |
getCompleteTime() |
double |
getSchedulerActivation()
Return the amount of time ( in milliseconds ) since the
the last heartbeat from this scheduler is heard, and before a new scheduler is
elected ( based on weight ).
|
double |
getSchedulerHeartbeat()
Return the scheduler heartbeat interval ( in milliseconds )
|
int |
getSchedulerWeight()
Return the scheduler weight
|
int |
getWorkerTasks() |
int |
getWorkerWeight() |
void |
setCompleteTime(double comptime) |
void |
setTaskBacklogLimitInBytes(int byteLimit) |
void |
setTaskBacklogLimitInMessages(int msgLimit) |
createRvdTransport, destroy, getCmName, getDefaultTimeLimit, getLedgerFile, getRelayAgent, getSyncLedger, requiresOldMsgs
initRvTransport
getDaemon, getEmbeddedTibrvTransport, getHost, getNetwork, getPort, getService, getSessionName, getTibrvQueue, getTibrvTransport, isRvaSession, setTransportName
public MRvcmqSession(java.lang.String sessionName, java.lang.String cmqName, java.lang.String service, java.lang.String network, java.lang.String daemon, int schedulerWeight, int schedulerHeartbeat, int schedulerActivation, int workerWeight, int workerTasks)
public int getSchedulerWeight()
public double getSchedulerHeartbeat()
public double getSchedulerActivation()
public java.lang.String getCmqName()
public double getCompleteTime()
public int getWorkerWeight()
public int getWorkerTasks()
public void setCompleteTime(double comptime) throws com.tibco.tibrv.TibrvException
com.tibco.tibrv.TibrvException
protected com.tibco.tibrv.TibrvTransport createRvTransport() throws com.tibco.tibrv.TibrvException
createRvTransport
in class MRvcmSession
com.tibco.tibrv.TibrvException
public void setTaskBacklogLimitInBytes(int byteLimit) throws MException
MException
public void setTaskBacklogLimitInMessages(int msgLimit) throws MException
MException