test_class.declarator: extensions = new HashMap<>()
test_class.modifier: private
test_class.original_string: private Map<String, String> extensions = new HashMap<>();
test_class.type: Map<String, String>
test_class.var_name: extensions
test_class.declarator: FIVE_SECOND = 5000L
test_class.modifier: private final
test_class.original_string: private final long FIVE_SECOND = 5000L;
test_class.type: long
test_class.var_name: FIVE_SECOND
test_class.declarator: transactionTimeout = 10
test_class.modifier: private final
test_class.original_string: private final long transactionTimeout = 10;
test_class.type: long
test_class.var_name: transactionTimeout
test_class.declarator: testName = new TestName()
test_class.modifier: @Rule
      public
test_class.original_string: @Rule
      public TestName testName = new TestName();
test_class.type: TestName
test_class.var_name: testName
test_class.declarator: topicName = "com.weevent.test"
test_class.modifier: private
test_class.original_string: private String topicName = "com.weevent.test";
test_class.type: String
test_class.var_name: topicName
test_class.declarator: weEventClient
test_class.modifier: private
test_class.original_string: private IWeEventClient weEventClient;
test_class.type: IWeEventClient
test_class.var_name: weEventClient
test_class.file: weevent-client/src/test/java/com/webank/weevent/client/WeEventClientTest.java
test_class.identifier: WeEventClientTest
test_case.body: @Test
      public void testExist() throws Exception {
          boolean result = this.weEventClient.exist(this.topicName);
          Assert.assertTrue(result);
      }
