org.apache.dubbo.common.utils.Assert.notNull()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(167)

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

Assert.notNull介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-dubbo

public DecodeableRpcResult(Channel channel, Response response, InputStream is, Invocation invocation, byte id) {
  Assert.notNull(channel, "channel == null");
  Assert.notNull(response, "response == null");
  Assert.notNull(is, "inputStream == null");
  this.channel = channel;
  this.response = response;
  this.inputStream = is;
  this.invocation = invocation;
  this.serializationType = id;
}

代码示例来源:origin: apache/incubator-dubbo

public DecodeableRpcInvocation(Channel channel, Request request, InputStream is, byte id) {
  Assert.notNull(channel, "channel == null");
  Assert.notNull(request, "request == null");
  Assert.notNull(is, "inputStream == null");
  this.channel = channel;
  this.request = request;
  this.inputStream = is;
  this.serializationType = id;
}

代码示例来源:origin: apache/incubator-dubbo

public DecodeableRpcInvocation(Channel channel, Request request, InputStream is, byte id) {
  Assert.notNull(channel, "channel == null");
  Assert.notNull(request, "request == null");
  Assert.notNull(is, "inputStream == null");
  this.channel = channel;
  this.request = request;
  this.inputStream = is;
  this.serializationType = id;
}

代码示例来源:origin: apache/incubator-dubbo

/**
 * @param prefix   the prefix of Configuration Properties
 * @param beanName the binding Bean Name
 */
public DubboConfigBindingBeanPostProcessor(String prefix, String beanName) {
  Assert.notNull(prefix, "The prefix of Configuration Properties must not be null");
  Assert.notNull(beanName, "The name of bean must not be null");
  this.prefix = prefix;
  this.beanName = beanName;
}

代码示例来源:origin: apache/incubator-dubbo

/**
 * @param prefix   the prefix of Configuration Properties
 * @param beanName the binding Bean Name
 */
public DubboConfigBindingBeanPostProcessor(String prefix, String beanName) {
  Assert.notNull(prefix, "The prefix of Configuration Properties must not be null");
  Assert.notNull(beanName, "The name of bean must not be null");
  this.prefix = prefix;
  this.beanName = beanName;
}

代码示例来源:origin: apache/incubator-dubbo

protected NativeJavaObjectOutput(ObjectOutputStream out) {
  Assert.notNull(out, "output == null");
  this.outputStream = out;
}

代码示例来源:origin: apache/incubator-dubbo

public CodecAdapter(Codec codec) {
  Assert.notNull(codec, "codec == null");
  this.codec = codec;
}

代码示例来源:origin: apache/incubator-dubbo

protected AbstractChannelHandlerDelegate(ChannelHandler handler) {
  Assert.notNull(handler, "handler == null");
  this.handler = handler;
}

代码示例来源:origin: apache/incubator-dubbo

public void createEphemeral(String path, String data) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.createEphemeral(path, data);
}

代码示例来源:origin: apache/incubator-dubbo

public void delete(String path) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.delete(path);
}

代码示例来源:origin: apache/incubator-dubbo

public void close() {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.close();
}

代码示例来源:origin: apache/incubator-dubbo

public List<String> subscribeChildChanges(String path, final IZkChildListener listener) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  return client.subscribeChildChanges(path, listener);
}

代码示例来源:origin: apache/incubator-dubbo

public void unsubscribeChildChanges(String path, IZkChildListener listener) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.unsubscribeChildChanges(path, listener);
}

代码示例来源:origin: apache/incubator-dubbo

public void close() {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.close();
}

代码示例来源:origin: apache/incubator-dubbo

public void createPersistent(String path, String data) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.createPersistent(path, data);
}

代码示例来源:origin: apache/incubator-dubbo

public String getData(String path) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  return client.readData(path);
}

代码示例来源:origin: apache/incubator-dubbo

public void createEphemeral(String path, String data) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.createEphemeral(path, data);
}

代码示例来源:origin: apache/incubator-dubbo

public String getData(String path) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  return client.readData(path);
}

代码示例来源:origin: apache/incubator-dubbo

public HeaderExchangeServer(Server server) {
  Assert.notNull(server, "server == null");
  this.server = server;
  startIdleCheckTask(getUrl());
}

代码示例来源:origin: apache/incubator-dubbo

public HeaderExchangeClient(Client client, boolean startTimer) {
  Assert.notNull(client, "Client can't be null");
  this.client = client;
  this.channel = new HeaderExchangeChannel(client);
  if (startTimer) {
    URL url = client.getUrl();
    startReconnectTask(url);
    startHeartBeatTask(url);
  }
}

相关文章