KH/kh-device-admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/fix-bug-202303' into fix-bug-202303

Browse Source
This commit is contained in:
梁琦涛
2023-03-09 17:37:41 +08:00
parent 5036eb8193 f5bf36f079
commit 043bd3bc75
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/core/MapMessageConverter.java
+1 -4
View File
@@ -7,8 +7,6 @@ import org.springframework.amqp.support.converter.MessageConverter;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.ObjectInputStream; import java.io.ObjectInputStream;
import java.util.HashMap;
import java.util.Map;
public class MapMessageConverter implements MessageConverter { public class MapMessageConverter implements MessageConverter {
@Override @Override
@@ -27,8 +25,7 @@ public class MapMessageConverter implements MessageConverter {
ByteArrayInputStream byteInt = new ByteArrayInputStream(message.getBody()); ByteArrayInputStream byteInt = new ByteArrayInputStream(message.getBody());
objInt = new ObjectInputStream(byteInt); objInt = new ObjectInputStream(byteInt);
//byte[]转map //byte[]转map
Map map = (HashMap) objInt.readObject(); return objInt.readObject();
return map;
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }