org.wso2.siddhi.core.util.transport.Option.isStatic()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(69)

本文整理了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

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);

相关文章

微信公众号

最新文章

更多