当前位置：源码 > Java源码 >

Java源码示例：org.apache.rocketmq.common.protocol.body.BrokerStatsData

示例1

public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis)
    throws MQClientException, RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException,
    InterruptedException {
    ViewBrokerStatsDataRequestHeader requestHeader = new ViewBrokerStatsDataRequestHeader();
    requestHeader.setStatsName(statsName);
    requestHeader.setStatsKey(statsKey);

    RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.VIEW_BROKER_STATS_DATA, requestHeader);

    RemotingCommand response = this.remotingClient
        .invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), brokerAddr), request, timeoutMillis);
    assert response != null;
    switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            byte[] body = response.getBody();
            if (body != null) {
                return BrokerStatsData.decode(body, BrokerStatsData.class);
            }
        }
        default:
            break;
    }

    throw new MQClientException(response.getCode(), response.getRemark());
}

示例2

public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis)
    throws MQClientException, RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException,
    InterruptedException {
    ViewBrokerStatsDataRequestHeader requestHeader = new ViewBrokerStatsDataRequestHeader();
    requestHeader.setStatsName(statsName);
    requestHeader.setStatsKey(statsKey);

    RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.VIEW_BROKER_STATS_DATA, requestHeader);

    RemotingCommand response = this.remotingClient
        .invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), brokerAddr), request, timeoutMillis);
    assert response != null;
    switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            byte[] body = response.getBody();
            if (body != null) {
                return BrokerStatsData.decode(body, BrokerStatsData.class);
            }
        }
        default:
            break;
    }

    throw new MQClientException(response.getCode(), response.getRemark());
}

示例3

public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis)
    throws MQClientException, RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException,
    InterruptedException {
    ViewBrokerStatsDataRequestHeader requestHeader = new ViewBrokerStatsDataRequestHeader();
    requestHeader.setStatsName(statsName);
    requestHeader.setStatsKey(statsKey);

    RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.VIEW_BROKER_STATS_DATA, requestHeader);

    String acturallyAddr = getActurallyBrokerAddr(brokerAddr);
    RemotingCommand response = this.remotingClient
        .invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), acturallyAddr), request, timeoutMillis);
    assert response != null;
    switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            byte[] body = response.getBody();
            if (body != null) {
                return BrokerStatsData.decode(body, BrokerStatsData.class);
            }
        }
        default:
            break;
    }

    throw new MQClientException(response.getCode(), response.getRemark());
}

示例4

public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis)
    throws MQClientException, RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException,
    InterruptedException {
    ViewBrokerStatsDataRequestHeader requestHeader = new ViewBrokerStatsDataRequestHeader();
    requestHeader.setStatsName(statsName);
    requestHeader.setStatsKey(statsKey);

    RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.VIEW_BROKER_STATS_DATA, requestHeader);

    RemotingCommand response = this.remotingClient
        .invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), brokerAddr), request, timeoutMillis);
    assert response != null;
    switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            byte[] body = response.getBody();
            if (body != null) {
                return BrokerStatsData.decode(body, BrokerStatsData.class);
            }
        }
        default:
            break;
    }

    throw new MQClientException(response.getCode(), response.getRemark());
}

示例5

public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis)
    throws MQClientException, RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException,
    InterruptedException {
    ViewBrokerStatsDataRequestHeader requestHeader = new ViewBrokerStatsDataRequestHeader();
    requestHeader.setStatsName(statsName);
    requestHeader.setStatsKey(statsKey);

    RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.VIEW_BROKER_STATS_DATA, requestHeader);

    RemotingCommand response = this.remotingClient
        .invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), brokerAddr), request, timeoutMillis);
    assert response != null;
    switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            byte[] body = response.getBody();
            if (body != null) {
                return BrokerStatsData.decode(body, BrokerStatsData.class);
            }
        }
        default:
            break;
    }

    throw new MQClientException(response.getCode(), response.getRemark());
}

示例6

