Skip to content

Commit 4aa0561

Browse files
committed
remove transient and hump naming.
1 parent 6e10a72 commit 4aa0561

File tree

1 file changed

+8
-8
lines changed
  • eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/sub/service

1 file changed

+8
-8
lines changed

eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -53,9 +53,9 @@
5353
@Component
5454
public class SubService implements InitializingBean {
5555

56-
private transient EventMeshHttpConsumer eventMeshHttpConsumer;
56+
private EventMeshHttpConsumer eventMeshHttpConsumer;
5757

58-
private transient Properties properties;
58+
private Properties properties;
5959

6060
{
6161
try {
@@ -68,19 +68,19 @@ public class SubService implements InitializingBean {
6868
final String localPort = properties.getProperty(SERVER_PORT);
6969
final String testURL = getURL(localPort, "/sub/test");
7070

71-
private final transient List<SubscriptionItem> topicList = Lists.newArrayList(
71+
private final List<SubscriptionItem> topicList = Lists.newArrayList(
7272
new SubscriptionItem(ExampleConstants.EVENTMESH_HTTP_ASYNC_TEST_TOPIC, SubscriptionMode.CLUSTERING, SubscriptionType.ASYNC)
7373
);
7474

7575
// CountDownLatch size is the same as messageSize in AsyncPublishInstance.java (Publisher)
76-
private transient CountDownLatch countDownLatch = new CountDownLatch(AsyncPublishInstance.MESSAGE_SIZE);
76+
private final CountDownLatch countDownLatch = new CountDownLatch(AsyncPublishInstance.MESSAGE_SIZE);
7777

7878
@Override
79-
public void afterPropertiesSet() throws Exception {
80-
final String eventmeshIP = properties.getProperty(ExampleConstants.EVENTMESH_IP);
81-
final String eventmeshHttpPort = properties.getProperty(ExampleConstants.EVENTMESH_HTTP_PORT);
79+
public void afterPropertiesSet() {
80+
final String eventMeshIP = properties.getProperty(ExampleConstants.EVENTMESH_IP);
81+
final String eventMeshHttpPort = properties.getProperty(ExampleConstants.EVENTMESH_HTTP_PORT);
8282

83-
final String eventMeshIPPort = eventmeshIP + ":" + eventmeshHttpPort;
83+
final String eventMeshIPPort = eventMeshIP + ":" + eventMeshHttpPort;
8484
final EventMeshHttpClientConfig eventMeshClientConfig = EventMeshHttpClientConfig.builder()
8585
.liteEventMeshAddr(eventMeshIPPort)
8686
.consumerGroup(ExampleConstants.DEFAULT_EVENTMESH_TEST_CONSUMER_GROUP)

0 commit comments

Comments
 (0)