- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.springframework.cloud.zookeeper.discovery.ZookeeperInstance.getMetadata()
方法的一些代码示例,展示了ZookeeperInstance.getMetadata()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperInstance.getMetadata()
方法的具体详情如下:
包路径:org.springframework.cloud.zookeeper.discovery.ZookeeperInstance
类名称:ZookeeperInstance
方法名:getMetadata
暂无
代码示例来源:origin: Nepxion/Discovery
@Override
public Map<String, String> getServerMetadata(Server server) {
if (server instanceof ZookeeperServer) {
ZookeeperServer zookeeperServer = (ZookeeperServer) server;
return zookeeperServer.getInstance().getPayload().getMetadata();
}
throw new DiscoveryException("Server instance isn't the type of ZookeeperServer");
}
}
代码示例来源:origin: spring-cloud/spring-cloud-zookeeper
@Override
public Map<String, String> getMetadata() {
if (this.serviceInstance == null || this.serviceInstance.getPayload() == null) {
return Collections.emptyMap();
}
return this.serviceInstance.getPayload().getMetadata();
}
}
代码示例来源:origin: spring-cloud/spring-cloud-zookeeper
@Override
public Object getStatus(ZookeeperRegistration registration) {
ZookeeperInstance instance = registration.getServiceInstance().getPayload();
String instanceStatus = instance.getMetadata().get(INSTANCE_STATUS_KEY);
if (!StringUtils.hasText(instanceStatus)) {
instanceStatus = STATUS_UP;
}
return instanceStatus;
}
代码示例来源:origin: spring-cloud/spring-cloud-zookeeper
@SuppressWarnings("unchecked")
protected List<ZookeeperServer> getServers() {
try {
if (this.serviceDiscovery == null) {
return Collections.EMPTY_LIST;
}
Collection<ServiceInstance<ZookeeperInstance>> instances = this.serviceDiscovery
.queryForInstances(this.serviceId);
if (instances == null || instances.isEmpty()) {
return Collections.EMPTY_LIST;
}
List<ZookeeperServer> servers = new ArrayList<>();
for (ServiceInstance<ZookeeperInstance> instance : instances) {
String instanceStatus = null;
if (instance.getPayload() != null && instance.getPayload().getMetadata() != null) {
instanceStatus = instance.getPayload().getMetadata().get(INSTANCE_STATUS_KEY);
}
if (!StringUtils.hasText(instanceStatus) // backwards compatibility
|| instanceStatus.equalsIgnoreCase(STATUS_UP)) {
servers.add(new ZookeeperServer(instance));
}
}
return servers;
}
catch (Exception e) {
rethrowRuntimeException(e);
}
return Collections.EMPTY_LIST;
}
}
代码示例来源:origin: com.nepxion/discovery-plugin-framework-zookeeper
@Override
public Map<String, String> getServerMetadata(Server server) {
if (server instanceof ZookeeperServer) {
ZookeeperServer zookeeperServer = (ZookeeperServer) server;
return zookeeperServer.getInstance().getPayload().getMetadata();
}
throw new DiscoveryException("Server instance isn't the type of ZookeeperServer");
}
}
代码示例来源:origin: spring-cloud/spring-cloud-zookeeper
@Override
public void setStatus(ZookeeperRegistration registration, String status) {
ServiceInstance<ZookeeperInstance> serviceInstance = registration.getServiceInstance();
ZookeeperInstance instance = serviceInstance.getPayload();
instance.getMetadata().put(INSTANCE_STATUS_KEY, status);
try {
getServiceDiscovery().updateService(serviceInstance);
} catch (Exception e) {
ReflectionUtils.rethrowRuntimeException(e);
}
}
代码示例来源:origin: spring-cloud/spring-cloud-zookeeper
@Override
public Map<String, String> getMetadata(Server server) {
if (server instanceof ZookeeperServer) {
ZookeeperServer zookeeperServer = (ZookeeperServer) server;
ServiceInstance<ZookeeperInstance> instance = zookeeperServer.getInstance();
if (instance != null && instance.getPayload() != null) {
return instance.getPayload().getMetadata();
}
}
return super.getMetadata(server);
}
}
代码示例来源:origin: spring-cloud/spring-cloud-zookeeper
/**
* @param serviceId The service id to be used
* @param serviceInstance The zookeeper service instance described by this service instance
*/
public ZookeeperServiceInstance(String serviceId, org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance> serviceInstance) {
this.serviceId = serviceId;
this.serviceInstance = serviceInstance;
this.host = this.serviceInstance.getAddress();
this.secure = serviceInstance.getSslPort() != null;
Integer port = serviceInstance.getPort();
if (this.secure) {
port = serviceInstance.getSslPort();
}
this.port = port;
this.uri = URI.create(serviceInstance.buildUriSpec());
if (serviceInstance.getPayload() != null) {
this.metadata = serviceInstance.getPayload().getMetadata();
} else {
this.metadata = new HashMap<>();
}
}
代码示例来源:origin: org.apache.camel/camel-spring-cloud-zookeeper
@Override
public ServiceDefinition convert(ZookeeperServer source) {
return new DefaultServiceDefinition(
source.getId(),
source.getHost(),
source.getPort(),
source.getInstance().getPayload().getMetadata()
);
}
}
在 clojure/java jdbc 中,我了解到使用 getMetaData 我可以返回大量关于通过 jdbc 连接的数据库的有趣信息。这可以根据目录、架构和表名进行过滤。 (defn get-d
我一直在尝试将 Ucanacces 与 getMetaData() 一起使用,但我遇到了一些问题,当我尝试显示信息时出现此错误: Error de SQLException:net.ucanacces
我需要使用复制事件将文件从文件夹复制到 Azure BLOB 存储,并且此复制事件应仅当文件存在于特定文件夹中时运行。我使用 GETMETADATA 事件来查看文件是否存在,但我需要配置此输出,以便在
我正在使用一个简单的应用程序来帮助学习 Apache.Derby 数据库并在 Eclipse 中工作。以下代码运行正常,但 conn.getMetaData() 不会返回任何与表相关的有意义的内容 -
在 ColdFusion 10 中的组件上调用 getMetaData() 似乎会随机抛出内部 NullPointerException。虽然此异常既不会暴露也不会影响实际请求(因此对我们的应用程序本
我正在使用 confluent golang对于我的卡夫卡客户。我使用 AdminClient 在 kafka 集群中创建/删除/获取主题。这是我初始化 AdminClient 的代码 adminCl
我开始使用 typeorm。我创建了一些实体: @Table() export class User { @PrimaryColumn() name: string; @Column() passwo
我需要从下面的代码返回一个可滚动的结果集: ResultSet columnMetaData = connection.getMetaData().getColumns(null, null, "my
我正在使用 JDBC 驱动程序连接到不同的数据库类型。我的数据库的用户仅具有目录的查看权限。它适用于 hive/teradata,但不适用于 Oracle。 使用 Oracle,我可以检索架构,但不能
有没有办法将从 getExportedKeys() 返回的 ResultSet 对象设置为 TYPE_SCROLL_SENSITIVE?我知道准备好的语句可以初始化为此值,但是从其他方法(例如 get
我正在尝试获取当前在我的应用程序中登录的当前 firebase 用户的创建日期。所以我使用下面的代码: FirebaseAuth.getInstance().getCurrentUser().getM
我一直在尝试从 Firebase 存储中获取图像文件的元数据 (md5hash),并检查它是否与用户手机上图像文件的 md5hash 不相等。问题是即使哈希值相同,我得到的结果也是不同的。 这是我尝试
本文整理了Java中org.geoserver.wms.WMSInfoImpl.getMetadata()方法的一些代码示例,展示了WMSInfoImpl.getMetadata()的具体用法。这些代
我正在尝试使用 this 在 Android 中制作一个音频应用程序视频作为指南,我在使用音频的元数据创建通知时遇到了问题。 这是我用来从设备中提取音频文件的代码: public void loadD
这是我的 sql 查询字符串: select t.create_date, concat('+', t.points) as points, case t.obtain
我在 plunker 中使用了这个 (Reflect.getMetadata('annotations',AppComponent)[0].template); 它工作正常 http://plnkr.
我想使用 Reflect 来获取我的组件的模板,但我收到了这个错误 console.log(Reflect.getMetadata('annotations',SectionsTemplateC
我在测试时发现了这个错误 https://github.com/ztytotoro/rxjs-extension/blob/master/src/decorators.ts#L20 export co
我正在处理一个用例,我想将加载到 Azure 数据库中的所有文件夹名称加载到不同的“控制”表中,但在正确使用 GetMetadata 事件时遇到问题。 此用例的目的是跳过所有旧文件夹(已加载),只关注
getMetaData() 或 getString() 函数不监听我的 SQL 查询中给出的别名。 SQL 查询成功执行。 这是我的查询的一部分:SELECT o.id as o_id, o.pack
我是一名优秀的程序员,十分优秀!