我应该如何坚持一个泛美的实体?

bvjveswy  于 2021-07-11  发布在  Java
关注(0)|答案(0)|浏览(317)

在通过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的,任何帮助都会很感激的,谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题