在通过websocket从客户端接收消息时,我正在尝试保留以下实体:
import javax.persistence.Column;
import javax.persistence.Entity;
import io.quarkus.hibernate.orm.panache.PanacheEntity;
@Entity
public class Penguin extends PanacheEntity{
@Column(name="penguin_name")
public String name;
}
当接收到post请求时,以下操作有效:
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Consumes;
import javax.ws.rs.Produces;
import javax.transaction.Transactional;
import com.penguins.demo.pojos.Penguin;
@Path("/api")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
public class PenguinResource {
@GET
public List<Penguin> getPenguins(){
return Penguin.listAll();
}
@POST
@Transactional
public Response addPenguin(Penguin penguin){
penguin.persist();
return Response.ok(penguin).status(201).build();
}
}
但是,以下代码到达persist行时会冻结。这个 message.getPenguin()
方法正在返回实际值 Penguin
参考(the MessageDecoder.class
是做这件事的一部分):
import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import com.penguins.demo.pojos.Message;
import com.penguins.demo.pojos.Penguin;
@ServerEndpoint(value = "/waddle/{user}", decoders = MessageDecoder.class, encoders = MessageEncoder.class)
public class PenguinHub {
@OnMessage
@Transactional
public void onMessage(Session session, Message message) throws IOException {
// Handle new messages
message.setFrom(users.get(session.getId()));
// it freezes on persist :(
message.getPenguin().persist();
broadcast(message);
}
}
我是新来panache/hibernate的,任何帮助都会很感激的,谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!