本文整理了Java中org.apache.dubbo.common.utils.Assert.notNull()
方法的一些代码示例,展示了Assert.notNull()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Assert.notNull()
方法的具体详情如下:
包路径:org.apache.dubbo.common.utils.Assert
类名称: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!