File tree Expand file tree Collapse file tree 2 files changed +7
-1
lines changed
main/java/com/uber/cadence/internal/sync
test/java/com/uber/cadence/internal/sync Expand file tree Collapse file tree 2 files changed +7
-1
lines changed Original file line number Diff line number Diff line change 1717
1818package com .uber .cadence .internal .sync ;
1919
20+ import com .google .common .annotations .VisibleForTesting ;
2021import com .google .common .base .Joiner ;
2122import com .google .common .base .Objects ;
2223import com .uber .cadence .PollForActivityTaskResponse ;
@@ -158,6 +159,11 @@ public boolean isAnyTypeSupported() {
158159 return !activities .isEmpty ();
159160 }
160161
162+ @ VisibleForTesting
163+ public Set <String > getRegisteredActivityTypes () {
164+ return activities .keySet ();
165+ }
166+
161167 void setActivitiesImplementation (Object [] activitiesImplementation ) {
162168 activities .clear ();
163169 for (Object activity : activitiesImplementation ) {
Original file line number Diff line number Diff line change 1515 * permissions and limitations under the License.
1616 */
1717
18- package com .uber .cadence .worker ;
18+ package com .uber .cadence .internal . sync ;
1919
2020import com .google .common .base .Objects ;
2121import com .uber .cadence .activity .ActivityInterface ;
You can’t perform that action at this time.
0 commit comments