com.hazelcast.nio.Address.readData()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(182)

本文整理了Java中com.hazelcast.nio.Address.readData()方法的一些代码示例,展示了Address.readData()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Address.readData()方法的具体详情如下:
包路径:com.hazelcast.nio.Address
类名称:Address
方法名:readData

Address.readData介绍

暂无

代码示例

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
protected void readInternal(final ObjectDataInput in) throws IOException {
  masterAddress = new Address();
  masterAddress.readData(in);
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
protected void readInternal(ObjectDataInput in) throws IOException {
  newTargetAddress = new Address();
  newTargetAddress.readData(in);
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
protected void readInternal(ObjectDataInput in) throws IOException {
  newTargetAddress = new Address();
  newTargetAddress.readData(in);
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
public void readData(ObjectDataInput in)
    throws IOException {
  super.readData(in);
  address = new Address();
  address.readData(in);
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
public void readData(ObjectDataInput in)
    throws IOException {
  super.readData(in);
  address = new Address();
  address.readData(in);
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
public void readData(final ObjectDataInput in) throws IOException {
  localAddress = new Address();
  localAddress.readData(in);
  boolean hasTarget = in.readBoolean();
  if (hasTarget) {
    targetAddress = new Address();
    targetAddress.readData(in);
  }
  reply = in.readBoolean();
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
public void readData(final ObjectDataInput in) throws IOException {
  localAddress = new Address();
  localAddress.readData(in);
  boolean hasTarget = in.readBoolean();
  if (hasTarget) {
    targetAddress = new Address();
    targetAddress.readData(in);
  }
  reply = in.readBoolean();
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
protected void readInternal(ObjectDataInput in) throws IOException {
  super.readInternal(in);
  initiator = new Address();
  initiator.readData(in);
  txnId = in.readUTF();
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
public void readData(ObjectDataInput in) throws IOException {
  this.partitionId = in.readInt();
  this.lostReplicaIndex = in.readInt();
  this.eventSource = new Address();
  this.eventSource.readData(in);
}

代码示例来源:origin: hazelcast/hazelcast-jet

private static PartitionReplica readPartitionReplicaLegacy(ObjectDataInput in) throws IOException {
  Address address = new Address();
  address.readData(in);
  String uuid = in.readUTF();
  return new PartitionReplica(address, uuid);
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
protected void readInternal(ObjectDataInput in) throws IOException {
  super.readInternal(in);
  initiator = new Address();
  initiator.readData(in);
  txnId = in.readUTF();
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
public void readData(ObjectDataInput in) throws IOException {
  this.partitionId = in.readInt();
  this.lostReplicaIndex = in.readInt();
  this.eventSource = new Address();
  this.eventSource.readData(in);
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
public void readData(ObjectDataInput in) throws IOException {
  id = in.readUTF();
  serviceName = in.readUTF();
  topic = in.readUTF();
  subscriber = new Address();
  subscriber.readData(in);
  filter = in.readObject();
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
public void readData(ObjectDataInput in) throws IOException {
  name = in.readUTF();
  eventType = ItemEventType.getByType(in.readInt());
  caller = new Address();
  caller.readData(in);
  data = in.readData();
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
public void readData(ObjectDataInput in) throws IOException {
  name = in.readUTF();
  eventType = ItemEventType.getByType(in.readInt());
  caller = new Address();
  caller.readData(in);
  data = in.readData();
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
protected void readInternal(ObjectDataInput in) throws IOException {
  super.readInternal(in);
  stateChange = in.readObject();
  initiator = new Address();
  initiator.readData(in);
  txnId = in.readUTF();
  isTransient = in.readBoolean();
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
public void readData(ObjectDataInput in) throws IOException {
  name = in.readUTF();
  eventType = ItemEventType.getByType(in.readInt());
  caller = new Address();
  caller.readData(in);
  data = in.readData();
}

代码示例来源:origin: com.hazelcast/hazelcast-all

@Override
public void readData(ObjectDataInput in) throws IOException {
  name = in.readUTF();
  eventType = ItemEventType.getByType(in.readInt());
  caller = new Address();
  caller.readData(in);
  data = in.readData();
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
public void readData(ObjectDataInput in) throws IOException {
  id = in.readUTF();
  serviceName = in.readUTF();
  topic = in.readUTF();
  subscriber = new Address();
  subscriber.readData(in);
  filter = in.readObject();
}

代码示例来源:origin: hazelcast/hazelcast-jet

@Override
protected void readInternal(ObjectDataInput in) throws IOException {
  super.readInternal(in);
  stateChange = in.readObject();
  initiator = new Address();
  initiator.readData(in);
  txnId = in.readUTF();
  isTransient = in.readBoolean();
}

相关文章