public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis)
    throws MQClientException, RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException,
    InterruptedException {
    ViewBrokerStatsDataRequestHeader requestHeader = new ViewBrokerStatsDataRequestHeader();
    requestHeader.setStatsName(statsName);
    requestHeader.setStatsKey(statsKey);

    RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.VIEW_BROKER_STATS_DATA, requestHeader);

    RemotingCommand response = this.remotingClient
        .invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), brokerAddr), request, timeoutMillis);
    assert response != null;
    switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            byte[] body = response.getBody();
            if (body != null) {
                return BrokerStatsData.decode(body, BrokerStatsData.class);
            }
        }
        default:
            break;
    }

    throw new MQClientException(response.getCode(), response.getRemark());
}

示例7

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例8

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例9

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例10

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例11

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例12

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例13

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例14

public static long compute24HourSum(BrokerStatsData bsd) {
    if (bsd.getStatsDay().getSum() != 0) {
        return bsd.getStatsDay().getSum();
    }

    if (bsd.getStatsHour().getSum() != 0) {
        return bsd.getStatsHour().getSum();
    }

    if (bsd.getStatsMinute().getSum() != 0) {
        return bsd.getStatsMinute().getSum();
    }

    return 0;
}

示例15

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.defaultMQAdminExtImpl.viewBrokerStatsData(brokerAddr, statsName, statsKey);
}

示例16

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.mqClientInstance.getMQClientAPIImpl().viewBrokerStatsData(brokerAddr, statsName, statsKey, timeoutMillis);
}

示例17

BrokerStatsData viewBrokerStatsData(final String brokerAddr, final String statsName, final String statsKey)
throws RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException, MQClientException,
InterruptedException;

示例18

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.defaultMQAdminExtImpl.viewBrokerStatsData(brokerAddr, statsName, statsKey);
}

示例19

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.mqClientInstance.getMQClientAPIImpl().viewBrokerStatsData(brokerAddr, statsName, statsKey, timeoutMillis);
}

示例20

BrokerStatsData viewBrokerStatsData(final String brokerAddr, final String statsName, final String statsKey)
throws RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException, MQClientException,
InterruptedException;

示例21

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.defaultMQAdminExtImpl.viewBrokerStatsData(brokerAddr, statsName, statsKey);
}

示例22

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.mqClientInstance.getMQClientAPIImpl().viewBrokerStatsData(brokerAddr, statsName, statsKey, timeoutMillis);
}

示例23

BrokerStatsData viewBrokerStatsData(final String brokerAddr, final String statsName, final String statsKey)
throws RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException, MQClientException,
InterruptedException;

示例24

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
                                           String statsKey) throws RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return defaultMQAdminExt.viewBrokerStatsData(brokerAddr, statsName, statsKey);
}

示例25

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.defaultMQAdminExtImpl.viewBrokerStatsData(brokerAddr, statsName, statsKey);
}

示例26

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.mqClientInstance.getMQClientAPIImpl().viewBrokerStatsData(brokerAddr, statsName, statsKey, timeoutMillis);
}

示例27

BrokerStatsData viewBrokerStatsData(final String brokerAddr, final String statsName, final String statsKey)
throws RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException, MQClientException,
InterruptedException;

示例28

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.defaultMQAdminExtImpl.viewBrokerStatsData(brokerAddr, statsName, statsKey);
}

示例29

@Override
public BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
    String statsKey) throws RemotingConnectException,
    RemotingSendRequestException, RemotingTimeoutException, MQClientException, InterruptedException {
    return this.mqClientInstance.getMQClientAPIImpl().viewBrokerStatsData(brokerAddr, statsName, statsKey, timeoutMillis);
}

示例30

BrokerStatsData viewBrokerStatsData(final String brokerAddr, final String statsName, final String statsKey)
throws RemotingConnectException, RemotingSendRequestException, RemotingTimeoutException, MQClientException,
InterruptedException;

Java源码示例：org.apache.rocketmq.common.protocol.body.BrokerStatsData

微信关注