本文整理了Java中org.jgroups.util.Util.readMessageBatch()
方法的一些代码示例,展示了Util.readMessageBatch()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Util.readMessageBatch()
方法的具体详情如下:
包路径:org.jgroups.util.Util
类名称:Util
方法名:readMessageBatch
[英]Reads a list of messages into 4 MessageBatches:
代码示例来源:origin: wildfly/wildfly
final MessageBatch[] batches=Util.readMessageBatch(dis,multicast);
for(MessageBatch batch: batches) {
if(batch != null)
代码示例来源:origin: wildfly/wildfly
protected void handleMessageBatch(DataInput in, boolean multicast) {
try {
final MessageBatch[] batches=Util.readMessageBatch(in, multicast);
final MessageBatch batch=batches[0], oob_batch=batches[1], internal_batch_oob=batches[2], internal_batch=batches[3];
processBatch(oob_batch, true, false);
processBatch(batch, false, false);
processBatch(internal_batch_oob, true, true);
processBatch(internal_batch, false, true);
}
catch(Throwable t) {
log.error(String.format(Util.getMessage("IncomingMsgFailure"), local_addr), t);
}
}
代码示例来源:origin: org.jboss.eap/wildfly-client-all
final MessageBatch[] batches=Util.readMessageBatch(dis,multicast);
for(MessageBatch batch: batches) {
if(batch != null)
代码示例来源:origin: org.jboss.eap/wildfly-client-all
protected void handleMessageBatch(DataInput in, boolean multicast) {
try {
final MessageBatch[] batches=Util.readMessageBatch(in, multicast);
final MessageBatch batch=batches[0], oob_batch=batches[1], internal_batch_oob=batches[2], internal_batch=batches[3];
processBatch(oob_batch, true, false);
processBatch(batch, false, false);
processBatch(internal_batch_oob, true, true);
processBatch(internal_batch, false, true);
}
catch(Throwable t) {
log.error(String.format(Util.getMessage("IncomingMsgFailure"), local_addr), t);
}
}
内容来源于网络,如有侵权,请联系作者删除!