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

Connection.getAddress介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-amqp

@Override
public InetAddress getAddress() {
  return this.delegate.getAddress();
}

代码示例来源：origin: org.springframework.amqp/spring-rabbit

@Override
public InetAddress getAddress() {
  return this.delegate.getAddress();
}

代码示例来源：origin: com.github.combinedmq/combinedmq

@Override
public InetAddress getAddress() {
  return connection.getAddress();
}

代码示例来源：origin: zstackio/zstack

logger.debug(String.format("rabbitmq connection is established on %s", conn.getAddress()));

代码示例来源：origin: awin/rabbiteasy

/**
 * Gets the host of the used broker.
 * 
 * @return the host
 */
public String getHost() {
  return channel.getConnection().getAddress().getHostName();
}

代码示例来源：origin: awin/rabbiteasy

@Override
public void onConnectionEstablished(Connection connection) {
  String hostName = connection.getAddress().getHostName();
  LOGGER.info("Connection established to {}", hostName);
  List<ConsumerHolder> enabledConsumerHolders = filterConsumersForEnabledFlag(true);
  LOGGER.info("Activating {} enabled consumers", enabledConsumerHolders.size());
  try {
    activateConsumers(enabledConsumerHolders);
    LOGGER.info("Activated enabled consumers");
  } catch (IOException e) {
    LOGGER.error("Failed to activate enabled consumers", e);
    deactivateConsumers(enabledConsumerHolders);
  }
}

代码示例来源：origin: net.jodah/lyra

@Override
 public Connection call() throws IOException, TimeoutException {
  log.info("{} connection {} to {}", recovery ? "Recovering" : "Creating", connectionName,
    options.getAddresses());
  ConnectionFactory cxnFactory = options.getConnectionFactory();
  Connection connection =
    cxnFactory.newConnection(consumerThreadPool, options.getAddresses(), connectionName);
  final String amqpAddress =
    String.format("%s://%s:%s/%s", cxnFactory.isSSL() ? "amqps" : "amqp",
      connection.getAddress().getHostAddress(), connection.getPort(),
      "/".equals(cxnFactory.getVirtualHost()) ? "" : cxnFactory.getVirtualHost());
  log.info("{} connection {} to {}", recovery ? "Recovered" : "Created", connectionName,
    amqpAddress);
  return connection;
 }
}, recurringPolicy, recurringStats, recurringExceptions, true, false);

代码示例来源：origin: jhalterman/lyra

@Override
 public Connection call() throws IOException, TimeoutException {
  log.info("{} connection {} to {}", recovery ? "Recovering" : "Creating", connectionName,
    options.getAddresses());
  ConnectionFactory cxnFactory = options.getConnectionFactory();
  Connection connection =
    cxnFactory.newConnection(consumerThreadPool, options.getAddresses(), connectionName);
  final String amqpAddress =
    String.format("%s://%s:%s/%s", cxnFactory.isSSL() ? "amqps" : "amqp",
      connection.getAddress().getHostAddress(), connection.getPort(),
      "/".equals(cxnFactory.getVirtualHost()) ? "" : cxnFactory.getVirtualHost());
  log.info("{} connection {} to {}", recovery ? "Recovered" : "Created", connectionName,
    amqpAddress);
  return connection;
 }
}, recurringPolicy, recurringStats, recurringExceptions, true, false);

代码示例来源：origin: yanghua/banyan

private void open() {
  if (this.isOpen())
    return;
  try {
    this.channel = this.connection.createChannel();
    context.setChannel(this.channel);
  } catch (IOException e) {
    logger.error("create channel error, connection host : " + this.connection.getAddress().getHostAddress()
        + " connection port : " + this.connection.getPort(), e);
    throw new RuntimeException(e);
  }
  carryEventBus = new EventBus("carryEventBus");
  context.setCarryEventBus(carryEventBus);
  context.setConfigManager(this.configManager);
  context.setConnection(this.connection);
  this.isOpen.compareAndSet(false, true);
  this.componentEventBus.post(new ClientInitedEvent());
}

代码示例来源：origin: yanghua/banyan

protected MessageContext initMessageContext() {
  MessageContext msgCtx = new MessageContext();
  msgCtx.setConfigManager(this.context.getConfigManager());
  msgCtx.setChannel(this.context.getChannel());
  msgCtx.setHost(this.context.getConnection().getAddress().getHostAddress());
  msgCtx.setCarryEventBus(this.context.getCarryEventBus());
  return msgCtx;
}

代码示例来源：origin: com.springsource.insight.plugins/insight-plugin-rabbitmq-client

protected void applyConnectionData(Operation op, Connection conn) {
  InetAddress    address = conn.getAddress();
  String        host = address.getHostAddress();
  int			port = conn.getPort();
  final String connectionUrl;
  if (conn instanceof AMQConnection) {
    connectionUrl = conn.toString();
  } else {
    connectionUrl = "amqp://" + host + ":" + port; 
  }
  
  op.put("host", host);
  op.put("port", port);
  op.put("connectionUrl", connectionUrl);
  
  //try to extract server version
  String serverVersion = getVersion(conn.getServerProperties());
  op.putAnyNonEmpty("serverVersion", serverVersion);
  
  //try to extract client version
  String    clientVersion = getVersion(conn.getClientProperties());
  op.putAnyNonEmpty("clientVersion", clientVersion);
}