Skip to content

Commit 39ea11f

Browse files
committed
fix minnor issues
Signed-off-by: Manish Dait <[email protected]>
1 parent 0f07e51 commit 39ea11f

File tree

6 files changed

+10
-10
lines changed

6 files changed

+10
-10
lines changed

hiero-enterprise-base/src/main/java/com/openelements/hiero/base/implementation/TopicClientImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ public SubscriptionHandle subscribeTopic(@NonNull TopicId topicId, @NonNull Cons
249249
throw new IllegalArgumentException("startTime must be greater than currentTime");
250250
}
251251
if (endTime.isBefore(startTime)) {
252-
throw new IllegalArgumentException("endTime must be greater than starTime");
252+
throw new IllegalArgumentException("endTime must be greater than startTime");
253253
}
254254

255255
TopicMessageRequest request = TopicMessageRequest.of(topicId, subscription, startTime, endTime);
@@ -270,7 +270,7 @@ public SubscriptionHandle subscribeTopic(@NonNull TopicId topicId, @NonNull Cons
270270
throw new IllegalArgumentException("startTime must be greater than currentTime");
271271
}
272272
if (endTime.isBefore(startTime)) {
273-
throw new IllegalArgumentException("endTime must be greater than starTime");
273+
throw new IllegalArgumentException("endTime must be greater than startTime");
274274
}
275275
if (limit == 0) {
276276
throw new IllegalArgumentException("limit must be greater than 0");

hiero-enterprise-base/src/main/java/com/openelements/hiero/base/protocol/data/TopicMessageRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public static TopicMessageRequest of(@NonNull TopicId topicId, @NonNull Consumer
3030
@NonNull
3131
public static TopicMessageRequest of(@NonNull TopicId topicId, @NonNull Consumer<TopicMessage> subscription,
3232
@NonNull long limit) {
33-
return new TopicMessageRequest(topicId, subscription, null, null,limit, null, null);
33+
return new TopicMessageRequest(topicId, subscription, null, null, limit, null, null);
3434
}
3535

3636
@NonNull

hiero-enterprise-base/src/test/java/com/openelements/hiero/base/test/TopicClientImplTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -740,8 +740,8 @@ void shouldThrowExceptionOnSubscribeTopicWithInvalidStartAndEndTime() {
740740
final IllegalArgumentException e2 = Assertions.assertThrows(IllegalArgumentException.class,
741741
() -> topicClient.subscribeTopic(topicId, subscription, startTime1, endTime1, limit));
742742

743-
Assertions.assertEquals("endTime must be greater than starTime", e1.getMessage());
744-
Assertions.assertEquals("endTime must be greater than starTime", e2.getMessage());
743+
Assertions.assertEquals("endTime must be greater than startTime", e1.getMessage());
744+
Assertions.assertEquals("endTime must be greater than startTime", e2.getMessage());
745745

746746
//Start time before current time
747747
final IllegalArgumentException e3 = Assertions.assertThrows(IllegalArgumentException.class,

hiero-enterprise-base/src/test/java/com/openelements/hiero/base/test/config/HieroTestContext.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ public class HieroTestContext implements HieroContext {
2424

2525
private final Client client;
2626

27-
private final Set<String> mirronNodeEnpoint;
27+
private final Set<String> mirronNodeEndpoint;
2828

2929
public HieroTestContext() {
3030
final Dotenv dotenv = Dotenv.configure().ignoreIfMissing().load();
@@ -61,7 +61,7 @@ public HieroTestContext() {
6161
final Map<String, AccountId> nodes = new HashMap<>();
6262
networkSettings.getConsensusNodes()
6363
.forEach(consensusNode -> nodes.put(consensusNode.getAddress(), consensusNode.getAccountId()));
64-
mirronNodeEnpoint = networkSettings.getConsensusServiceAddress();
64+
mirronNodeEndpoint = networkSettings.getConsensusServiceAddress();
6565
client = Client.forNetwork(nodes);
6666
if (!networkSettings.getMirrorNodeAddresses().isEmpty()) {
6767
try {
@@ -84,6 +84,6 @@ public Client getClient() {
8484

8585
@Override
8686
public @NonNull Set<String> getMirrorNodeEndPoint() {
87-
return mirronNodeEnpoint;
87+
return mirronNodeEndpoint;
8888
}
8989
}

hiero-enterprise-spring/src/test/java/com/openelements/hiero/spring/test/TopicClientTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -303,6 +303,6 @@ void testSubscribeTopicWithStartAndEndTimeWithInvalidParams() throws HieroExcept
303303
() -> topicClient.subscribeTopic(topicId, (message) -> {}, start, invalidEnd)
304304
);
305305

306-
Assertions.assertEquals("endTime must be greater than starTime", e2.getMessage());
306+
Assertions.assertEquals("endTime must be greater than startTime", e2.getMessage());
307307
}
308308
}

hiero-enterprise-test/src/main/java/com/openelements/hiero/test/SoloActionNetworkSettings.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public class SoloActionNetworkSettings implements NetworkSettings {
2525
}
2626

2727
@Override
28-
public @NonNull Set<String> getConsensusServiceAddress() {return Set.of("http://localhost:8080");} //TBD
28+
public @NonNull Set<String> getConsensusServiceAddress() {return Set.of("http://localhost:8080");}
2929

3030
@Override
3131
public @NonNull Set<ConsensusNode> getConsensusNodes() {

0 commit comments

Comments
 (0)