| %%------------------------------------------------------------------------------ |
| %% Licensed to the Apache Software Foundation (ASF) under one or more |
| %% contributor license agreements. See the NOTICE file distributed with |
| %% this work for additional information regarding copyright ownership. |
| %% The ASF licenses this file to You under the Apache License, Version 2.0 |
| %% (the "License"); you may not use this file except in compliance with |
| %% the License. You may obtain a copy of the License at |
| %% |
| %% http://www.apache.org/licenses/LICENSE-2.0 |
| %% |
| %% Unless required by applicable law or agreed to in writing, software |
| %% distributed under the License is distributed on an "AS IS" BASIS, |
| %% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| %% See the License for the specific language governing permissions and |
| %% limitations under the License. |
| %%------------------------------------------------------------------------------ |
| -module(consumer_SUITE). |
| %% API |
| -export([]). |
| |
| -compile(export_all). |
| |
| -include_lib("common_test/include/ct.hrl"). |
| -include("dubbo_sample_service.hrl"). |
| %%-------------------------------------------------------------------- |
| %% Function: suite() -> Info |
| %% Info = [tuple()] |
| %%-------------------------------------------------------------------- |
| suite() -> |
| [{timetrap, {seconds, 60}}]. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: init_per_suite(Config0) -> |
| %% Config1 | {skip,Reason} | {skip_and_save,Reason,Config1} |
| %% Config0 = Config1 = [tuple()] |
| %% Reason = term() |
| %%-------------------------------------------------------------------- |
| init_per_suite(Config) -> |
| logger:add_handler(testttt, logger_std_h, #{ |
| level => debug |
| }), |
| Start = application:ensure_all_started(dubboerl), |
| %% dubboerl:init(), |
| dubboerl:start_provider(), |
| timer:sleep(2000), |
| dubboerl:start_consumer(), |
| dubbo_sample_service_app:register_type_list(), |
| timer:sleep(5000), |
| io:format(user, "test case start info ~p~n", [Start]), |
| [{appid, 1}]. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: end_per_suite(Config0) -> term() | {save_config,Config1} |
| %% Config0 = Config1 = [tuple()] |
| %%-------------------------------------------------------------------- |
| end_per_suite(_Config) -> |
| application:stop(dubboerl), |
| ok. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: init_per_group(GroupName, Config0) -> |
| %% Config1 | {skip,Reason} | {skip_and_save,Reason,Config1} |
| %% GroupName = atom() |
| %% Config0 = Config1 = [tuple()] |
| %% Reason = term() |
| %%-------------------------------------------------------------------- |
| init_per_group(_GroupName, Config) -> |
| Config. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: end_per_group(GroupName, Config0) -> |
| %% term() | {save_config,Config1} |
| %% GroupName = atom() |
| %% Config0 = Config1 = [tuple()] |
| %%-------------------------------------------------------------------- |
| end_per_group(_GroupName, _Config) -> |
| ok. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: init_per_testcase(TestCase, Config0) -> |
| %% Config1 | {skip,Reason} | {skip_and_save,Reason,Config1} |
| %% TestCase = atom() |
| %% Config0 = Config1 = [tuple()] |
| %% Reason = term() |
| %%-------------------------------------------------------------------- |
| init_per_testcase(_TestCase, Config) -> |
| Config. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: end_per_testcase(TestCase, Config0) -> |
| %% term() | {save_config,Config1} | {fail,Reason} |
| %% TestCase = atom() |
| %% Config0 = Config1 = [tuple()] |
| %% Reason = term() |
| %%-------------------------------------------------------------------- |
| end_per_testcase(_TestCase, _Config) -> |
| ok. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: groups() -> [Group] |
| %% Group = {GroupName,Properties,GroupsAndTestCases} |
| %% GroupName = atom() |
| %% Properties = [parallel | sequence | Shuffle | {RepeatType,N}] |
| %% GroupsAndTestCases = [Group | {group,GroupName} | TestCase] |
| %% TestCase = atom() |
| %% Shuffle = shuffle | {shuffle,{integer(),integer(),integer()}} |
| %% RepeatType = repeat | repeat_until_all_ok | repeat_until_all_fail | |
| %% repeat_until_any_ok | repeat_until_any_fail |
| %% N = integer() | forever |
| %%-------------------------------------------------------------------- |
| groups() -> |
| [ |
| {consumer1, [sequence], [lib_type_register, json_sync_invoker, hessian_sync_invoker]} |
| ]. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: all() -> GroupsAndTestCases | {skip,Reason} |
| %% GroupsAndTestCases = [{group,GroupName} | TestCase] |
| %% GroupName = atom() |
| %% TestCase = atom() |
| %% Reason = term() |
| %%-------------------------------------------------------------------- |
| all() -> |
| [{group, consumer1}]. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: TestCase() -> Info |
| %% Info = [tuple()] |
| %%-------------------------------------------------------------------- |
| lib_type_register() -> |
| []. |
| |
| %%-------------------------------------------------------------------- |
| %% Function: TestCase(Config0) -> |
| %% ok | exit() | {skip,Reason} | {comment,Comment} | |
| %% {save_config,Config1} | {skip_and_save,Reason,Config1} |
| %% Config0 = Config1 = [tuple()] |
| %% Reason = term() |
| %% Comment = term() |
| %%-------------------------------------------------------------------- |
| lib_type_register(_Config) -> |
| ok. |
| |
| json_sync_invoker(_Config) -> |
| application:set_env(dubboerl, serialization, json), |
| R1 = userOperator:queryUserInfo(#userInfoRequest{username = "name", requestId = "111"}, #{sync=> true}), |
| io:format(user, "json_sync_invoker result ~p ~n", [R1]), |
| R2 = userOperator:genUserId(), |
| io:format(user, "json_sync_invoker result2 ~p ~n", [R2]), |
| ok. |
| hessian_sync_invoker(_Config) -> |
| application:set_env(dubboerl, serialization, hessian), |
| R1 = userOperator:queryUserInfo(#userInfoRequest{username = "name", requestId = "111"}, #{sync=> true}), |
| io:format(user, "json_sync_invoker result ~p ~n", [R1]), |
| R2 = userOperator:genUserId(), |
| io:format(user, "json_sync_invoker result2 ~p ~n", [R2]), |
| ok. |