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

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

本文整理了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

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

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

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

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

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

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

  1. @Override
  2. public void readData(ObjectDataInput in)
  3. throws IOException {
  4. super.readData(in);
  5. address = new Address();
  6. address.readData(in);
  7. }

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

  1. @Override
  2. public void readData(ObjectDataInput in)
  3. throws IOException {
  4. super.readData(in);
  5. address = new Address();
  6. address.readData(in);
  7. }

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

  1. @Override
  2. public void readData(final ObjectDataInput in) throws IOException {
  3. localAddress = new Address();
  4. localAddress.readData(in);
  5. boolean hasTarget = in.readBoolean();
  6. if (hasTarget) {
  7. targetAddress = new Address();
  8. targetAddress.readData(in);
  9. }
  10. reply = in.readBoolean();
  11. }

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

  1. @Override
  2. public void readData(final ObjectDataInput in) throws IOException {
  3. localAddress = new Address();
  4. localAddress.readData(in);
  5. boolean hasTarget = in.readBoolean();
  6. if (hasTarget) {
  7. targetAddress = new Address();
  8. targetAddress.readData(in);
  9. }
  10. reply = in.readBoolean();
  11. }

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

  1. @Override
  2. protected void readInternal(ObjectDataInput in) throws IOException {
  3. super.readInternal(in);
  4. initiator = new Address();
  5. initiator.readData(in);
  6. txnId = in.readUTF();
  7. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. this.partitionId = in.readInt();
  4. this.lostReplicaIndex = in.readInt();
  5. this.eventSource = new Address();
  6. this.eventSource.readData(in);
  7. }

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

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

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

  1. @Override
  2. protected void readInternal(ObjectDataInput in) throws IOException {
  3. super.readInternal(in);
  4. initiator = new Address();
  5. initiator.readData(in);
  6. txnId = in.readUTF();
  7. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. this.partitionId = in.readInt();
  4. this.lostReplicaIndex = in.readInt();
  5. this.eventSource = new Address();
  6. this.eventSource.readData(in);
  7. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. id = in.readUTF();
  4. serviceName = in.readUTF();
  5. topic = in.readUTF();
  6. subscriber = new Address();
  7. subscriber.readData(in);
  8. filter = in.readObject();
  9. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. name = in.readUTF();
  4. eventType = ItemEventType.getByType(in.readInt());
  5. caller = new Address();
  6. caller.readData(in);
  7. data = in.readData();
  8. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. name = in.readUTF();
  4. eventType = ItemEventType.getByType(in.readInt());
  5. caller = new Address();
  6. caller.readData(in);
  7. data = in.readData();
  8. }

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

  1. @Override
  2. protected void readInternal(ObjectDataInput in) throws IOException {
  3. super.readInternal(in);
  4. stateChange = in.readObject();
  5. initiator = new Address();
  6. initiator.readData(in);
  7. txnId = in.readUTF();
  8. isTransient = in.readBoolean();
  9. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. name = in.readUTF();
  4. eventType = ItemEventType.getByType(in.readInt());
  5. caller = new Address();
  6. caller.readData(in);
  7. data = in.readData();
  8. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. name = in.readUTF();
  4. eventType = ItemEventType.getByType(in.readInt());
  5. caller = new Address();
  6. caller.readData(in);
  7. data = in.readData();
  8. }

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

  1. @Override
  2. public void readData(ObjectDataInput in) throws IOException {
  3. id = in.readUTF();
  4. serviceName = in.readUTF();
  5. topic = in.readUTF();
  6. subscriber = new Address();
  7. subscriber.readData(in);
  8. filter = in.readObject();
  9. }

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

  1. @Override
  2. protected void readInternal(ObjectDataInput in) throws IOException {
  3. super.readInternal(in);
  4. stateChange = in.readObject();
  5. initiator = new Address();
  6. initiator.readData(in);
  7. txnId = in.readUTF();
  8. isTransient = in.readBoolean();
  9. }

相关文章