acquireMessageBufferPosition(final int messageLength, final int flags) | com.latencybusters.lbm.LBMSource | |
addSourceCallback(LBMSourceEventCallback cb) | com.latencybusters.lbm.LBMSource | |
addSourceCallback(LBMSourceEventCallback cb, Object cbArg) | com.latencybusters.lbm.LBMSource | |
close() | com.latencybusters.lbm.LBMSource | |
createChannel(long channelNumber) | com.latencybusters.lbm.LBMSource | |
deleteChannel(LBMSourceChannelInfo channelInfo) | com.latencybusters.lbm.LBMSource | |
dumpAttributeList() | com.latencybusters.lbm.LBMSource | |
finalize() | com.latencybusters.lbm.LBMSource | protected |
flush() | com.latencybusters.lbm.LBMSource | |
getAttributeValue(String attributeName) | com.latencybusters.lbm.LBMSource | |
getInflight(int type) | com.latencybusters.lbm.LBMSource | |
getInflightEx(int type) | com.latencybusters.lbm.LBMSource | |
getMessagesBuffer() | com.latencybusters.lbm.LBMSource | |
getStatistics() | com.latencybusters.lbm.LBMSource | |
isClosed() | com.latencybusters.lbm.LBMSource | |
LBMSource(LBMContext lbmctx, LBMTopic lbmtopic) | com.latencybusters.lbm.LBMSource | |
LBMSource(LBMContext lbmctx, LBMTopic lbmtopic, LBMSourceEventCallback cb, Object cbArg) | com.latencybusters.lbm.LBMSource | |
LBMSource(LBMContext lbmctx, LBMTopic lbmtopic, LBMEventQueue lbmevq) | com.latencybusters.lbm.LBMSource | |
LBMSource(LBMContext lbmctx, LBMTopic lbmtopic, LBMSourceEventCallback cb, Object cbArg, LBMEventQueue lbmevq) | com.latencybusters.lbm.LBMSource | |
load(InputStream inStream) | com.latencybusters.lbm.LBMSource | |
messageBuffersCancel() | com.latencybusters.lbm.LBMSource | |
messageBuffersComplete() | com.latencybusters.lbm.LBMSource | |
messageBuffersCompleteAndAcquirePosition(final int messageLength, final int flags) | com.latencybusters.lbm.LBMSource | |
onResponse(LBMRequest lbmreq, LBMMessage lbmmsg) | com.latencybusters.lbm.LBMSource | protected |
onSourceEvent(LBMSourceEvent sourceEvent) | com.latencybusters.lbm.LBMSource | protected |
removeSourceCallback(LBMSourceEventCallback cb) | com.latencybusters.lbm.LBMSource | |
removeSourceCallback(LBMSourceEventCallback cb, Object cbArg) | com.latencybusters.lbm.LBMSource | |
resetStatistics() | com.latencybusters.lbm.LBMSource | |
send(byte[] message, int messageLength, int flags) | com.latencybusters.lbm.LBMSource | |
send(byte[] message, int messageLength, int flags, Object cbArg) | com.latencybusters.lbm.LBMSource | |
send(byte[] message, int messageLength, int flags, LBMSourceSendExInfo exinfo) | com.latencybusters.lbm.LBMSource | |
send(ByteBuffer message, int startPosition, int messageLength, int flags) | com.latencybusters.lbm.LBMSource | |
send(ByteBuffer message, int startPosition, int messageLength, int flags, Object cbArg) | com.latencybusters.lbm.LBMSource | |
send(ByteBuffer message, int startPosition, int messageLength, int flags, LBMSourceSendExInfo exinfo) | com.latencybusters.lbm.LBMSource | |
send(LBMRequest lbmreq, int flags) | com.latencybusters.lbm.LBMSource | |
send(LBMRequest lbmreq, LBMEventQueue lbmevq, int flags) | com.latencybusters.lbm.LBMSource | |
send(LBMRequest lbmreq, LBMEventQueue lbmevq, int flags, LBMSourceSendExInfo exinfo) | com.latencybusters.lbm.LBMSource | |
send(LBMRequest lbmreq, int flags, LBMSourceSendExInfo exinfo) | com.latencybusters.lbm.LBMSource | |
sendStatistics(ByteBuffer message, int messageLength, int statsType) | com.latencybusters.lbm.LBMSource | |
setAttributeValue(String attributeName, String attributeValue) | com.latencybusters.lbm.LBMSource | |
setInflight(int type, LBMSetInflightCallback setInflightCb, Object clientd) | com.latencybusters.lbm.LBMSource | |
setInflightEx(int type, LBMSetInflightCallback setInflightCb, Object clientd) | com.latencybusters.lbm.LBMSource | |
setProperty(String attributeName, String attributeValue) | com.latencybusters.lbm.LBMSource | |
setUMEMessageStable(long sqn) | com.latencybusters.lbm.LBMSource | |
umederegister() | com.latencybusters.lbm.LBMSource | |
unblock() | com.latencybusters.lbm.LBMSource | |