@@ -93,7 +93,6 @@ public class UtilApi {
@PostMapping("ibmmq/depth")
public ResponseEntity<Map<String,Object>> ibmmqDepth(@RequestBody(required = true) IbmmqProp prop) {
int depth = IbmmqUtil.getDepth(prop.getHost(), prop.getPort(), prop.getCCSID(), prop.getQueueManager(), prop.getChannel(), prop.getQueueName(), prop.getUserName(), prop.getPassword());
-
return ResponseEntity.ok(UniReturnUtil.success(depth));
}
@@ -14,15 +14,11 @@ public class KafkaScriptUtil {
private static final DataBase DATA_BASE = new DataBase();
public static Map<String, Object> receptionMessage(String dataSourceId, String topic, String groupId) throws Exception {
return Kafka.receptionMessage(queryConnectionStr(dataSourceId), topic, groupId);
public static Map<String, Object> sendMessage(String dataSourceId, String topic, Object datas) throws Exception {
return Kafka.sendMessage(queryConnectionStr(dataSourceId), topic, DataFormatUtil.toList(datas));