@Override public String getName() { if (getMethod() == null) { if (name == null) { name = wadlMethod.getId(); if (name == null) { name = wadlMethod.getName(); Set<String> medias = null; if (GET.equals(name)) { medias = new HashSet<String>(); for( org.netbeans.modules.websvc.saas.model.wadl.Response response :wadlMethod.getResponse()) { medias.addAll(SaasUtil.getMediaTypes( response.getRepresentation())); } } else if (PUT.equals(name) || POST.equals(name)) { medias = SaasUtil.getMediaTypes( wadlMethod.getRequest().getRepresentation()); } name = name.toLowerCase(); if (medias != null && medias.size() > 0) { for (String m : medias) { name += "_" + m; } name = name.replaceAll("\\W", "_").replaceAll("_+", "_").replaceAll("_$", ""); } } } return name; } return super.getName(); }
@Override public String getDisplayName() { if (getMethod() == null) { if (displayName == null) { displayName = wadlMethod.getId(); if (displayName == null) { displayName = wadlMethod.getName(); Set<String> medias = null; if (GET.equals(displayName)) { medias = new HashSet<String>(); for( org.netbeans.modules.websvc.saas.model.wadl.Response response :wadlMethod.getResponse()) { medias.addAll(SaasUtil.getMediaTypes( response.getRepresentation())); } } else if (PUT.equals(displayName) || POST.equals(displayName)) { medias = SaasUtil.getMediaTypes( wadlMethod.getRequest().getRepresentation()); } if (medias != null && medias.size() > 0) { displayName += medias; } } } return displayName; } return super.getDisplayName(); }
/** * * @param positionId * @param employeeId * @return * returns javax.xml.ws.Response<ru.technoserv.ws.ChangePositionResponse> */ @WebMethod(operationName = "changePosition") @RequestWrapper(localName = "changePosition", targetNamespace = "http://ws.technoserv.ru/", className = "ru.technoserv.ws.ChangePosition") @ResponseWrapper(localName = "changePositionResponse", targetNamespace = "http://ws.technoserv.ru/", className = "ru.technoserv.ws.ChangePositionResponse") public Response<ChangePositionResponse> changePositionAsync( @WebParam(name = "employeeId", targetNamespace = "") int employeeId, @WebParam(name = "PositionId", targetNamespace = "") int positionId);
/** * * @param gradeId * @param employeeId * @return * returns javax.xml.ws.Response<ru.technoserv.ws.ChangeGradeResponse> */ @WebMethod(operationName = "changeGrade") @RequestWrapper(localName = "changeGrade", targetNamespace = "http://ws.technoserv.ru/", className = "ru.technoserv.ws.ChangeGrade") @ResponseWrapper(localName = "changeGradeResponse", targetNamespace = "http://ws.technoserv.ru/", className = "ru.technoserv.ws.ChangeGradeResponse") public Response<ChangeGradeResponse> changeGradeAsync( @WebParam(name = "employeeId", targetNamespace = "") int employeeId, @WebParam(name = "GradeId", targetNamespace = "") int gradeId);
/** * * @param employeeId * @param salary * @return * returns javax.xml.ws.Response<ru.technoserv.ws.ChangeSalaryResponse> */ @WebMethod(operationName = "changeSalary") @RequestWrapper(localName = "changeSalary", targetNamespace = "http://ws.technoserv.ru/", className = "ru.technoserv.ws.ChangeSalary") @ResponseWrapper(localName = "changeSalaryResponse", targetNamespace = "http://ws.technoserv.ru/", className = "ru.technoserv.ws.ChangeSalaryResponse") public Response<ChangeSalaryResponse> changeSalaryAsync( @WebParam(name = "employeeId", targetNamespace = "") int employeeId, @WebParam(name = "Salary", targetNamespace = "") BigDecimal salary);
protected final Response<Object> doInvoke(Object proxy, Object[] args, AsyncHandler handler) { AsyncInvoker invoker = new SEIAsyncInvoker(proxy, args); invoker.setNonNullAsyncHandlerGiven(handler != null); AsyncResponseImpl<Object> ft = new AsyncResponseImpl<Object>(invoker,handler); invoker.setReceiver(ft); ft.run(); return ft; }
public final Response<T> invokeAsync(T param) { Container old = ContainerResolver.getDefault().enterContainer(owner.getContainer()); try { if (LOGGER.isLoggable(Level.FINE)) { dumpParam(param, "invokeAsync(T)"); } AsyncInvoker invoker = new DispatchAsyncInvoker(param); AsyncResponseImpl<T> ft = new AsyncResponseImpl<T>(invoker,null); invoker.setReceiver(ft); ft.run(); return ft; } finally { ContainerResolver.getDefault().exitContainer(old); } }
@ResponseWrapper(localName = "avisoEntradasResponse", targetNamespace = "urn:es:caib:bantel:ws:v1:model:BantelFacade", className = "es.caib.bantel.wsClient.v1.model.AvisoEntradasResponse") @RequestWrapper(localName = "avisoEntradas", targetNamespace = "urn:es:caib:bantel:ws:v1:model:BantelFacade", className = "es.caib.bantel.wsClient.v1.model.AvisoEntradas") @WebMethod(operationName = "avisoEntradas") public Response<es.caib.bantel.wsClient.v1.model.AvisoEntradasResponse> avisoEntradasAsync( @WebParam(name = "numeroEntradas", targetNamespace = "urn:es:caib:bantel:ws:v1:model:BantelFacade") es.caib.bantel.wsClient.v1.model.ReferenciasEntrada numeroEntradas );
@ResponseWrapper(localName = "avisoEntradasResponse", targetNamespace = "urn:es:caib:bantel:ws:v2:model:BantelFacade", className = "es.caib.bantel.wsClient.v2.model.AvisoEntradasResponse") @RequestWrapper(localName = "avisoEntradas", targetNamespace = "urn:es:caib:bantel:ws:v2:model:BantelFacade", className = "es.caib.bantel.wsClient.v2.model.AvisoEntradas") @WebMethod(operationName = "avisoEntradas") public Response<es.caib.bantel.wsClient.v2.model.AvisoEntradasResponse> avisoEntradasAsync( @WebParam(name = "numeroEntradas", targetNamespace = "urn:es:caib:bantel:ws:v2:model:BantelFacade") es.caib.bantel.wsClient.v2.model.ReferenciasEntrada numeroEntradas );
@Override public void handleResponse(Response<T> res) { try { processResponse(res.get()); } catch (Exception e) { processException(e); } }
/** * * @param requests * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.GetPIArchiveDataResponse> */ @WebMethod(operationName = "GetPIArchiveData", action = "http://xml.osisoft.com/services/IPITimeSeries/GetPIArchiveData") @RequestWrapper(localName = "GetPIArchiveData", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPIArchiveData") @ResponseWrapper(localName = "GetPIArchiveDataResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPIArchiveDataResponse") public Response<GetPIArchiveDataResponse> getPIArchiveDataAsync( @WebParam(name = "requests", targetNamespace = "http://xml.osisoft.com/services/PIDataService") ArrayOfPIArcDataRequest requests);
/** * * @param evtFilter * @param maxWaitForUpdates * @param updateTicket * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.GetPIUpdatesResponse> */ @WebMethod(operationName = "GetPIUpdates", action = "http://xml.osisoft.com/services/IPITimeSeries/GetPIUpdates") @RequestWrapper(localName = "GetPIUpdates", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPIUpdates") @ResponseWrapper(localName = "GetPIUpdatesResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPIUpdatesResponse") public Response<GetPIUpdatesResponse> getPIUpdatesAsync( @WebParam(name = "updateTicket", targetNamespace = "http://xml.osisoft.com/services/PIDataService") String updateTicket, @WebParam(name = "maxWaitForUpdates", targetNamespace = "http://xml.osisoft.com/services/PIDataService") int maxWaitForUpdates, @WebParam(name = "evtFilter", targetNamespace = "http://xml.osisoft.com/services/PIDataService") UpdateFilterType evtFilter);
/** * * @param paths * @param expiration * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.SignUpForPIUpdatesResponse> */ @WebMethod(operationName = "SignUpForPIUpdates", action = "http://xml.osisoft.com/services/IPITimeSeries/SignUpForPIUpdates") @RequestWrapper(localName = "SignUpForPIUpdates", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.SignUpForPIUpdates") @ResponseWrapper(localName = "SignUpForPIUpdatesResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.SignUpForPIUpdatesResponse") public Response<SignUpForPIUpdatesResponse> signUpForPIUpdatesAsync( @WebParam(name = "paths", targetNamespace = "http://xml.osisoft.com/services/PIDataService") ArrayOfString paths, @WebParam(name = "expiration", targetNamespace = "http://xml.osisoft.com/services/PIDataService") int expiration);
/** * * @param updateTicket * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.CancelSignUpForPIUpdatesResponse> */ @WebMethod(operationName = "CancelSignUpForPIUpdates", action = "http://xml.osisoft.com/services/IPITimeSeries/CancelSignUpForPIUpdates") @RequestWrapper(localName = "CancelSignUpForPIUpdates", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.CancelSignUpForPIUpdates") @ResponseWrapper(localName = "CancelSignUpForPIUpdatesResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.CancelSignUpForPIUpdatesResponse") public Response<CancelSignUpForPIUpdatesResponse> cancelSignUpForPIUpdatesAsync( @WebParam(name = "updateTicket", targetNamespace = "http://xml.osisoft.com/services/PIDataService") String updateTicket);
/** * * @param updateTicket * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.ListPathsByUpdateTicketResponse> */ @WebMethod(operationName = "ListPathsByUpdateTicket", action = "http://xml.osisoft.com/services/IPITimeSeries/ListPaths") @RequestWrapper(localName = "ListPathsByUpdateTicket", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.ListPathsByUpdateTicket") @ResponseWrapper(localName = "ListPathsByUpdateTicketResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.ListPathsByUpdateTicketResponse") public Response<ListPathsByUpdateTicketResponse> listPathsByUpdateTicketAsync( @WebParam(name = "updateTicket", targetNamespace = "http://xml.osisoft.com/services/PIDataService") String updateTicket);
/** * * @param paths * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.GetPISnapshotDataResponse> */ @WebMethod(operationName = "GetPISnapshotData", action = "http://xml.osisoft.com/services/IPITimeSeries/GetPISnapshotData") @RequestWrapper(localName = "GetPISnapshotData", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPISnapshotData") @ResponseWrapper(localName = "GetPISnapshotDataResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPISnapshotDataResponse") public Response<GetPISnapshotDataResponse> getPISnapshotDataAsync( @WebParam(name = "paths", targetNamespace = "http://xml.osisoft.com/services/PIDataService") ArrayOfString paths);
/** * * @param requests * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.GetPISummaryDataResponse> */ @WebMethod(operationName = "GetPISummaryData", action = "http://xml.osisoft.com/services/IPITimeSeries/GetPISummaryData") @RequestWrapper(localName = "GetPISummaryData", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPISummaryData") @ResponseWrapper(localName = "GetPISummaryDataResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.GetPISummaryDataResponse") public Response<GetPISummaryDataResponse> getPISummaryDataAsync( @WebParam(name = "requests", targetNamespace = "http://xml.osisoft.com/services/PIDataService") ArrayOfPISummaryDataRequest requests);
/** * * @param events * @param duplicateSwitch * @return * returns javax.xml.ws.Response<com.osisoft.xml.services.pidataservice.InsertPIDataResponse> */ @WebMethod(operationName = "InsertPIData", action = "http://xml.osisoft.com/services/IPITimeSeries/InsertPIData") @RequestWrapper(localName = "InsertPIData", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.InsertPIData") @ResponseWrapper(localName = "InsertPIDataResponse", targetNamespace = "http://xml.osisoft.com/services/PIDataService", className = "com.osisoft.xml.services.pidataservice.InsertPIDataResponse") public Response<InsertPIDataResponse> insertPIDataAsync( @WebParam(name = "events", targetNamespace = "http://xml.osisoft.com/services/PIDataService") ArrayOfTimeSeries events, @WebParam(name = "duplicateSwitch", targetNamespace = "http://xml.osisoft.com/services/PIDataService") String duplicateSwitch);
@Test public void testMessageHandlerKeeping() throws URISyntaxException { MessageHandler mi = new TypedMessageHandler(Response.class, new ResponseHandler()); GossipManager gossipManager = builder.messageHandler(mi).registry(new MetricRegistry()).build(); assertNotNull(gossipManager.getMessageHandler()); Assert.assertEquals(gossipManager.getMessageHandler(), mi); }
@ResponseWrapper(localName = "GetRelevanceResultResponse", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.GetRelevanceResultResponse") @RequestWrapper(localName = "GetRelevanceResult", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.GetRelevanceResult") @WebMethod(operationName = "GetRelevanceResult") public Response<com.bigfix.schemas.relevance.GetRelevanceResultResponse> getRelevanceResultAsync( @WebParam(name = "relevanceExpr", targetNamespace = "http://schemas.bigfix.com/Relevance") java.lang.String relevanceExpr, @WebParam(name = "username", targetNamespace = "http://schemas.bigfix.com/Relevance") java.lang.String username, @WebParam(name = "password", targetNamespace = "http://schemas.bigfix.com/Relevance") java.lang.String password );
@ResponseWrapper(localName = "CreateUserResponse", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.CreateUserResponse") @RequestWrapper(localName = "CreateUser", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.CreateUser") @WebMethod(operationName = "CreateUser") public Response<com.bigfix.schemas.relevance.CreateUserResponse> createUserAsync( @WebParam(name = "user", targetNamespace = "http://schemas.bigfix.com/Relevance") com.bigfix.schemas.relevance.UserAccount user, @WebParam(name = "RequestHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) RequestHeader requestHeader, @WebParam(mode = WebParam.Mode.OUT, name = "ResponseHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) javax.xml.ws.Holder<ResponseHeader> responseHeader );
@ResponseWrapper(localName = "DeleteSharedVariableResponse", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.DeleteSharedVariableResponse") @RequestWrapper(localName = "DeleteSharedVariable", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.DeleteSharedVariable") @WebMethod(operationName = "DeleteSharedVariable") public Response<com.bigfix.schemas.relevance.DeleteSharedVariableResponse> deleteSharedVariableAsync( @WebParam(name = "dashboardVariableIdentifier", targetNamespace = "http://schemas.bigfix.com/Relevance") com.bigfix.schemas.relevance.DashboardVariableIdentifier dashboardVariableIdentifier, @WebParam(name = "RequestHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) RequestHeader requestHeader, @WebParam(mode = WebParam.Mode.OUT, name = "ResponseHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) javax.xml.ws.Holder<ResponseHeader> responseHeader );
@ResponseWrapper(localName = "GetStructuredRelevanceResultResponse", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.GetStructuredRelevanceResultResponse") @RequestWrapper(localName = "GetStructuredRelevanceResult", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.GetStructuredRelevanceResult") @WebMethod(operationName = "GetStructuredRelevanceResult") public Response<com.bigfix.schemas.relevance.GetStructuredRelevanceResultResponse> getStructuredRelevanceResultAsync( @WebParam(name = "relevanceExpr", targetNamespace = "http://schemas.bigfix.com/Relevance") java.lang.String relevanceExpr, @WebParam(name = "RequestHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) RequestHeader requestHeader, @WebParam(mode = WebParam.Mode.OUT, name = "ResponseHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) javax.xml.ws.Holder<ResponseHeader> responseHeader );
@ResponseWrapper(localName = "StoreSharedVariableResponse", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.StoreSharedVariableResponse") @RequestWrapper(localName = "StoreSharedVariable", targetNamespace = "http://schemas.bigfix.com/Relevance", className = "com.bigfix.schemas.relevance.StoreSharedVariable") @WebMethod(operationName = "StoreSharedVariable") public Response<com.bigfix.schemas.relevance.StoreSharedVariableResponse> storeSharedVariableAsync( @WebParam(name = "dashboardVariableIdentifier", targetNamespace = "http://schemas.bigfix.com/Relevance") com.bigfix.schemas.relevance.DashboardVariableIdentifier dashboardVariableIdentifier, @WebParam(name = "variableValue", targetNamespace = "http://schemas.bigfix.com/Relevance") java.lang.String variableValue, @WebParam(name = "RequestHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) RequestHeader requestHeader, @WebParam(mode = WebParam.Mode.OUT, name = "ResponseHeaderElement", targetNamespace = "http://schemas.bigfix.com/Relevance", header = true) javax.xml.ws.Holder<ResponseHeader> responseHeader );
@Override public void handleResponse(Response<String> response) { try { res = response.get(); } catch (Exception e) { e.printStackTrace(); res = e.getMessage(); } }
@Test @RunAsClient public void testInvokeAsynch() throws Exception { Source reqObj = new StreamSource(new StringReader(reqPayload)); Dispatch<Source> dispatch = createDispatch(); Response<Source> response = dispatch.invokeAsync(reqObj); verifyResponse(response.get(3000, TimeUnit.MILLISECONDS)); }
@Override public Future<?> downloadCampaignsByAccountIdsAsync(DownloadCampaignsByAccountIdsRequest parameters, AsyncHandler<DownloadCampaignsByAccountIdsResponse> asyncHandler) { onDownloadCampaignsByAccountIds.accept(parameters); Response response = new CompleteResponse(getDownloadCampaignsByAccountIdsResponse.get(), getInboundHeadersSupplier().get()); if (asyncHandler != null) { asyncHandler.handleResponse(response); } return response; }
public Response getLocation(String addressFrom, String addressTo){ findByState() }
Response<?> invoke(Object proxy, Object[] args) throws WebServiceException { return doInvoke(proxy,args,null); }
@Override public Response<HeartbeatResponse> heartbeatAsync(HeartbeatRequest parameters, String chargeBoxIdentity) { return null; }