本文整理了Java中javax.ws.rs.core.Response.created
方法的一些代码示例,展示了Response.created
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response.created
方法的具体详情如下:
包路径:javax.ws.rs.core.Response
类名称:Response
方法名:created
[英]Create a new ResponseBuilder for a created resource, set the location header using the supplied value.
[中]为创建的资源创建新的ResponseBuilder,使用提供的值设置位置标题。
代码示例来源:origin: apache/nifi
/**
* Generates a 201 Created response with the specified content.
*
* @param uri The URI
* @param entity entity
* @return The response to be built
*/
protected ResponseBuilder generateCreatedResponse(final URI uri, final Object entity) {
// generate the response builder
return Response.created(uri).entity(entity);
}
代码示例来源:origin: jersey/jersey
@Path("start")
@POST
public Response post(@DefaultValue("0") @QueryParam("testSources") int testSources, @Context Sse sse) {
final Process process = new Process(testSources, sse);
processes.put(process.getId(), process);
Executors.newSingleThreadExecutor().execute(process);
final URI processIdUri = UriBuilder.fromResource(DomainResource.class).path("process/{id}").build(process.getId());
return Response.created(processIdUri).build();
}
代码示例来源:origin: apache/usergrid
@POST
@Consumes({MediaType.APPLICATION_JSON})
@Produces({MediaType.APPLICATION_JSON})
public Response createQueue(Queue queue ) throws Exception {
Preconditions.checkArgument(queue != null, "Queue configuration is required");
Preconditions.checkArgument(!QakkaUtils.isNullOrEmpty(queue.getName()), "Queue name is required");
queueManager.createQueue(queue);
ApiResponse apiResponse = new ApiResponse();
apiResponse.setQueues( Collections.singletonList(queue) );
return Response.created( uriStrategy.queueURI( queue.getName() )).entity(apiResponse).build();
}
代码示例来源:origin: Netflix/Priam
/**
* Creates a new instance with the given parameters
*
* @param id the node id
* @return Response (201) if the instance was created
*/
@POST
public Response createInstance(
@QueryParam("id") int id,
@QueryParam("instanceID") String instanceID,
@QueryParam("hostname") String hostname,
@QueryParam("ip") String ip,
@QueryParam("rack") String rack,
@QueryParam("token") String token) {
log.info(
"Creating instance [id={}, instanceId={}, hostname={}, ip={}, rack={}, token={}",
id,
instanceID,
hostname,
ip,
rack,
token);
PriamInstance instance =
factory.create(
config.getAppName(), id, instanceID, hostname, ip, rack, null, token);
URI uri = UriBuilder.fromPath("/{id}").build(instance.getId());
return Response.created(uri).build();
}
代码示例来源:origin: Graylog2/graylog2-server
@PUT
@Timed
@Path("/{inputId}")
@ApiOperation(
value = "Update input on this node",
response = InputCreated.class
)
@ApiResponses(value = {
@ApiResponse(code = 404, message = "No such input on this node."),
@ApiResponse(code = 400, message = "Missing or invalid input configuration.")
})
@AuditEvent(type = AuditEventTypes.MESSAGE_INPUT_UPDATE)
public Response update(@ApiParam(name = "JSON body", required = true) @Valid @NotNull InputCreateRequest lr,
@ApiParam(name = "inputId", required = true) @PathParam("inputId") String inputId) throws org.graylog2.database.NotFoundException, NoSuchInputTypeException, ConfigurationException, ValidationException {
checkPermission(RestPermissions.INPUTS_EDIT, inputId);
final Input input = inputService.find(inputId);
final Map<String, Object> mergedInput = input.getFields();
final MessageInput messageInput = messageInputFactory.create(lr, getCurrentUser().getName(), lr.node());
messageInput.checkConfiguration();
mergedInput.putAll(messageInput.asMap());
final Input newInput = inputService.create(input.getId(), mergedInput);
inputService.update(newInput);
final URI inputUri = getUriBuilderToSelf().path(InputsResource.class)
.path("{inputId}")
.build(input.getId());
return Response.created(inputUri).entity(InputCreated.create(input.getId())).build();
}
代码示例来源:origin: OAuth-Apis/apis
/**
* Save a new resource owner.
*/
@PUT
public Response put(@Context
HttpServletRequest request, @Valid
ResourceOwner newOne) {
Response validateScopeResponse = validateScope(request, Collections.singletonList(AbstractResource.SCOPE_WRITE));
if (validateScopeResponse != null) {
return validateScopeResponse;
}
ResourceOwner resourceOwnerSaved;
try {
//we run transactional modus, so any constraint violations only occur after the commit of the transaction (to late...)
validate(newOne);
resourceOwnerSaved = resourceOwnerRepository.save(newOne);
} catch (Exception e) {
return buildErrorResponse(e);
}
LOG.debug("New resourceOwner has been saved: {}. ", resourceOwnerSaved);
final URI uri = UriBuilder.fromPath("{resourceServerId}.json").build(resourceOwnerSaved.getId());
return Response.created(uri).entity(resourceOwnerSaved).build();
}
代码示例来源:origin: jersey/jersey
@Path("start")
@POST
public Response post(@DefaultValue("0") @QueryParam("testSources") int testSources) {
final Process process = new Process(testSources);
processes.put(process.getId(), process);
Executors.newSingleThreadExecutor().execute(process);
final URI processIdUri = UriBuilder.fromResource(DomainResource.class).path("process/{id}").build(process.getId());
return Response.created(processIdUri).build();
}
代码示例来源:origin: dsukhoroslov/bagri
@POST
@Produces(MediaType.TEXT_PLAIN)
@ApiOperation(value = "postTx: starts a new user Transaction in the current session")
public Response postTx(String isolation) {
TransactionManagement txMgr = getTxManager();
try {
long txId = txMgr.beginTransaction(TransactionIsolation.valueOf(isolation));
return Response.created(UriBuilder.fromPath("/tx/" + txId).build()).entity(txId).build();
} catch (Exception ex) {
logger.error("postTx.error", ex);
throw new WebApplicationException(ex, Status.INTERNAL_SERVER_ERROR);
}
}
代码示例来源:origin: agoncal/agoncal-application-conference
@POST
@ApiOperation(value = "Adds a new session to the conference")
@ApiResponses(value = {
@ApiResponse(code = 201, message = "The session is created"),
@ApiResponse(code = 400, message = "Invalid input")}
)
public Response add(@ApiParam(value = "Session to be created", required = true) @NotNull Session session) {
Session created = sessionRepository.create(session);
return Response.created(getURIForSelf(session)).entity(created).build();
}
代码示例来源:origin: apache/hbase
if (servlet.isReadOnly()) {
return Response.status(Response.Status.FORBIDDEN)
.type(MIMETYPE_TEXT).entity("Forbidden" + CRLF)
.build();
URI uri = builder.path(id).build();
servlet.getMetrics().incrementSucessfulPutRequests(1);
return Response.created(uri).build();
} catch (Exception e) {
LOG.error("Exception occured while processing " + uriInfo.getAbsolutePath() + " : ", e);
if (e instanceof TableNotFoundException) {
return Response.status(Response.Status.NOT_FOUND)
.type(MIMETYPE_TEXT).entity("Not found" + CRLF)
.build();
} else if (e instanceof RuntimeException
|| e instanceof JsonMappingException | e instanceof JsonParseException) {
return Response.status(Response.Status.BAD_REQUEST)
.type(MIMETYPE_TEXT).entity("Bad request" + CRLF)
.build();
代码示例来源:origin: OAuth-Apis/apis
/**
* Save a new client.
*/
@PUT
public Response put(@Context HttpServletRequest request,
@PathParam("resourceServerId") Long resourceServerId, Client client) {
Response validateScopeResponse = validateScope(request, Collections.singletonList(AbstractResource.SCOPE_WRITE));
if (validateScopeResponse != null) {
return validateScopeResponse;
}
ResourceServer resourceServer = getResourceServer(request, resourceServerId);
client.setResourceServer(resourceServer);
client.setClientId(generateClientId(client));
client.setSecret(client.isAllowedImplicitGrant() ? null : generateSecret());
Client clientSaved;
try {
clientSaved = clientRepository.save(client);
} catch (RuntimeException e) {
return buildErrorResponse(e);
}
if (LOG.isDebugEnabled()) {
LOG.debug("Saved client: {}", clientSaved);
}
final URI uri = UriBuilder.fromPath("{clientId}.json").build(clientSaved.getId());
return Response.created(uri).entity(clientSaved).build();
}
代码示例来源:origin: jersey/jersey
@Override
public String set(String value) {
if (System.setProperty(name, value) == null) {
throw new WebApplicationException(Response.created(uriInfo.getRequestUri()).entity(value).build());
}
return value;
}
}
代码示例来源:origin: Graylog2/graylog2-server
@POST
@Timed
@ApiOperation(value = "Add a new named pattern", response = GrokPattern.class)
@AuditEvent(type = AuditEventTypes.GROK_PATTERN_CREATE)
public Response createPattern(@ApiParam(name = "pattern", required = true)
@Valid @NotNull GrokPattern pattern) throws ValidationException {
checkPermission(RestPermissions.INPUTS_CREATE);
// remove the ID from the pattern, this is only used to create new patterns
final GrokPattern newPattern = grokPatternService.save(pattern.toBuilder().id(null).build());
final URI patternUri = getUriBuilderToSelf().path(GrokResource.class, "listPattern").build(newPattern.id());
return Response.created(patternUri).entity(newPattern).build();
}
代码示例来源:origin: lievendoclo/cleanarch
@POST
@Consumes("application/json")
public Response create(CreateBuildingJsonPayload payload) {
final AtomicReference<String> id = new AtomicReference<>();
createBuilding.execute(new CreateBuildingRequest(payload.getName()), id::set);
return Response.created(UriBuilder.fromPath(GET_SINGLE_BUILDING_URI_TEMPLATE).resolveTemplate("buildingId", id.get()).build())
.header("X-Created-Id", id.get())
.build();
}
代码示例来源:origin: agoncal/agoncal-application-conference
@POST
@ApiOperation(value = "Adds a new attendee to the conference")
@ApiResponses(value = {
@ApiResponse(code = 201, message = "The attendee is created"),
@ApiResponse(code = 400, message = "Invalid input")}
)
public Response add(@ApiParam(value = "Room to be created", required = true) @NotNull Attendee attendee) {
Attendee created = attendeeRepository.create(attendee);
return Response.created(getURIForSelf(attendee)).entity(created).build();
}
代码示例来源:origin: org.apache.cxf.fediz/fediz-idp-core
@Override
public Response addClaim(UriInfo ui, Claim claim) {
LOG.info("add Claim config");
Claim createdClaim = claimDAO.addClaim(claim);
UriBuilder uriBuilder = UriBuilder.fromUri(ui.getRequestUri());
uriBuilder.path("{index}");
URI location = uriBuilder.build(createdClaim.getClaimType().toString());
return Response.created(location).entity(claim).build();
}
代码示例来源:origin: OAuth-Apis/apis
/**
* Save a new resource server.
*/
@PUT
public Response put(@Context
HttpServletRequest request, @Valid
ResourceServer newOne) {
Response validateScopeResponse = validateScope(request, Collections.singletonList(AbstractResource.SCOPE_WRITE));
if (validateScopeResponse != null) {
return validateScopeResponse;
}
String owner = getUserId(request);
// Read only fields
newOne.setKey(generateKey());
newOne.setSecret(generateSecret());
newOne.setOwner(owner);
ResourceServer resourceServerSaved;
try {
//we run transactional modus, so any constraint violations only occur after the commit of the transaction (to late...)
validate(newOne);
resourceServerSaved = resourceServerRepository.save(newOne);
} catch (Exception e) {
return buildErrorResponse(e);
}
LOG.debug("New resourceServer has been saved: {}. ", resourceServerSaved);
final URI uri = UriBuilder.fromPath("{resourceServerId}.json").build(resourceServerSaved.getId());
return Response.created(uri).entity(resourceServerSaved).build();
}
代码示例来源:origin: neo4j/neo4j
private Response createdResponse( TransactionHandle transactionHandle, StreamingOutput streamingResults )
{
return Response.created( transactionHandle.uri() )
.entity( streamingResults )
.build();
}
代码示例来源:origin: Graylog2/graylog2-server
@POST
@Timed
@ApiOperation(value = "Create a stream rule")
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
@AuditEvent(type = AuditEventTypes.STREAM_RULE_CREATE)
public Response create(@ApiParam(name = "streamid", value = "The stream id this new rule belongs to.", required = true)
@PathParam("streamid") String streamId,
@ApiParam(name = "JSON body", required = true)
@Valid @NotNull CreateStreamRuleRequest cr) throws NotFoundException, ValidationException {
checkPermission(RestPermissions.STREAMS_EDIT, streamId);
checkNotDefaultStream(streamId, "Cannot add stream rules to the default stream.");
// Check if stream exists
streamService.load(streamId);
final StreamRule streamRule = streamRuleService.create(streamId, cr);
final String id = streamRuleService.save(streamRule);
final SingleStreamRuleSummaryResponse response = SingleStreamRuleSummaryResponse.create(id);
final URI streamRuleUri = getUriBuilderToSelf().path(StreamRuleResource.class)
.path("{streamRuleId}")
.build(streamId, id);
return Response.created(streamRuleUri).entity(response).build();
}
代码示例来源:origin: lievendoclo/cleanarch
@POST
@Consumes("application/json")
@Path("{buildingId}/tenant")
public Response addTenant(@PathParam("buildingId") String buildingId, AddTenantToBuildingJsonPayload payload) {
final AtomicReference<String> id = new AtomicReference<>();
addTenantToBuilding.execute(new AddTenantToBuildingRequest(buildingId, payload.getName()), id::set);
return Response.created(UriBuilder.fromPath(GET_BUILDING_TENANT_URI_TEMPLATE).resolveTemplate("buildingId", buildingId).resolveTemplate("tenantId", id.get()).build()).build();
}
内容来源于网络,如有侵权,请联系作者删除!