Remove unused method to publish events

Signed-off-by: Abhay Kishore <abhay.kishore@walmart.com>
hyperledger-labs · Oct 22, 2024 · 5564e57 · 5564e57
1 parent b8a187e
commit 5564e57
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 68 deletions.
diff --git a/src/main/java/hlf/java/rest/client/service/EventPublishService.java b/src/main/java/hlf/java/rest/client/service/EventPublishService.java
@@ -9,16 +9,6 @@
 @ConditionalOnProperty("kafka.event-listeners[0].brokerHost")
 public interface EventPublishService {
 
-  /**
-   * @param payload String message payload
-   * @param fabricTxId String Fabric transaction ID
-   * @param eventName String chaincode event-name
-   * @param channelName String Name of the channel where the event was generated.
-   * @return status boolean status of msg sent
-   */
-  boolean sendMessage(
-      final String payload, String fabricTxId, String eventName, String channelName);
-
   /**
    * @param payload String message payload
    * @param fabricTxId String Fabric transaction ID

diff --git a/src/main/java/hlf/java/rest/client/service/impl/EventPublishServiceImpl.java b/src/main/java/hlf/java/rest/client/service/impl/EventPublishServiceImpl.java
@@ -28,64 +28,6 @@ public class EventPublishServiceImpl implements EventPublishService {
 
   @Autowired private RoutingKafkaTemplate routingKafkaTemplate;
 
-  @Override
-  public boolean sendMessage(String msg, String fabricTxId, String eventName, String channelName) {
-
-    log.debug("Send Event Message - " + msg);
-
-    boolean status = true;
-
-    try {
-
-      ProducerRecord<Object, Object> producerRecord =
-          new ProducerRecord<>(
-              kafkaProperties.getEventListeners().get(0).getTopic(),
-              String.valueOf(msg.hashCode()),
-              msg);
-
-      producerRecord
-          .headers()
-          .add(
-              new RecordHeader(FabricClientConstants.FABRIC_TRANSACTION_ID, fabricTxId.getBytes()));
-      producerRecord
-          .headers()
-          .add(new RecordHeader(FabricClientConstants.FABRIC_EVENT_NAME, eventName.getBytes()));
-      producerRecord
-          .headers()
-          .add(new RecordHeader(FabricClientConstants.FABRIC_CHANNEL_NAME, channelName.getBytes()));
-
-      ListenableFuture<SendResult<Object, Object>> future =
-          routingKafkaTemplate.send(producerRecord);
-
-      future.addCallback(
-          new ListenableFutureCallback<SendResult<Object, Object>>() {
-
-            @Override
-            public void onSuccess(SendResult<Object, Object> result) {
-              log.info(
-                  "Sent message '{}' to partition {} for offset {}",
-                  msg,
-                  result.getRecordMetadata().partition(),
-                  result.getRecordMetadata().offset());
-            }
-
-            @Override
-            public void onFailure(Throwable ex) {
-              log.error(
-                  "Failed to send message event for Transaction ID {} due to {}",
-                  fabricTxId,
-                  ex.getMessage());
-            }
-          });
-
-    } catch (Exception ex) {
-      status = false;
-      log.error("Error sending message - " + ex.getMessage());
-    }
-
-    return status;
-  }
-
   @Override
   public void publishChaincodeEvents(
       String payload,