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

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

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

Address.toString介绍

暂无

代码示例

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

  1. protected AbstractMember(Address address, MemberVersion version, String uuid, Map<String, Object> attributes,
  2. boolean liteMember) {
  3. assert address != null : "Address is required!";
  4. this.address = address;
  5. this.version = version;
  6. this.uuid = uuid != null ? uuid : "<" + address.toString() + ">";
  7. if (attributes != null) {
  8. this.attributes.putAll(attributes);
  9. }
  10. this.liteMember = liteMember;
  11. }

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

  1. protected AbstractMember(Address address, MemberVersion version, String uuid, Map<String, Object> attributes,
  2. boolean liteMember) {
  3. assert address != null : "Address is required!";
  4. this.address = address;
  5. this.version = version;
  6. this.uuid = uuid != null ? uuid : "<" + address.toString() + ">";
  7. if (attributes != null) {
  8. this.attributes.putAll(attributes);
  9. }
  10. this.liteMember = liteMember;
  11. }

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

  1. private String getThisNodesAddress() {
  2. Address thisAddress = context.getThisNodesAddress();
  3. return thisAddress.toString();
  4. }
  5. }

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

  1. private String getThisNodesAddress() {
  2. Address thisAddress = context.getThisNodesAddress();
  3. return thisAddress.toString();
  4. }
  5. }

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

  1. private String getThisNodesAddress() {
  2. Address thisAddress = nodeEngine.getThisAddress();
  3. return thisAddress.toString();
  4. }
  5. }

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

  1. private String getThisNodesAddress() {
  2. Address thisAddress = nodeEngine.getThisAddress();
  3. return thisAddress.toString();
  4. }
  5. }

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

  1. @ManagedAnnotation("address")
  2. @ManagedDescription("Address of the node")
  3. public String getName() {
  4. return managedObject.address.toString();
  5. }

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

  1. @ManagedAnnotation("address")
  2. @ManagedDescription("Address of the node")
  3. public String getName() {
  4. return managedObject.address.toString();
  5. }

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

  1. protected String getThisNodesAddress() {
  2. return mapServiceContext.getNodeEngine().getThisAddress().toString();
  3. }

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

  1. protected String getThisNodesAddress() {
  2. return mapServiceContext.getNodeEngine().getThisAddress().toString();
  3. }

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

  1. @ManagedAnnotation("masterAddress")
  2. @ManagedDescription("The master address of the cluster")
  3. public String getMasterAddress() {
  4. Address masterAddress = managedObject.getMasterAddress();
  5. return masterAddress == null ? null : masterAddress.toString();
  6. }
  7. }

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

  1. @ManagedAnnotation("masterAddress")
  2. @ManagedDescription("The master address of the cluster")
  3. public String getMasterAddress() {
  4. Address masterAddress = managedObject.getMasterAddress();
  5. return masterAddress == null ? null : masterAddress.toString();
  6. }
  7. }

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

  1. public void publishMultiMapEvent(String mapName, EntryEventType eventType, int numberOfEntriesAffected) {
  2. EventService eventService = nodeEngine.getEventService();
  3. Collection<EventRegistration> registrations = eventService.getRegistrations(MultiMapService.SERVICE_NAME, mapName);
  4. if (registrations.isEmpty()) {
  5. return;
  6. }
  7. Address caller = nodeEngine.getThisAddress();
  8. String source = caller.toString();
  9. MapEventData mapEventData = new MapEventData(source, mapName, caller, eventType.getType(), numberOfEntriesAffected);
  10. eventService.publishEvent(MultiMapService.SERVICE_NAME, registrations, mapEventData, mapName.hashCode());
  11. }

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

  1. public void publishMultiMapEvent(String mapName, EntryEventType eventType, int numberOfEntriesAffected) {
  2. EventService eventService = nodeEngine.getEventService();
  3. Collection<EventRegistration> registrations = eventService.getRegistrations(MultiMapService.SERVICE_NAME, mapName);
  4. if (registrations.isEmpty()) {
  5. return;
  6. }
  7. Address caller = nodeEngine.getThisAddress();
  8. String source = caller.toString();
  9. MapEventData mapEventData = new MapEventData(source, mapName, caller, eventType.getType(), numberOfEntriesAffected);
  10. eventService.publishEvent(MultiMapService.SERVICE_NAME, registrations, mapEventData, mapName.hashCode());
  11. }

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

  1. @Override
  2. public boolean ownPartition(Address address, int index, Integer partitionId) {
  3. if (!hasNode(address)) {
  4. String error = "Address does not belong to this group: " + address.toString();
  5. LOGGER.warning(error);
  6. return false;
  7. }
  8. if (containsPartition(partitionId)) {
  9. if (LOGGER.isFinestEnabled()) {
  10. LOGGER.finest("Partition[" + partitionId + "] is already owned by this group!");
  11. }
  12. return false;
  13. }
  14. groupPartitionTable.add(index, partitionId);
  15. return nodePartitionTables.get(address).add(index, partitionId);
  16. }

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

  1. private void addEventToQueryCache(Record record) {
  2. EntryEventData eventData = new EntryEventData(thisAddress.toString(), name, thisAddress,
  3. record.getKey(), mapServiceContext.toData(record.getValue()),
  4. null, null, ADDED.getType());
  5. mapEventPublisher.addEventToQueryCache(eventData);
  6. }

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

  1. private static void addResponse(JsonObject root, Address address, boolean success, String result, String stackTrace) {
  2. JsonObject json = new JsonObject();
  3. json.add("success", success);
  4. json.add("result", result);
  5. json.add("stackTrace", stackTrace != null ? Json.value(stackTrace) : Json.NULL);
  6. root.add(address.toString(), json);
  7. }
  8. }

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

  1. private static void addResponse(JsonObject root, Address address, boolean success, String result, String stackTrace) {
  2. JsonObject json = new JsonObject();
  3. json.add("success", success);
  4. json.add("result", result);
  5. json.add("stackTrace", stackTrace != null ? Json.value(stackTrace) : Json.NULL);
  6. root.add(address.toString(), json);
  7. }
  8. }

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

  1. private void addEventToQueryCache(Record record) {
  2. EntryEventData eventData = new EntryEventData(thisAddress.toString(), name, thisAddress,
  3. record.getKey(), mapServiceContext.toData(record.getValue()),
  4. null, null, ADDED.getType());
  5. mapEventPublisher.addEventToQueryCache(eventData);
  6. }

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

  1. public final void publishEntryEvent(String multiMapName, EntryEventType eventType, Data key, Object newValue,
  2. Object oldValue) {
  3. EventService eventService = nodeEngine.getEventService();
  4. Collection<EventRegistration> registrations = eventService.getRegistrations(MultiMapService.SERVICE_NAME, multiMapName);
  5. for (EventRegistration registration : registrations) {
  6. MultiMapEventFilter filter = (MultiMapEventFilter) registration.getFilter();
  7. if (filter.getKey() == null || filter.getKey().equals(key)) {
  8. Data dataNewValue = filter.isIncludeValue() ? nodeEngine.toData(newValue) : null;
  9. Data dataOldValue = filter.isIncludeValue() ? nodeEngine.toData(oldValue) : null;
  10. Address caller = nodeEngine.getThisAddress();
  11. String source = caller.toString();
  12. EntryEventData event = new EntryEventData(source, multiMapName, caller, key, dataNewValue, dataOldValue,
  13. eventType.getType());
  14. eventService.publishEvent(MultiMapService.SERVICE_NAME, registration, event, multiMapName.hashCode());
  15. }
  16. }
  17. }
  18. }

相关文章