本文整理了Java中org.wso2.siddhi.core.util.transport.Option.isStatic()
方法的一些代码示例,展示了Option.isStatic()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Option.isStatic()
方法的具体详情如下:
包路径:org.wso2.siddhi.core.util.transport.Option
类名称:Option
方法名:isStatic
暂无
代码示例来源:origin: org.wso2.extension.siddhi.io.http/siddhi-io-http
/**
* This method will be called before the processing method.
* Intention to establish connection to publish event.
* such that the system will take care retrying for connection
*/
@Override
public void connect() {
if (publisherURLOption.isStatic()) {
log.info(streamID + " has successfully connected to " + publisherURL);
}
}
代码示例来源:origin: org.wso2.extension.siddhi.io.http/siddhi-io-http
/**
* This method will be called when events need to be published via this sink
*
* @param payload payload of the event based on the supported event class exported by the extensions
* @param dynamicOptions holds the dynamic options of this sink and Use this object to obtain dynamic options.
*/
@Override
public void publish(Object payload, DynamicOptions dynamicOptions) {
//get the dynamic parameter
String headers = httpHeaderOption.getValue(dynamicOptions);
List<Header> headersList = HttpSinkUtil.getHeaders(headers);
if (publisherURLOption.isStatic()) {
publisherURL = publisherURLOption.getValue();
} else {
publisherURL = publisherURLOption.getValue(dynamicOptions);
}
if (authType.equals(HttpConstants.BASIC_AUTH) || authType.equals(HttpConstants.NO_AUTH)) {
sendRequest(payload, dynamicOptions, headersList, HttpConstants.MAXIMUM_TRY_COUNT);
} else {
sendOauthRequest(payload, dynamicOptions, headersList);
}
}
代码示例来源:origin: org.wso2.extension.siddhi.io.email/siddhi-io-email
if ((attachmentOption != null) && (!attachmentOption.isStatic())) {
attachments =
Arrays.asList(attachmentOption.getValue(dynamicOptions).split(EmailConstants.COMMA_SEPERATOR));
代码示例来源:origin: org.wso2.extension.siddhi.io.http/siddhi-io-http
void initClientConnector(DynamicOptions dynamicOptions) {
if (publisherURLOption.isStatic()) {
publisherURL = publisherURLOption.getValue();
} else {
代码示例来源:origin: org.wso2.extension.siddhi.io.http/siddhi-io-http
private int sendRequest(Object payload, DynamicOptions dynamicOptions, List<Header> headersList, int tryCount) {
if (!publisherURLOption.isStatic()) {
super.initClientConnector(dynamicOptions);
代码示例来源:origin: org.wso2.extension.siddhi.io.http/siddhi-io-http
private int sendRequest(Object payload, DynamicOptions dynamicOptions, List<Header> headersList) {
if (publisherURLOption.isStatic()) {
if (clientConnector != null) {
clientConnector.close();
代码示例来源:origin: org.wso2.extension.siddhi.io.email/siddhi-io-email
if (attachmentOption.isStatic()) {
attachments = Arrays.asList(attachmentOption.getValue().split(EmailConstants.COMMA_SEPERATOR));
代码示例来源:origin: org.wso2.extension.siddhi.io.http/siddhi-io-http
authType = HttpConstants.NO_AUTH;
if (publisherURLOption.isStatic()) {
initClientConnector(null);
内容来源于网络,如有侵权,请联系作者删除!