application/jaxrs-redis-quarkus/src/main/java/webapp/tier/resource/RedisResource.java
package webapp.tier.resource;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.inject.Inject;
import javax.ws.rs.DELETE;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.core.Response;
import webapp.tier.service.RedisService;
@Path("/quarkus/redis")
public class RedisResource {
private final Logger logger = Logger.getLogger(this.getClass().getSimpleName());
@Inject
RedisService svc;
@POST
@Path("/put")
public Response put() {
try {
return Response.ok().entity(svc.putMsg()).build();
} catch (Exception e) {
logger.log(Level.WARNING, "Put Error.", e);
return Response.status(500).entity("Put Error.").build();
}
}
@GET
@Path("/get")
public Response get() {
try {
return Response.ok().entity(svc.getMsgList()).build();
} catch (Exception e) {
logger.log(Level.WARNING, "Get Error.", e);
return Response.status(500).entity("Get Error.").build();
}
}
@DELETE
@Path("/delete")
public Response delete() {
try {
return Response.ok().entity(svc.delete()).build();
} catch (Exception e) {
logger.log(Level.WARNING, "Delete Error.", e);
return Response.status(500).entity("Delete Error.").build();
}
}
@POST
@Path("/publish")
public Response publish() {
try {
return Response.ok().entity(svc.publish()).build();
} catch (Exception e) {
logger.log(Level.WARNING, "Publish Error.", e);
return Response.status(500).entity("Publish Error.").build();
}
}
}