test_case.class_method_signature: WeEventClientTest.testExist()
test_case.full_signature: @Test public void testExist()
test_case.identifier: testExist
test_case.invocations: exist assertTrue
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testExist()
focal_class.declarator: brokerUrl
focal_class.modifier: private final
focal_class.original_string: private final String brokerUrl;
focal_class.type: String
focal_class.var_name: brokerUrl
focal_class.declarator: brokerRestfulUrl
focal_class.modifier: private final
focal_class.original_string: private final String brokerRestfulUrl;
focal_class.type: String
focal_class.var_name: brokerRestfulUrl
focal_class.declarator: groupId
focal_class.modifier: private final
focal_class.original_string: private final String groupId;
focal_class.type: String
focal_class.var_name: groupId
focal_class.declarator: userName
focal_class.modifier: private final
focal_class.original_string: private final String userName;
focal_class.type: String
focal_class.var_name: userName
focal_class.declarator: password
focal_class.modifier: private final
focal_class.original_string: private final String password;
focal_class.type: String
focal_class.var_name: password
focal_class.declarator: brokerStompUrl = "ws://localhost:7000/weevent-broker/stomp"
focal_class.modifier: private final
focal_class.original_string: private final String brokerStompUrl = "ws://localhost:7000/weevent-broker/stomp";
focal_class.type: String
focal_class.var_name: brokerStompUrl
focal_class.declarator: subscribeIdList
focal_class.modifier: private
focal_class.original_string: private List<String> subscribeIdList;
focal_class.type: List<String>
focal_class.var_name: subscribeIdList
focal_class.declarator: httpClientHelper
focal_class.modifier: private
focal_class.original_string: private HttpClientHelper httpClientHelper;
focal_class.type: HttpClientHelper
focal_class.var_name: httpClientHelper
focal_class.declarator: transport
focal_class.modifier: private
focal_class.original_string: private WebSocketTransport transport;
focal_class.type: WebSocketTransport
focal_class.var_name: transport
focal_class.file: weevent-client/src/main/java/com/webank/weevent/client/WeEventClient.java
focal_class.identifier: WeEventClient
focal_class.interfaces: implements IWeEventClient
focal_class.class_method_signature: WeEventClient.WeEventClient(String brokerUrl, String groupId, String userName, String password, int timeout)
focal_class.full_signature:   WeEventClient(String brokerUrl, String groupId, String userName, String password, int timeout)
focal_class.identifier: WeEventClient
focal_class.parameters: (String brokerUrl, String groupId, String userName, String password, int timeout)
focal_class.signature:  WeEventClient(String brokerUrl, String groupId, String userName, String password, int timeout)
focal_class.class_method_signature: WeEventClient.unSubscribe(String subscriptionId)
focal_class.full_signature: @Override public boolean unSubscribe(String subscriptionId)
focal_class.identifier: unSubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (String subscriptionId)
focal_class.return: boolean
focal_class.signature: boolean unSubscribe(String subscriptionId)
focal_class.class_method_signature: WeEventClient.open(String topic)
focal_class.full_signature: @Override public boolean open(String topic)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (String topic)
focal_class.return: boolean
focal_class.signature: boolean open(String topic)
focal_class.class_method_signature: WeEventClient.close(String topic)
focal_class.full_signature: @Override public boolean close(String topic)
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: (String topic)
focal_class.return: boolean
focal_class.signature: boolean close(String topic)
focal_class.class_method_signature: WeEventClient.exist(String topic)
focal_class.full_signature: @Override public boolean exist(String topic)
focal_class.identifier: exist
focal_class.modifiers: @Override public
focal_class.parameters: (String topic)
focal_class.return: boolean
focal_class.signature: boolean exist(String topic)
focal_class.class_method_signature: WeEventClient.list(Integer pageIndex, Integer pageSize)
focal_class.full_signature: @Override public TopicPage list(Integer pageIndex, Integer pageSize)
focal_class.identifier: list
focal_class.modifiers: @Override public
focal_class.parameters: (Integer pageIndex, Integer pageSize)
focal_class.return: TopicPage
focal_class.signature: TopicPage list(Integer pageIndex, Integer pageSize)
focal_class.class_method_signature: WeEventClient.state(String topic)
focal_class.full_signature: @Override public TopicInfo state(String topic)
focal_class.identifier: state
focal_class.modifiers: @Override public
focal_class.parameters: (String topic)
focal_class.return: TopicInfo
focal_class.signature: TopicInfo state(String topic)
focal_class.class_method_signature: WeEventClient.getEvent(String eventId)
focal_class.full_signature: @Override public WeEvent getEvent(String eventId)
focal_class.identifier: getEvent
focal_class.modifiers: @Override public
focal_class.parameters: (String eventId)
focal_class.return: WeEvent
focal_class.signature: WeEvent getEvent(String eventId)
focal_class.class_method_signature: WeEventClient.publish(WeEvent weEvent)
focal_class.full_signature: @Override public SendResult publish(WeEvent weEvent)
focal_class.identifier: publish
focal_class.modifiers: @Override public
focal_class.parameters: (WeEvent weEvent)
focal_class.return: SendResult
focal_class.signature: SendResult publish(WeEvent weEvent)
focal_class.class_method_signature: WeEventClient.publishAsync(WeEvent weEvent)
focal_class.full_signature: @Override public CompletableFuture<SendResult> publishAsync(WeEvent weEvent)
focal_class.identifier: publishAsync
focal_class.modifiers: @Override public
focal_class.parameters: (WeEvent weEvent)
focal_class.return: CompletableFuture<SendResult>
focal_class.signature: CompletableFuture<SendResult> publishAsync(WeEvent weEvent)
focal_class.class_method_signature: WeEventClient.subscribe(String topic, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.full_signature: @Override public String subscribe(String topic, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.identifier: subscribe
focal_class.modifiers: @Override public
focal_class.parameters: (String topic, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.return: String
focal_class.signature: String subscribe(String topic, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.class_method_signature: WeEventClient.subscribe(String[] topics, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.full_signature: @Override public String subscribe(String[] topics, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.identifier: subscribe
focal_class.modifiers: @Override public
focal_class.parameters: (String[] topics, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.return: String
focal_class.signature: String subscribe(String[] topics, String offset, Map<String, String> extension, @NonNull EventListener listener)
focal_class.class_method_signature: WeEventClient.dealSubscribe(String topic, String offset, Map<String, String> extension, EventListener
              listener)
focal_class.full_signature: private String dealSubscribe(String topic, String offset, Map<String, String> extension, EventListener
              listener)
focal_class.identifier: dealSubscribe
focal_class.modifiers: private
focal_class.parameters: (String topic, String offset, Map<String, String> extension, EventListener
              listener)
focal_class.return: String
focal_class.signature: String dealSubscribe(String topic, String offset, Map<String, String> extension, EventListener
              listener)
focal_class.class_method_signature: WeEventClient.getStompUrl(String brokerUrl)
focal_class.full_signature: private String getStompUrl(String brokerUrl)
focal_class.identifier: getStompUrl
focal_class.modifiers: private
focal_class.parameters: (String brokerUrl)
focal_class.return: String
focal_class.signature: String getStompUrl(String brokerUrl)
focal_class.class_method_signature: WeEventClient.getSSLContext()
focal_class.full_signature: public static SSLContext getSSLContext()
focal_class.identifier: getSSLContext
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: SSLContext
focal_class.signature: SSLContext getSSLContext()
focal_class.class_method_signature: WeEventClient.buildStomp()
focal_class.full_signature: private void buildStomp()
focal_class.identifier: buildStomp
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void buildStomp()
focal_class.class_method_signature: WeEventClient.validateWeEvent(WeEvent weEvent)
focal_class.full_signature: private static void validateWeEvent(WeEvent weEvent)
focal_class.identifier: validateWeEvent
focal_class.modifiers: private static
focal_class.parameters: (WeEvent weEvent)
focal_class.return: void
focal_class.signature: void validateWeEvent(WeEvent weEvent)
focal_class.class_method_signature: WeEventClient.validateParam(String param)
focal_class.full_signature: private static void validateParam(String param)
focal_class.identifier: validateParam
focal_class.modifiers: private static
focal_class.parameters: (String param)
focal_class.return: void
focal_class.signature: void validateParam(String param)
focal_class.class_method_signature: WeEventClient.validateArrayParam(byte[] param)
focal_class.full_signature: private static void validateArrayParam(byte[] param)
focal_class.identifier: validateArrayParam
focal_class.modifiers: private static
focal_class.parameters: (byte[] param)
focal_class.return: void
focal_class.signature: void validateArrayParam(byte[] param)
focal_class.class_method_signature: WeEventClient.encodeTopic(String topic)
focal_class.full_signature: private String encodeTopic(String topic)
focal_class.identifier: encodeTopic
focal_class.modifiers: private
focal_class.parameters: (String topic)
focal_class.return: String
focal_class.signature: String encodeTopic(String topic)
focal_class.class_method_signature: WeEventClient.checkConnected()
focal_class.full_signature: private void checkConnected()
focal_class.identifier: checkConnected
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void checkConnected()
focal_class.class_method_signature: WeEventClient.createUri(String url)
focal_class.full_signature: private URI createUri(String url)
focal_class.identifier: createUri
focal_class.modifiers: private
focal_class.parameters: (String url)
focal_class.return: URI
focal_class.signature: URI createUri(String url)
focal_class.class_method_signature: WeEventClient.validateGroupId(String brokerUrl, String groupId)
focal_class.full_signature: private void validateGroupId(String brokerUrl, String groupId)
focal_class.identifier: validateGroupId
focal_class.modifiers: private
focal_class.parameters: (String brokerUrl, String groupId)
focal_class.return: void
focal_class.signature: void validateGroupId(String brokerUrl, String groupId)
focal_method.body: @Override
      public boolean exist(String topic) throws BrokerException {
          validateParam(topic);
          HttpGet httpGet = new HttpGet(String.format("%s/exist?topic=%s&groupId=%s",
                  this.brokerRestfulUrl,
                  encodeTopic(topic),
                  this.groupId));
  
  
          return this.httpClientHelper.invokeCGI(httpGet, new TypeReference<BaseResponse<Boolean>>() {
          }).getData();
      }
focal_method.class_method_signature: WeEventClient.exist(String topic)
focal_method.full_signature: @Override public boolean exist(String topic)
focal_method.identifier: exist
focal_method.invocations: validateParam format encodeTopic getData invokeCGI
focal_method.modifiers: @Override public
focal_method.parameters: (String topic)
focal_method.return: boolean
focal_method.signature: boolean exist(String topic)