| | |
|---|
| | | import com.java110.utils.constant.KafkaConstant; |
|---|
| | | import org.apache.kafka.clients.consumer.ConsumerRecord; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import com.java110.core.log.LoggerFactory; |
|---|
| | | import org.springframework.kafka.annotation.KafkaListener; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | JSONObject param = null; |
|---|
| | | try { |
|---|
| | | param = JSONObject.parseObject(record.value().toString()); |
|---|
| | | ParkingAreaWebsocket.sendInfo(param.toJSONString(), param.getString("extPaId")); |
|---|
| | | ParkingAreaWebsocket.sendInfo(param.toJSONString(), param.getString("extBoxId")); |
|---|
| | | } catch (Exception e) { |
|---|
| | | logger.error("发送消息失败", e); |
|---|
| | | } finally { |
|---|
